IT业界：Golang入门系列(十) 如何操作Mysql，详细介绍

作者:课课家教育更新于： 2020-07-03 21:59:57

Go的目标是希望提升现有编程语言对程序库等依赖性(dependency)的管理，这些软件元素会被应用程序反复调用。由于存在并行编程模式，因此这一语言也被设计用来解决多处理器的任务。

之前，已经讲过一些Golang的基础的东西，感兴趣的可以看看以前的文章，

今天简单介绍下Golang是如何使用MySQL数据库的。下面主要从增删查改以及事物等方面介绍go语言中mysql的使用。

一、安装

由于Go本身不提供具体数据库驱动，只提供驱动接口和管理。各个数据库驱动需要第三方实现，并且注册到Go中的驱动管理中。github上面的mysql驱动有好几个，我在这里选择go-sql-driver。

admin:123456@tcp(10.2.1.5)/irisapp

二、连接数据库

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

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")

   id,_ := result.LastInsertId()

    fmt.Println("插入成功")

}

代码如下：

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

}

说明：返回的DB可以安全的被多个goroutine同时使用，并会维护自身的闲置连接池。这样一来，Open函数只需调用一次。很少需要关闭DB。

三、增删改查

简单说明下是如何实现增删改查的：

• 通过 Exec() 方法插入、修改和删除数据的操作，返回的结果是 sql.Result 类型
• 通过Query() 方法执行查询操作。
• 支持预备表达式，可以用来优化SQL查询提高性能，减少SQL注入的风险, db.Prepare()和 tx.Prepare 都提供了对于预备表达式的支持。
• LastInsertId() 获取插入第一条的id。
• RowsAffected() 获取影响/插入的条数。

1、插入

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")

   id,_ := result.LastInsertId()

    fmt.Println("插入成功")

}

说明：

1. 可以通过LastInsertId() 获取插入的id 。

2. 提供了对于预备表达式的支持 db.Prepare()，减少SQL注入的风险,。

2、查询

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("删除成功")

}

3、更新

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)

}

说明：RowsAffected() 返回影响的条数,注意有两个返回值。

4、删除

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

 总结

这里只是简单介绍了go语言开发中mysql在go语言开发中的基本使用，其实真正开发过程中还是主要使用orm相关第三方框架，但是底层原理还是要学的。分享关注（章为忠学架构）获取完整代码。

Go语言是谷歌2009发布的第二款开源编程语言。

Go语言专门针对多处理器系统应用程序的编程进行了优化，使用Go编译的程序可以媲美C或C++代码的速度，而且更加安全、支持并行进程。