Go原生就支持连接数据库,所以在使用 Golang 开发时,当需要数据库交互时,即可使用database/sql包。
在Go中访问DB需用sql.DB接口:可创建语句(statement)和事务(transaction),执行查询,获取结果。
使用DB时,除database/sql包,还需引入想使用的特定DB驱动。官方不提供实现,需要先下载三方实现,点击这里查看各种各样的实现版本。
通常DB选型MySQL,所以选型驱动为:github.com/go-sql-driver/mysql,需引入包:
"database/sql" _ "github.com/go-sql-driver/mysql"
包名前的"_"
import 下划线(如:import _ github/demo)的作用:当导入一个包时,该包下的文件里所有init()函数都会被执行,然而,有些时候我们并不需要把整个包都导入进来,仅仅是是希望它执行init()函数而已。这个时候就可以使用 import _ 引用该包。
上面的MySQL驱动中引入的就是MySQL包中各个init()方法,你无法通过包名来调用包中的其他函数。导入时,驱动的初始化函数会调用sql.Register将自己注册在database/sql包的全局变量sql.drivers中,以便以后通过sql.Open访问。
案例用数据表
初始化数据库连接
sql.Open()中的数据库连接串格式为:"用户名:密码@tcp(IP:端口)/数据库?charset=utf8"。DB的类型为:*sql.DB,有DB后即可执行CRUD。
Go将数据库操作分为两类:Query与Exec
Query表示查询,它会从数据库获取查询结果(一系列行,可能为空)。
Exec表示执行语句,它不会返回行。
常见数据库操作模式:
QueryRow只返回一行的查询,作为Query的一个常见特例。
Prepare准备一个需要多次使用的语句,供后续执行用。
查询操作
var user User rows, e := DB.Query("select * from user where id in (1,2,3)") if e == nil { errors.New("query incur error") } for rows.Next(){ e := rows.Scan(user.sex, user.phone, user.name, user.id, user.age) if e != nil{ fmt.Println(json.Marshal(user)) } } rows.Close() // 单行查询操作 DB.QueryRow("select * from user where id=1").Scan(user.age, user.id, user.name, user.phone, user.sex)