database/sql 与驱动程序
DB 设置、QueryRow、Scan 与连接池
database/sql 与驱动程序 是 CoddyKit 上的免费 Go Academy 课时。 这是第 1 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Go Academy 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 Go Academy 课程共包含 4 节课。
database/sql 概览
database/sql 是 Go 的标准数据库抽象层。它管理连接池,并通过驱动插件与任何数据库配合使用。
注册驱动
导入驱动软件包以执行其副作用(注册驱动)。然后打开连接:
import _ "github.com/lib/pq" // PostgreSQL driver
db, err := sql.Open("postgres", "postgres://user:pass@localhost/mydb?sslmode=disable")
if err != nil { log.Fatal(err) }
defer db.Close()sql.Open 与 db.Ping
sql.Open 不会建立连接——它只会校验 DSN。调用 db.Ping() 或 db.PingContext(ctx) 来确认连接处于活动状态。
if err := db.Ping(); err != nil { log.Fatal(err) }查询行
使用 db.QueryContext 执行 SELECT 并扫描行:
rows, err := db.QueryContext(ctx, "SELECT id, name FROM users WHERE active = $1", true)
if err != nil { return err }
defer rows.Close()
for rows.Next() {
var id int; var name string
rows.Scan(&id, &name)
}单行查询
对于预期最多返回一条结果的查询,db.QueryRowContext 会返回一个 *Row:
var name string
err := db.QueryRowContext(ctx, "SELECT name FROM users WHERE id = $1", id).Scan(&name)
if errors.Is(err, sql.ErrNoRows) { /* not found */ }执行数据变更
对 INSERT、UPDATE、DELETE 使用 db.ExecContext。它会返回一个 Result,其中包含受影响的行数和最后插入的 ID。
result, err := db.ExecContext(ctx, "INSERT INTO users(name) VALUES($1)", name)
if err != nil { return err }
id, _ := result.LastInsertId()预处理语句
预先准备一次语句,然后高效地执行多次:
stmt, err := db.PrepareContext(ctx, "SELECT id FROM users WHERE email = $1")
defer stmt.Close()
for _, email := range emails {
row := stmt.QueryRowContext(ctx, email)
}连接池设置
为生产环境配置连接池:
db.SetMaxOpenConns(25)
db.SetMaxIdleConns(25)
db.SetConnMaxLifetime(5 * time.Minute)检查 rows.Err()
完成行循环后,务必检查 rows.Err()——循环可能因网络错误而提前退出。
if err := rows.Err(); err != nil { return err }空值
使用 sql.NullString、sql.NullInt64 等处理数据库 NULL 值;否则,将其扫描到非指针 Go 类型中时可能引发 panic。
var bio sql.NullString
rows.Scan(&bio)
if bio.Valid { fmt.Println(bio.String) }驱动列表
常用驱动:github.com/lib/pq(PostgreSQL)、github.com/go-sql-driver/mysql(MySQL)、modernc.org/sqlite(SQLite,纯 Go 实现)。
快速检查
查询后为什么必须始终调用 rows.Close() 并检查 rows.Err()?
回顾:database/sql
要点:
- 使用 _ 导入驱动以执行副作用;然后调用 sql.Open + Ping
- QueryContext → rows.Next + Scan + rows.Close + rows.Err
- 对数据变更使用 ExecContext;对单行查询使用 QueryRowContext
- 使用 SetMaxOpenConns、SetMaxIdleConns、SetConnMaxLifetime 配置连接池
常见问题解答
「database/sql 与驱动程序」课时是免费的吗?
是的 — 「database/sql 与驱动程序」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 Go Academy 课程的其余内容,请升级到 CoddyKit PRO。 Go Academy 课程共包含 4 节课。
「database/sql 与驱动程序」这节课中我会学到什么?
DB 设置、QueryRow、Scan 与连接池 你通过在浏览器中直接运行的动手代码来练习 Go Academy,全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Go Academy 需要有经验吗?
无需任何先前经验。CoddyKit 上的 Go Academy 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 1 节课,共 4 节。
「database/sql 与驱动程序」课时需要多长时间?
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。
我能在这节 Go Academy 课中编写并运行代码吗?
能。每节 Go Academy 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。
此课程中的所有课时
- database/sql 与驱动程序
- sqlx:结构体扫描与命名查询
- pgx:高性能 PostgreSQL 驱动程序
- 事务与迁移