本文介绍了使用 go 的 database/sql 包操作 mysql 实现 crud 的方法。1. 安装 go-sql-driver/mysql 驱动并正确导入；2. 使用 sql.open 初始化连接池并通过 db.ping 检测连接，合理设置连接数限制；3. 查询时使用 db.query 或 db.queryrow，并注意资源释放和字段匹配；4. 插入数据使用 db.exec 并获取插入 id，建议用结构体管理参数；5. 更新和删除同样使用 db.exec，注意 where 条件避免误删；6. 严格处理错误、防止 sql 注入、并发控制及日志记录是关键保障措施。
刚开始学 Golang 的时候，操作数据库是个绕不开的环节。MySQL 是一个很常见的选择，而 Go 标准库中的 database/sql 提供了很好的支持。虽然它本身不包含具体的驱动实现，但配合像 go-sql-driver/mysql 这样的第三方驱动，可以很好地完成 CRUD 操作。
下面我们就一步步来看看怎么用 database/sql 实现对 MySQL 的增删改查。
安装依赖和连接数据库
要使用 MySQL，首先得安装对应的驱动：
立即学习“go语言免费学习笔记（深入）”；
go get -u github.com/go-sql-driver/mysql
然后在代码中导入：
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)连接数据库时需要构造 DSN（Data Source Name），格式大致如下：
dsn := "user:password@tcp(127.0.0.1:3306)/dbname"
db, err := sql.Open("mysql", dsn)
if err != nil {
log.Fatal(err)
}这里需要注意几点：
-
sql.Open并不会立即建立连接，只是初始化了一个连接池 - 真正测试连接是否正常可以用
db.Ping()方法 - 建议设置最大打开连接数和最大空闲连接数，比如：
db.SetMaxOpenConns(20) db.SetMaxIdleConns(10)
查询数据（Read）
查询是最常见的操作之一。基本流程是准备 SQL、执行查询、遍历结果：
rows, err := db.Query("SELECT id, name FROM users WHERE age > ?", 18)
if err != nil {
log.Fatal(err)
}
defer rows.Close()
for rows.Next() {
var id int
var name string
if err := rows.Scan(&id, &name); err != nil {
log.Fatal(err)
}
fmt.Println(id, name)
}几点建议：
- 记得调用
rows.Close()避免资源泄露 - 使用
rows.Scan时要注意字段顺序和类型匹配 - 如果只期望一行结果，可以用
db.QueryRow更简洁
插入数据（Create）
插入操作通常使用 Exec 方法，返回的是 sql.Result，里面包含最后插入 ID 和受影响行数：
result, err := db.Exec("INSERT INTO users (name, email) VALUES (?, ?)", "Tom", "tom@example.com")
if err != nil {
log.Fatal(err)
}
lastID, _ := result.LastInsertId()
fmt.Println("Last inserted ID:", lastID)注意事项：
- 字段多的时候建议使用结构体绑定参数，避免写错顺序
- 可以使用命名参数库（如
sqlx）来提升可读性，但原生库不支持
更新和删除（Update & Delete）
更新和删除本质上都是“写”操作，使用方式类似：
res, err := db.Exec("UPDATE users SET name = ? WHERE id = ?", "Jerry", 1)
if err != nil {
log.Fatal(err)
}
rowsAffected, _ := res.RowsAffected()
fmt.Println("Rows affected:", rowsAffected)删除操作同理：
res, err := db.Exec("DELETE FROM users WHERE id = ?", 1)注意点：
- 一定要小心 WHERE 条件，尤其是 DELETE 操作
- 测试环境建议加事务或备份机制，防止误删
处理错误和常见问题
Go 中处理数据库错误非常重要。例如：
- 查询时如果字段名拼错了，
Scan会报错 - 如果传参类型不匹配，也可能导致执行失败
建议的做法：
- 每次调用都检查 error
- 使用
log.Fatal或自定义日志记录来定位问题 - 开启慢查询日志，排查性能瓶颈
另外一些容易出错的地方：
- 忘记关闭
rows - 没有正确使用占位符导致 SQL 注入风险
- 多个 goroutine 共享连接池时没有合理控制并发
基本上就这些内容了。刚上手的时候可能觉得有点繁琐，但熟悉之后你会发现 database/sql 虽然不提供 ORM 功能，但它足够灵活，也更容易掌控底层行为。只要注意好错误处理和连接管理，CRUD 操作其实并不复杂。
