4. 事务的 Rollback：错误处理与回滚策略

在分布式事务与数据库事务中，回滚（Rollback）是保证数据一致性的最后防线。Go 语言中，事务回滚不仅仅是调用 tx.Rollback()，更涉及错误传播、资源清理、部分回滚（Savepoint）以及并发安全下的回滚策略。本章深入剖析事务回滚的三种核心模式：错误处理与回滚策略、defer 回滚模式、Savepoint 使用。

4.1 错误处理与回滚策略

事务回滚的核心原则是：一旦发生不可恢复的错误，立即回滚，避免部分写入。Go 标准库 database/sql 中，Tx 对象在调用 Rollback 后即进入失效状态，后续任何操作都会返回 sql.ErrTxClosed。

4.1.1 回滚触发条件

4.1.2 错误传播与回滚决策

在 Go 中，事务函数通常返回 error，调用方根据错误决定是否回滚。推荐使用 闭包封装 模式，将事务逻辑与回滚决策解耦：

func WithTransaction(db *sql.DB, fn func(tx *sql.Tx) error) error {
    tx, err := db.Begin()
    if err != nil {
        return err
    }
    defer tx.Rollback() // 安全网：如果未提交则回滚

    if err := fn(tx); err != nil {
        return err // defer 中的 Rollback 会自动执行
    }
    return tx.Commit()
}

4.2 defer 回滚模式

defer 回滚模式 是 Go 事务编程中最常用的安全模式。它利用 defer 的延迟执行特性，确保无论函数如何退出，事务都能被正确清理。

4.2.1 标准 defer 回滚模式

func TransferMoney(db *sql.DB, from, to int64, amount float64) error {
    tx, err := db.Begin()
    if err != nil {
        return err
    }
    // 注册回滚：如果 Commit 成功，Rollback 会变成空操作
    defer func() {
        if err := tx.Rollback(); err != nil && err != sql.ErrTxClosed {
            log.Printf("rollback error: %v", err)
        }
    }()

    // 执行扣款
    _, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, from)
    if err != nil {
        return err
    }
    // 执行加款
    _, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, to)
    if err != nil {
        return err
    }
    // 提交事务
    return tx.Commit()
}

4.2.2 defer 回滚的三种变体

4.3 Savepoint 使用

Savepoint（保存点） 允许在事务内部设置一个回滚点，实现部分回滚。这在长事务或复杂业务逻辑中非常有用：当某一步操作失败时，不必回滚整个事务，只需回滚到最近的 Savepoint。

4.3.1 Savepoint 核心操作

4.3.2 Savepoint 实战：批量插入部分回滚

func BatchInsertWithSavepoint(tx *sql.Tx, items []Item) error {
    // 创建全局保存点
    if _, err := tx.Exec("SAVEPOINT batch_start"); err != nil {
        return err
    }

    for i, item := range items {
        // 为每个元素创建独立保存点
        spName := fmt.Sprintf("sp_item_%d", i)
        if _, err := tx.Exec(fmt.Sprintf("SAVEPOINT %s", spName)); err != nil {
            return err
        }

        _, err := tx.Exec("INSERT INTO items (id, name) VALUES (?, ?)", item.ID, item.Name)
        if err != nil {
            // 回滚到当前元素的保存点，不影响之前已插入的数据
            tx.Exec(fmt.Sprintf("ROLLBACK TO %s", spName))
            log.Printf("item %d failed, rolled back to savepoint: %v", i, err)
            continue // 跳过失败项，继续处理后续
        }
    }
    return nil // 由调用方决定是否 Commit
}

4.4 事务回滚流程与 Savepoint 架构

下图展示了完整的事务回滚流程，包括全局回滚与 Savepoint 部分回滚两种路径：

4.5 并发安全下的回滚策略

在并发场景中，多个 goroutine 可能共享同一个 Tx 对象。Go 的 database/sql 包规定：一个 Tx 不能同时在多个 goroutine 中使用。回滚操作必须与事务的创建和提交在同一个 goroutine 中完成。

4.5.1 并发回滚的三种模式

4.6 回滚策略对比总结