我正在寻找一个可靠的解决方案来从 Go 连接到 MySQL 数据库。我见过一些图书馆,但很难确定完整性和当前维护的不同状态。我没有复杂的需求,但我想知道人们在依赖什么,或者连接 MySQL 的最标准解决方案是什么。
问问题
70712 次
2 回答
266
有一些驱动程序可用,但您应该只考虑那些实现database/sql API 的驱动程序
- 它提供了简洁高效的语法,
- 它确保您以后可以在不更改代码的情况下更改驱动程序,除了导入和连接。
MySQL 有两个快速可靠的驱动程序:
我已经在生产中使用了它们,程序运行了几个月,连接数以百万计,没有失败。
go-wiki 上列出了其他 SQL 数据库驱动程序。
使用 MyMySQL 时导入:
import (
"database/sql"
_ "github.com/ziutek/mymysql/godrv"
)
使用 Go-MySQL-Driver 时导入:
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
使用 MyMySQL 连接和关闭:
con, err := sql.Open("mymysql", database+"/"+user+"/"+password)
defer con.Close()
// here you can use the connection, it will be closed when function returns
使用 Go-MySQL-Driver 连接和关闭:
con, err := sql.Open("mysql", store.user+":"+store.password+"@/"+store.database)
defer con.Close()
选择一行:
row := con.QueryRow("select mdpr, x, y, z from sometable where id=?", id)
cb := new(SomeThing)
err := row.Scan(&cb.Mdpr, &cb.X, &cb.Y, &cb.Z)
选择多行并构建一个带有结果的数组:
rows, err := con.Query("select a, b from item where p1=? and p2=?", p1, p2)
if err != nil { /* error handling */}
items := make([]*SomeStruct, 0, 10)
var ida, idb uint
for rows.Next() {
err = rows.Scan(&ida, &idb)
if err != nil { /* error handling */}
items = append(items, &SomeStruct{ida, idb})
}
插入 :
_, err = con.Exec("insert into tbl (id, mdpr, isok) values (?, ?, 1)", id, mdpr)
你会看到在 Go 中使用 MySQL 是一种令人愉快的体验:我从来没有遇到过问题,我的服务器运行了几个月没有错误或泄漏。大多数函数仅采用可变数量的参数这一事实减轻了在许多语言中繁琐的任务。
请注意,如果将来您需要使用另一个 MySQL 驱动程序,您只需在一个 go 文件中更改两行:执行导入的行和打开连接的行。
于 2012-07-06T06:41:20.380 回答
2
有几件事需要注意选择 1 行示例:
row := con.QueryRow("select mdpr, x, y, z from sometable where id=?",id)
cb := new(SomeThing)
err := row.Scan(&cb.Mdpr, &cb.X, &cb.Y, &cb.Z)
此示例中缺少一个row.Next()
。它需要调用row.Next()
来获取返回的第一行。
图书馆也有一些不灵活,这在某种程度上试图促进数据极简主义。如果您尝试选择不是 Scan 的列,它将引发错误(不仅仅是警告)
于 2014-06-15T09:35:20.023 回答