Golang 入门系列(十) mysql数据库的使用

之前，已经讲过一些Golang的基础的东西，感兴趣的可以看看以前的文章，https://www.cnblogs.com/zhangweizhong/category/1275863.html，

今天简单介绍下Golang是如何使用mysql数据库的。由于Go本身不提供具体数据库驱动，只提供驱动接口和管理。各个数据库驱动需要第三方实现，并且注册到Go中的驱动管理中。github上面的mysql驱动有好几个，我在这里选择的https://github.com/go-sql-driver/mysql。

下面主要从增删查改以及事物等方面介绍go语言中mysql的使用

一、连接数据库

使用sql.Open()函数打开数据库连接，数据库的连接字符串（dsn）格式如下：

admin:123456@tcp(10.2.1.5)/irisapp

代码如下：

func (f *mysql_db) mysql_open() {db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)if err != nil {fmt.Println("链接失败")}fmt.Println("链接成功")f.db = db
}

二、插入

func (f *mysql_db) mysql_insert() { //insert  添加数据fmt.Println("开始插入")stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")//defer stmt.Close()if err != nil {fmt.Println("插入失败")return}stmt.Exec("dd", "adadcccda")fmt.Println("插入成功")
}

三、查询

func (f *mysql_db) mysql_select(sql_data string) {   //select 查询数据fmt.Println("sql:", sql_data)rows, err := f.db.Query(sql_data)if err != nil {fmt.Println("查询失败")}for rows.Next() {var departID intvar departName stringvar memo stringerr = rows.Scan(&departID, &departName, &memo)if err != nil {panic(err)}fmt.Println("departName:", departName)}}

四、更新

func (f *mysql_db) mysql_update() { //update  修改数据stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?")//defer stmt.Close()if err != nil {//错误处理
    }result,_ := stmt.Exec("aa","asdfadsadsfa",1)if result == nil {fmt.Println("修改失败")}affect_count,_ := result.RowsAffected()    //返回影响的条数,注意有两个返回值fmt.Println("%v",affect_count)
}

五、删除

func (f *mysql_db) mysql_delete() { //delete  删除数据stmt, err := f.db.Prepare("delete from depart where departId=?")//defer stmt.Close()if err != nil {//错误处理
    }stmt.Exec(2)     //不返回任何结果fmt.Println("删除成功")
}

六、事物

func (f *mysql_db) mysql_tran(){//事务tx,err := f.db.Begin()        //声明一个事务的开始if err != nil {fmt.Println(err)return}insert_sql := "insert into depart (departName,memo) VALUES(?,?)"insert_stmt,insert_err := tx.Prepare(insert_sql)if insert_err != nil {fmt.Println(insert_err)return}insert_res,insert_err := insert_stmt.Exec("ff","ff")last_insert_id,_ := insert_res.LastInsertId()fmt.Println(last_insert_id)// defer tx.Rollback()            //回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的tx.Commit()                        //这里提交了上面的操作，所以上面的执行的sql 会在数据库中产生一条数据
}

调用

func main() {db := &mysql_db{}db.mysql_open()db.mysql_insert()db.mysql_update()db.mysql_delete()db.mysql_tran()db.mysql_select("select departID,departName,memo from depart")db.mysql_close() //关闭

}

启动后输出如下：

D:\Go_Path\go\src\mysqldemo>go run mysqldemo.go
链接成功
开始插入
插入成功
0
删除成功
10
sql: select departID,departName,memo from depart
departName: aa
departName: dd
departName: dd
departName: dd
departName: dd
departName: dd
departName: ff
departName: dd
departName: ff

完整代码

package mainimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql")var (dbhostsip  = "10.2.1.5:3306"dbusername = "admin"dbpassword = "123456"dbname     = "irisapp"
)type mysql_db struct {db *sql.DB
}func (f *mysql_db) mysql_open() {db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)if err != nil {fmt.Println("链接失败")}fmt.Println("链接成功")f.db = db
}func (f *mysql_db) mysql_close() {defer f.db.Close()
}func (f *mysql_db) mysql_select(sql_data string) {   //select 查询数据fmt.Println("sql:", sql_data)rows, err := f.db.Query(sql_data)if err != nil {fmt.Println("查询失败")}for rows.Next() {var departID intvar departName stringvar memo stringerr = rows.Scan(&departID, &departName, &memo)if err != nil {panic(err)}fmt.Println("departName:", departName)}}func (f *mysql_db) mysql_insert() { //insert  添加数据fmt.Println("开始插入")stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")//defer stmt.Close()if err != nil {fmt.Println("插入失败")return}stmt.Exec("dd", "adadcccda")fmt.Println("插入成功")
}func (f *mysql_db) mysql_update() { //update  修改数据stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?")//defer stmt.Close()if err != nil {//错误处理
    }result,_ := stmt.Exec("aa","asdfadsadsfa",1)if result == nil {fmt.Println("修改失败")}affect_count,_ := result.RowsAffected()    //返回影响的条数,注意有两个返回值
    fmt.Println(affect_count)
}func (f *mysql_db) mysql_delete() { //delete  删除数据stmt, err := f.db.Prepare("delete from depart where departId=?")//defer stmt.Close()if err != nil {//错误处理
    }stmt.Exec(2)     //不返回任何结果fmt.Println("删除成功")
}func (f *mysql_db) mysql_tran(){//事务tx,err := f.db.Begin()        //声明一个事务的开始if err != nil {fmt.Println(err)return}insert_sql := "insert into depart (departName,memo) VALUES(?,?)"insert_stmt,insert_err := tx.Prepare(insert_sql)if insert_err != nil {fmt.Println(insert_err)return}insert_res,insert_err := insert_stmt.Exec("ff","ff")last_insert_id,_ := insert_res.LastInsertId()fmt.Println(last_insert_id)// defer tx.Rollback()            //回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的tx.Commit()                        //这里提交了上面的操作，所以上面的执行的sql 会在数据库中产生一条数据
}func main() {db := &mysql_db{}db.mysql_open()db.mysql_insert()db.mysql_update()db.mysql_delete()db.mysql_tran()db.mysql_select("select departID,departName,memo from depart")db.mysql_close() //关闭

}

View Code

总结

1. 支持预备表达式，可以用来优化SQL查询提高性能，减少SQL注入的风险, db.Prepare()和 tx.Prepare 都提供了对于预备表达式的支持。

2. LastInsertId()　　获取插入第一条的id

3. RowsAffected()　　获取影响/插入的条数

4. 这里只是简单介绍了go语言开发中mysql在go语言开发中的基本使用，其实真正开发过程中还是主要使用orm相关第三方框架，但是底层原理还是要学的。

转载于:https://www.cnblogs.com/zhangweizhong/p/10517987.html