2. 数据库事务入门：database/sql包基础、连接池管理、事务对象获取

在Go语言中操作关系型数据库，database/sql是标准库提供的核心抽象层。它不直接驱动具体数据库，而是定义了一套通用接口，由第三方驱动（如 go-sql-driver/mysql、lib/pq）实现。理解这个包的设计哲学，是掌握事务边界的第一步。

2.1 database/sql 核心抽象

database/sql 包围绕三个核心类型构建：

类型	职责	生命周期
sql.DB	数据库连接池的抽象，代表零个或多个底层连接的集合	应用级单例，通常全局初始化一次
sql.Conn	代表一个真实的底层数据库连接，从连接池中取出	显式获取和释放，用于需要连接绑定的场景
sql.Tx	代表一个数据库事务，绑定在一个连接上	Begin → 执行SQL → Commit 或 Rollback

2.2 连接池管理机制

连接池是 database/sql 高性能的基石。它维护着一组可复用的数据库连接，避免每次请求都经历TCP握手、认证等开销。连接池的核心参数通过 sql.DB 的方法设置：

方法	作用	默认值	建议
SetMaxOpenConns(n int)	最大打开连接数（含正在使用的）	0（无限制）	根据数据库上限设置，如 100
SetMaxIdleConns(n int)	最大空闲连接数	2	根据并发量调大，如 10-50
SetConnMaxLifetime(d time.Duration)	连接最大存活时间	0（永不回收）	建议小于数据库连接超时，如 30m
SetConnMaxIdleTime(d time.Duration)	连接最大空闲时间	0（永不回收）	建议设置，如 5m

2.3 连接池生命周期与事务绑定

下面的SVG图展示了连接池在事务场景下的完整生命周期：

独占一个连接，直到 Commit 或 Rollback 后才归还 • 长事务会长时间占用连接，降低连接池的并发处理能力

2.4 获取事务对象的标准流程

在Go中开启一个事务，遵循以下步骤：

1. 初始化连接池：使用 sql.Open() 创建 sql.DB 实例（注意：此时不建立真实连接）。
2. 验证连接：使用 db.Ping() 或 db.PingContext() 确认数据库可达。
3. 开启事务：调用 db.Begin() 或 db.BeginTx() 获取 sql.Tx 对象。
4. 执行SQL：通过 tx.Exec()、tx.Query() 等方法操作数据库。
5. 提交或回滚：调用 tx.Commit() 或 tx.Rollback() 结束事务。

2.5 代码示例：基础事务操作

import (
    "context"
    "database/sql"
    "fmt"
    "log"
    "time"
)

// 初始化连接池
func initDB(dsn string) (*sql.DB, error) {
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        return nil, fmt.Errorf("sql.Open failed: %w", err)
    }

    // 配置连接池参数
    db.SetMaxOpenConns(50)
    db.SetMaxIdleConns(20)
    db.SetConnMaxLifetime(30 * time.Minute)
    db.SetConnMaxIdleTime(5 * time.Minute)

    // 验证连接
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()
    if err := db.PingContext(ctx); err != nil {
        return nil, fmt.Errorf("db.Ping failed: %w", err)
    }
    return db, nil
}

// 执行事务
func transferFunds(db *sql.DB, fromID, toID int, amount float64) error {
    // 开启事务
    tx, err := db.Begin()
    if err != nil {
        return fmt.Errorf("db.Begin failed: %w", err)
    }

    // 确保事务最终被回滚（如果未提交）
    defer func() {
        if err != nil {
            // 如果已有错误，尝试回滚
            if rbErr := tx.Rollback(); rbErr != nil {
                log.Printf("tx.Rollback error: %v (original error: %v)", rbErr, err)
            }
        }
    }()

    // 执行转账操作
    _, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, fromID)
    if err != nil {
        return fmt.Errorf("deduct failed: %w", err)
    }

    _, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, toID)
    if err != nil {
        return fmt.Errorf("credit failed: %w", err)
    }

    // 提交事务
    if err = tx.Commit(); err != nil {
        return fmt.Errorf("tx.Commit failed: %w", err)
    }
    return nil
}

2.6 事务获取的两种模式对比

模式	方法	适用场景	特点
默认事务	db.Begin()	简单事务，使用默认隔离级别	使用 context.Background()，无法超时控制
上下文事务	db.BeginTx(ctx, opts)	需要超时、取消、自定义隔离级别	支持 context 传播，可设置 sql.TxOptions

sql.TxOptions 结构体允许你精细控制事务行为：

type TxOptions struct {
    Isolation IsolationLevel // 隔离级别
    ReadOnly  bool           // 是否只读事务
}

// 示例：开启一个可重复读的只读事务
tx, err := db.BeginTx(ctx, &sql.TxOptions{
    Isolation: sql.LevelRepeatableRead,
    ReadOnly:  true,
})

2.7 连接池与事务的交互细节

下面的SVG图展示了多个并发事务在连接池中的调度过程：

BeginTx 配合 context.WithTimeout 防止事务无限期占用连接

2.8 常见陷阱与排查思路

• 陷阱1：忘记处理事务错误 —— 事务中的SQL执行失败后，后续操作仍会执行，导致数据不一致。解决方案：检查每次 tx.Exec 的返回值。
• 陷阱2：事务内使用 db.Query 而非 tx.Query —— 这会在事务外创建一个新的连接执行查询，破坏事务的原子性。解决方案：事务内所有数据库操作必须使用 tx 对象。
• 陷阱3：连接池耗尽 —— 事务未及时提交或回滚，导致连接被长期占用。解决方案：设置合理的 ConnMaxLifetime 和 ConnMaxIdleTime，并监控连接池状态。