0Pricing
Go Academy · 课时

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 反馈 — 无需本地设置。

此课程中的所有课时

  1. database/sql 与驱动程序
  2. sqlx:结构体扫描与命名查询
  3. pgx:高性能 PostgreSQL 驱动程序
  4. 事务与迁移
← 返回 Go Academy