2. Go语言事务基础：database/sql包与ACID实战

在分布式事务体系中，单节点事务是所有分布式协调的基石。Go语言通过标准库 database/sql 提供了统一的数据库操作接口，其中内置了对事务的原生支持。本章将深入剖析 database/sql 包的事务模型、ACID 特性的落地方式，以及 Begin/Commit/Rollback 的标准用法。

2.1 database/sql 包的事务抽象

database/sql 包定义了一个轻量级的事务抽象层，不依赖具体数据库驱动。核心接口如下：

接口/类型 职责 关键方法
*sql.DB 数据库连接池，管理长连接 Begin()、BeginTx()
*sql.Tx 事务对象，绑定一个连接 Exec()、Query()、Commit()、Rollback()
*sql.Stmt 预编译语句，可绑定到事务 Exec()、Query()
*sql.Rows 查询结果集 Scan()、Next()、Close()
关键认知： 在 Go 中，事务 *sql.Tx 会从连接池中独占一个数据库连接，直到事务结束（Commit 或 Rollback）才释放回池。这意味着长事务会阻塞连接复用，必须严格控制事务生命周期。

2.2 ACID 特性在 Go 中的映射

ACID 是事务正确性的四个保证。Go 的 database/sql 包本身不实现 ACID，而是通过底层数据库驱动和 SQL 语句来保证。下表展示了 ACID 在 Go 事务编程中的具体体现：

ACID 特性 Go 中的保证方式 常见陷阱
原子性 (Atomicity) Commit() 提交全部，Rollback() 回滚全部 忘记处理 Rollback 导致部分写入
一致性 (Consistency) 依赖数据库约束 + 应用层逻辑 Go 代码中未校验业务规则
隔离性 (Isolation) 通过 BeginTx() 设置隔离级别 默认级别可能产生脏读/不可重复读
持久性 (Durability) 由数据库存储引擎保证（如 WAL） 事务提交后 Go 未确认写入完成

2.3 Begin / Commit / Rollback 基础用法

标准的事务流程包含三个步骤：开启事务、执行操作、提交或回滚。以下是最基础的代码模板：

// 开启事务
tx, err := db.Begin()
if err != nil {
    return fmt.Errorf("begin tx failed: %w", err)
}
// 确保在函数退出时回滚未提交的事务
defer tx.Rollback()

// 执行业务操作
_, err = tx.Exec("UPDATE accounts SET balance = balance - 100 WHERE id = ?", 1)
if err != nil {
    return fmt.Errorf("exec update failed: %w", err)
}

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

// 提交事务
if err := tx.Commit(); err != nil {
    return fmt.Errorf("commit tx failed: %w", err)
}
return nil
⚠️ 重要模式： defer tx.Rollback() 必须在 tx.Commit() 之前声明。如果 Commit() 成功，Rollback() 调用会返回 sql.ErrTxDone 错误，通常可以忽略。这种模式确保任何异常路径都能回滚事务，避免连接泄漏。

2.4 事务边界与连接生命周期

下面的 SVG 图展示了 Go 事务从开启到结束的完整生命周期，以及连接在连接池中的流转过程：

Go 事务生命周期与连接流转 连接池 *sql.DB 管理 N 个连接 Begin() 事务对象 *sql.Tx 独占一个连接 Exec/Query 业务操作 UPDATE / INSERT SELECT ... FOR UPDATE Commit() Rollback() 连接释放回连接池

2.5 进阶：BeginTx 与隔离级别

标准 db.Begin() 使用数据库默认隔离级别。在分布式事务场景中，通常需要显式控制隔离级别。Go 1.8+ 提供了 db.BeginTx() 方法：

// 使用可重复读隔离级别开启事务
tx, err := db.BeginTx(ctx, &sql.TxOptions{
    Isolation: sql.LevelRepeatableRead,
    ReadOnly:  false,
})
if err != nil {
    return fmt.Errorf("begin tx with options failed: %w", err)
}
defer tx.Rollback()

// 业务操作...
if err := tx.Commit(); err != nil {
    return fmt.Errorf("commit failed: %w", err)
}
隔离级别常量 对应 SQL 标准 典型场景
sql.LevelDefault 数据库默认 简单 CRUD
sql.LevelReadUncommitted 读未提交 极少使用，存在脏读风险
sql.LevelReadCommitted 读已提交 大多数 OLTP 系统默认
sql.LevelRepeatableRead 可重复读 金融转账、库存扣减
sql.LevelSerializable 可串行化 分布式事务协调、对账
💡 最佳实践： 在分布式事务边界中，推荐使用 RepeatableRead 或 Serializable 隔离级别，并结合 SELECT ... FOR UPDATE 悲观锁来防止并发冲突。但要注意，隔离级别越高，数据库并发性能越低，需要在一致性和吞吐量之间做权衡。

2.6 事务中的错误处理与资源释放

事务编程中最常见的错误是资源泄漏和未回滚。以下是一个健壮的事务处理模式：

func transferMoney(db *sql.DB, fromID, toID int, amount float64) error {
    tx, err := db.Begin()
    if err != nil {
        return err
    }
    // 延迟回滚：如果 Commit 成功，Rollback 返回 sql.ErrTxDone，可忽略
    defer func() {
        if rbErr := tx.Rollback(); rbErr != nil && rbErr != sql.ErrTxDone {
            // 记录日志，但不应覆盖原始错误
            log.Printf("rollback error: %v", rbErr)
        }
    }()

    // 扣减转出账户
    result, err := tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ? AND balance >= ?", amount, fromID, amount)
    if err != nil {
        return fmt.Errorf("deduct failed: %w", err)
    }
    rows, _ := result.RowsAffected()
    if rows == 0 {
        return fmt.Errorf("insufficient balance or account not found")
    }

    // 增加转入账户
    _, 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("commit failed: %w", err)
    }
    return nil
}
⚠️ 避坑指南：
  • 不要在事务内部使用 db.Exec() 代替 tx.Exec()，否则操作不在事务范围内。
  • 事务中的 SELECT ... FOR UPDATE 会锁定行，务必在事务结束时释放，避免死锁。
  • 如果事务中调用了外部 HTTP 请求或 RPC，考虑超时控制，防止事务长时间挂起。

2.7 事务边界与连接池的交互

理解事务与连接池的交互是避免性能问题的关键。下面的 SVG 图展示了多个事务并发时连接池的分配情况：

事务并发与连接池分配 连接池 (MaxOpenConns=3) 连接 1 事务 A 独占 连接 2 事务 B 独占 连接 3 空闲（可用） 事务 A 转账操作中... 事务 B 订单创建中... 等待队列 事务 C 等待中 事务 D 等待中 事务 E 等待中 ... 连接耗尽 ⚠️ 连接池耗尽风险 长事务会阻塞其他请求，建议设置合理的 MaxOpenConns 和事务超时

2.8 本章小结

  • database/sql 提供了 Begin() / BeginTx() 开启事务，Commit() 提交，Rollback() 回滚。
  • ACID 中的原子性由 Commit/Rollback 保证，隔离性通过隔离级别控制，一致性和持久性依赖数据库和应用层共同保障。
  • 事务会独占连接，必须及时 Commit 或 Rollback 释放资源，避免连接池耗尽。
  • 使用 defer tx.Rollback() 模式确保异常路径安全，配合 sql.ErrTxDone 忽略重复回滚错误。
  • 在分布式事务场景中，优先使用 BeginTx() 显式设置隔离级别，并结合悲观锁控制并发。
← 上一章 📖 返回目录 下一章 →