七叶笔记 » golang编程 » Golang入门系列(十) 如何操作Mysql,详细介绍

Golang入门系列(十) 如何操作Mysql,详细介绍

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

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

一、安装

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

github网址:。

 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_select(sql_data string) {   //select 查询数据
   sql_data :="select departID,departName,memo from depart"
    fmt.Println("sql:", sql_data)
    rows, err := f.db.Query(sql_data)
    if err != nil {
        fmt.Println("查询失败")
    }
    for rows.Next() {
        var departID int
        var departName string
        var memo string
        err = rows.Scan(&departID, &departName, &memo)
        if err != nil {
            panic(err)
        }
        fmt.Println("departName:", departName)
    }

}  

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()
    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相关第三方框架,但是底层原理还是要学的。分享关注( 章为忠学架构 )获取完整代码。

推荐阅读:

相关文章