欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

简单讲解Go程序中使用MySQL的方法

程序员文章站 2022-08-29 09:18:36
go官方仅提供了database package,database package下有两个包sql,sql/driver。这两个包用来定义操作数据库的接口,这就保证了无论使...

go官方仅提供了database package,database package下有两个包sql,sql/driver。这两个包用来定义操作数据库的接口,这就保证了无论使用哪种数据库,他们的操作方式都是相同的。


但go官方并没有提供连接数据库的driver,如果要操作数据库,还需要第三方的driver 包,幸好,主流的数据库的driver都已经有了:https://code.google.com/p/go-wiki/wiki/sqldrivers

其中,mysql有两个包,一个是mymysql,一个是go-sql-driver/mysql,两个package都是纯go实现。我选择了后者,因为后者的效率更高一点,benchmark在这里:https://github.com/go-sql-driver/sql-benchmark
sql包的用法简洁明了:
1、建立连接
首先是open,

复制代码 代码如下:
db, err := sql.open(“mysql”, “user:password@/dbname”)

db 是一个*sql.db类型的指针,在后面的操作中,都要用到db
open之后,并没有与数据库建立实际的连接,与数据库建立实际的连接是通过ping方法完成。此外,db应该在整个程序的生命周期中存在,也就是说,程序一启动,就通过open获得db,直到程序结束,再close db,而不是经常open/close。
复制代码 代码如下:
err = db.ping()

2、基本用法
db的主要方法有:
query 执行数据库的query操作,例如一个select语句,返回*rows

queryrow 执行数据库至多返回1行的query操作,返回*row

prepare 准备一个数据库query操作,返回一个*stmt,用于后续query或执行。这个stmt可以被多次执行,或者并发执行

exec 执行数不返回任何rows的据库语句,例如delete操作

3、简单实例

复制代码 代码如下:

package main

import (
 "database/sql"
 "fmt"
 _ "github.com/go-sql-driver/mysql"
)

type user struct {
 id                 int
 username, password string
}

var sqldata map[interface{}]interface{}

func main() {
 var u user
 db, err := sql.open("mysql", "root:@/test?charset=utf8")
 check(err)
 插入数据
 stmt, err := db.prepare("insert user set username=?,password=?")
 check(err)
 res, err := stmt.exec("xiaowei", "xiaowei")
 check(err)
 id, err := res.lastinsertid()
 check(err)
 fmt.println(id)
 //查询数据
 rows, err := db.query("select * from user")
 check(err)

 fmt.println(rows.columns())
 userinfo := make(map[interface{}]interface{})
 for rows.next() {
  err := rows.scan(&u.id, &u.username, &u.password)
  check(err)
  userinfo[u.id] = u
 }
 fmt.println(userinfo)
}

func check(err error) {
 if err != nil {
  fmt.println(err)
 }
}