Golang database/sql是一套统一的访问数据库的抽象接口，真正与数据库打交道的是各个数据库对应的驱动实现，在使用时需要先注册对应驱动，然后就可以使用sql中定义的接口统一操作数据库。

连接池sql.DB

import (
	"database/sql"
	_ "github.com/go-sql-driver/mysql"
)
func main() {
	db, err := sql.Open("mysql",
		"user:password@tcp(127.0.0.1:3306)/hello")
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()
        err = db.Ping()
        if err != nil {
	     // do something here
        }
}

sql.DB刚开始建立时是懒加载的，不会自动创建新的连接，只有使用Ping()或者运行查询时才会自动生成一个新的连接然后去连接数据库，只有这个时候才能确定数据库是否真的OK，所以建议一定要在sql.Open后运行Ping()确定数据连接正常运行。

sql.DB是连接后初始化的一个连接池，通常全局就初始化这一个连接池，并且长期运行，所有后续数据库操作都使用该连接池进行。sql.DB内部自动维护连接池，当需要连接时自动选择一个空闲的连接，如果没有空闲就建立一个新的连接，当连接不再使用时放回连接池中，内部会自动管理空闲回收。

数据库的连接是一个比较大的耗时和资源消耗操作，首选需要经典的TCP三次握手，tcp连接后数据库需要分配连接资源，同时根据连接信息鉴权等，所以建议使用长连接。对应到我们的go中，sql.DB会自动管理连接池，最好全局使用一个连接池，不要重复的open或者close。

查询

sql.DB支持4种查询：

db.Query()    
db.QueryRow()
db.Prepare(sql)   stmt.Query(args)
db.Exec()

• db.Query() 返回多行数据，需要依次遍历，并且需要自己关闭查询结果集
• db.QueryRow() 是专门查询一行数据的一个语法糖，返回ErrNoRow或者一行数据，不需要自己关闭结果集
• db.Prepare() 是预先将一个数据库连接（con）和一个条sql语句绑定并返回stmt结构体代表这个绑定后的连接，然后运行stmt.Query()或者stmt.QueryRow()；stmt是并发安全的。之所以这样设计，是因为每次直接调用db.Prepare都会自动选择一个可用的con，每次选择的可能不是同一个con
• db.Exec() 适用于执行insert、update、delete等不需要返回结果集的操作

结果集

只有db.Query()返回结果集

var (
	id int
	name string
)
rows, err := db.Query("select id, name from users where id = ?", 1)
if err != nil {
	log.Fatal(err)
}
defer rows.Close()
for rows.Next() {
	err := rows.Scan(&id, &name)
	if err != nil {
		log.Fatal(err)
	}
	log.Println(id, name)
}
err = rows.Err()
if err != nil {
	log.Fatal(err)
}

• 首先检查结果集返回时是否有error

1. 如果有error，直接操作error
2. 如果无error，defer rows.Close()，确保结果集最终关闭，这样才能释放连接回连接池，Close是可以重复调用的，关闭已经关闭的结果集不会报错

• 遍历结果集

1. 使用for rows.Next()遍历结果集，这样迭代一行一行处理结果，节约内存分配，同时防止出现OOM的问题
2. 使用rows.Scan将一行数据填入指定的变量中，scan会自动根据目标变量的类型处理类型转换的问题，比如数据库中是varchar，但目标变量是int，那么scan会自动转换，当然如果转化出现error会返回error

事务

tx := db.Begin()
tx.Commit()
tx.Rollback()

事务是使用db.begin开始，以db.commit/db.rollback结束

普通的db.Query/db.QueryRow自动从连接池中选择一个可用连接，运行结束后会自动将连接放回连接池，下次运行再次重复这个过程

db.begin会自动从连接池中选择一个连接并返回一直持有该连接的tx（和db.Prepare有点像），后续所有事务操作都用tx，这样能保证是在用一个连接内运行事务，只有commit/rollback才会释放连接

Error处理

• 结果集遍历后error，每次for rows.Next结束后要跟一个rows.Err()检测

for rows.Next() {
	// ...
}
if err = rows.Err(); err != nil {
	// handle the error here
}

• 结果集遍历close error

if err = rows.Close(); err != nil {
	// but what should we do if there's an error?
	log.Println(err)
}

• QueryRow() Error

err = db.QueryRow("select name from users where id = ?", 1).Scan(&name)
if err != nil {
	log.Fatal(err)
}

QueryRow的结果是在Scan时才会出现

• Mysql特定Error

if driverErr, ok := err.(*mysql.MySQLError); ok { // Now the error number is accessible directly
	if driverErr.Number == 1045 {
		// Handle the permission-denied error
	}
}

• 连接没释放问题

1. 事务没有commit或者rollback
2. 查询集没有close

• 查询参数问题

1. Mysql使用？做参数，防止sql注入
2. 既然是参数，就只能当参数，不可以用于其他部分，也不能做插值

标准库sql不支持但常用的特性

• 不支持多条sql执行
• 不支持返回多个结果集
• 不支持存储过程（Mysql驱动目前不支持）
• 不支持Scan到map、struct
• 不建议uint64

第三方扩展库github.com/jmoiron/sqlx

简化连接

db = sqlx.MustConnect("sqlite3", ":memory:")  // sql.Open+db.Ping

便捷功能

• StructScan 、SliceScan、MapScan
• Get、Select
• MustExec
• 支持命名参数
• 支持IN查询自动展开参数

Get、Select类似于QueryRow和Query，但Get和Select可以自动将结果Scan到特定数据

Struct字段必须能导出，且根据db tag（如果没有就用小写字段名）进行匹配