本文介绍了使用 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)
}几点建议:
PHP是一种功能强大的网络程序设计语言,而且易学易用,移植性和可扩展性也都非常优秀,本书将为读者详细介绍PHP编程。 全书分为预备篇、开始篇和加速篇三大部分,共9章。预备篇主要介绍一些学习PHP语言的预备知识以及PHP运行平台的架设;开始篇则较为详细地向读者介绍PKP语言的基本语法和常用函数,以及用PHP如何对MySQL数据库进行操作;加速篇则通过对典型实例的介绍来使读者全面掌握PHP。 本书
- 记得调用
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 操作其实并不复杂。









