4. Ent 事务 API 详解：Tx 对象、Rollback、Commit、TxOptions 的使用

在 Ent 中，事务是保证数据一致性的核心机制。与直接使用 database/sql 的事务不同，Ent 的 Tx 对象封装了完整的 ORM 操作能力，允许你在同一个事务内执行多个 CRUD 操作，并统一提交或回滚。本章将深入解析 Tx 对象的创建、提交、回滚以及事务选项的配置。

4.1 Tx 对象：事务的载体

Tx 是 Ent 事务的核心对象，它实现了与 Client 相同的操作接口（如 User、Car 等模型的 CRUD 方法）。当你通过 client.Tx(ctx) 创建一个事务时，Ent 会从连接池中获取一个数据库连接，并将其绑定到该 Tx 对象上。此后，所有通过该 Tx 对象执行的操作都会在同一个数据库连接上运行，直到调用 Commit 或 Rollback。

4.2 事务的创建与生命周期

事务的生命周期由三个关键步骤组成：开始、执行操作、结束（提交或回滚）。以下是一个标准的事务使用模式：

// 1. 开始事务
tx, err := client.Tx(ctx)
if err != nil {
    return fmt.Errorf("starting transaction: %w", err)
}

// 2. 执行事务内的操作
hub, err := tx.User.
    Create().
    SetName("Hub").
    SetAge(30).
    Save(ctx)
if err != nil {
    // 3. 操作失败，回滚事务
    return tx.Rollback()
}

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

4.3 Commit 与 Rollback：事务的终局

Commit 和 Rollback 是事务的两个终结方法，它们的行为决定了事务的最终状态。

4.4 TxOptions：事务行为的精细控制

TxOptions 允许你自定义事务的行为，例如设置隔离级别和只读模式。它通过 client.Tx(ctx, &sql.TxOptions{...}) 传入。

以下是一个使用 TxOptions 的示例：

// 创建一个可序列化隔离级别、只读的事务
tx, err := client.Tx(ctx, &sql.TxOptions{
    Isolation: sql.LevelSerializable,
    ReadOnly:  true,
})
if err != nil {
    return err
}
defer tx.Rollback() // 只读事务通常不需要提交，回滚即可释放连接

// 执行只读查询
users, err := tx.User.Query().All(ctx)
if err != nil {
    return err
}
// 注意：在只读事务中尝试写入操作会返回错误

4.5 事务流程可视化

下面的 SVG 图展示了 Ent 事务从创建到结束的完整生命周期，包括正常提交和异常回滚两条路径。

4.6 事务嵌套与闭包辅助函数

Ent 提供了 client.Tx 的闭包变体 WithTx，它自动处理了 Commit 和 Rollback 的逻辑，减少了样板代码。当闭包返回 nil 时自动提交，返回错误时自动回滚。

// 使用 WithTx 简化事务管理
err := client.WithTx(ctx, func(tx *ent.Tx) error {
    hub, err := tx.User.Create().SetName("Hub").SetAge(30).Save(ctx)
    if err != nil {
        return err // 自动回滚
    }
    // 更多操作...
    return nil // 自动提交
})
if err != nil {
    return fmt.Errorf("transaction failed: %w", err)
}

4.7 常见错误与避坑指南

• 忘记调用 Commit 或 Rollback：导致连接泄漏，最终耗尽连接池。始终使用 defer tx.Rollback() 作为安全网。
• 在只读事务中执行写入：数据库会返回错误。确保 ReadOnly: true 的事务只执行查询操作。
• 重复调用 Commit 或 Rollback：第二次调用会返回 sql: transaction has already been committed or rolled back 错误。使用 WithTx 可以避免此问题。
• 事务内执行长时间操作：长时间持有事务会阻塞其他并发操作，并增加死锁风险。保持事务短小精悍。