2. Go 事务基础：ACID 特性与 database/sql 包

在报表回放系统中，事务是保证数据一致性的核心机制。本章从数据库事务的 ACID 理论出发，介绍 Go 标准库 database/sql 包的事务操作接口，并演示事务的开启、提交与回滚。

2.1 数据库事务的 ACID 特性

事务（Transaction）是数据库执行过程中的一个逻辑单元，由一组 SQL 语句组成。事务必须满足四个基本特性，即 ACID：

2.2 Go 中 database/sql 包简介

Go 标准库 database/sql 提供了统一的 SQL 数据库操作接口，不绑定具体数据库驱动。开发者只需导入对应驱动（如 MySQL 的 github.com/go-sql-driver/mysql），即可通过相同的 API 操作不同数据库。

2.2.1 核心接口与对象

2.2.2 连接数据库示例

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql" // 注册 MySQL 驱动
)

func main() {
    // 数据源名称格式：user:password@tcp(host:port)/dbname?charset=utf8mb4
    dsn := "report_user:report_pass@tcp(127.0.0.1:3306)/report_db?charset=utf8mb4&parseTime=true"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        panic("数据库连接失败: " + err.Error())
    }
    defer db.Close()

    // 设置连接池参数
    db.SetMaxOpenConns(25)  // 最大打开连接数
    db.SetMaxIdleConns(5)   // 最大空闲连接数
    db.SetConnMaxLifetime(5 * time.Minute) // 连接最大存活时间

    // 测试连接是否正常
    if err := db.Ping(); err != nil {
        panic("数据库 Ping 失败: " + err.Error())
    }
}

2.3 事务开启与提交

在 database/sql 包中，事务通过 db.Begin() 开启，通过 tx.Commit() 提交，通过 tx.Rollback() 回滚。事务内的所有 SQL 操作都使用 tx 对象执行，而不是 db 对象。

2.3.1 事务基本流程

func transferFunds(db *sql.DB, fromID, toID int, amount float64) error {
    // 1. 开启事务
    tx, err := db.Begin()
    if err != nil {
        return fmt.Errorf("开启事务失败: %w", err)
    }
    // 2. 确保在函数退出时回滚（如果尚未提交）
    defer tx.Rollback()

    // 3. 执行事务内的 SQL 操作
    _, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, fromID)
    if err != nil {
        return fmt.Errorf("扣款失败: %w", err)
    }

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

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

2.3.2 事务隔离级别设置

Go 的 database/sql 支持通过 db.BeginTx() 方法设置事务隔离级别：

import (
    "database/sql"
    "context"
)

func beginWithIsolation(db *sql.DB) (*sql.Tx, error) {
    ctx := context.Background()
    opts := &sql.TxOptions{
        Isolation: sql.LevelRepeatableRead, // 可重复读
        ReadOnly:  false,
    }
    tx, err := db.BeginTx(ctx, opts)
    if err != nil {
        return nil, err
    }
    return tx, nil
}

Go 支持的隔离级别常量：

2.4 事务生命周期 SVG 图

下图展示了 Go 中一个完整事务的生命周期，包括开启、执行、提交/回滚以及连接释放过程：

2.5 事务边界与连接绑定

理解事务与底层连接的绑定关系，是避免并发问题的关键。下图展示了事务、连接与连接池之间的关系：

2.6 报表回放中的事务实践要点

• 短事务原则： 事务应尽快提交，避免长时间持有连接。报表回放中，建议每个事务只处理一批（如 1000 条）数据。
• 错误处理： 事务内的每个 SQL 操作都必须检查错误，一旦出错立即回滚。
• 重试机制： 对于可重试的错误（如死锁），可以捕获后重新开启事务重试。
• 避免嵌套事务： Go 的 database/sql 不支持嵌套事务，如果需要类似功能，可以使用保存点（Savepoint）模拟。