GORM 事务与并发控制#

闭包事务#

推荐使用闭包形式，让 GORM 负责提交和回滚：

1
err := db.Transaction(func(tx *gorm.DB) error {
2
  if err := tx.Create(&order).Error; err != nil {
3
    return err // 自动回滚
4
  }
5

6
  if err := tx.Model(&Account{}).
7
    Where("id = ? AND balance >= ?", accountID, amount).
8
    Update("balance", gorm.Expr("balance - ?", amount)).Error; err != nil {
9
    return err
10
  }
11

12
  return nil // 自动提交
13
})

事务内的所有数据库操作都必须使用 tx，不能又使用外层 db，否则操作可能跑到事务之外。

手动事务#

需要更细的控制时：

1
tx := db.Begin()
2
if tx.Error != nil {
3
  return tx.Error
4
}
5

6
defer func() {
7
  if r := recover(); r != nil {
8
    tx.Rollback()
9
    panic(r)
10
  }
11
}()
12

13
if err := tx.Create(&order).Error; err != nil {
14
  tx.Rollback()
15
  return err
16
}
17
if err := tx.Commit().Error; err != nil {
18
  return err
19
}
20
return nil

手动模式必须覆盖 Begin、每个操作、Commit、Rollback 和 panic，否则容易留下未完成事务。

上下文与超时#

1
ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
2
defer cancel()
3

4
err := db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
5
  return tx.Create(&record).Error
6
})

请求取消时，驱动是否立即停止 SQL 取决于驱动和数据库支持，但应用层应该把请求上下文传到底层。

默认事务与性能#

GORM 默认会为写操作使用事务以保证数据一致性。SkipDefaultTransaction 可以降低单条写入开销，但只适合单条写入本身具备足够原子性、且业务不依赖默认事务的场景。

1
db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{
2
  SkipDefaultTransaction: true,
3
})

关闭默认事务不会关闭显式 db.Transaction(...)，关键业务仍然可以自己开启事务。

嵌套事务与保存点#

1
err := db.Transaction(func(tx *gorm.DB) error {
2
  if err := tx.Create(&order).Error; err != nil {
3
    return err
4
  }
5

6
  return tx.Transaction(func(nested *gorm.DB) error {
7
    if err := nested.Create(&audit).Error; err != nil {
8
      return err // 通常回滚到保存点，不一定回滚外层事务
9
    }
10
    return nil
11
  })
12
})

嵌套事务的具体行为依赖数据库对保存点的支持；不要把它当成跨数据库的完全一致抽象。

行锁#

读取后要基于当前值更新时，可以使用数据库行锁：

1
var account Account
2
err := db.Transaction(func(tx *gorm.DB) error {
3
  if err := tx.Clauses(clause.Locking{Strength: "UPDATE"}).
4
    Where("id = ?", accountID).
5
    First(&account).Error; err != nil {
6
    return err
7
  }
8

9
  if account.Balance < amount {
10
    return errors.New("insufficient balance")
11
  }
12
  account.Balance -= amount
13
  return tx.Save(&account).Error
14
})

锁的范围、等待和死锁行为由数据库隔离级别与执行计划决定；事务应尽量短，多个事务获取锁时保持一致顺序。

乐观并发控制#

可以使用版本号或带旧值条件的更新：

1
result := db.Model(&Document{}).
2
  Where("id = ? AND version = ?", id, oldVersion).
3
  Updates(map[string]any{
4
    "content": newContent,
5
    "version": gorm.Expr("version + 1"),
6
  })
7
if result.Error != nil {
8
  return result.Error
9
}
10
if result.RowsAffected == 0 {
11
  return errors.New("document was changed by another request")
12
}

事务原则#

事务边界放在业务用例层，而不是每个 Repository 方法内部各开一个事务。
事务中不要执行长时间网络请求、文件 IO 或等待用户操作。
事务中所有读写使用同一个 tx，并传递同一个上下文。
对死锁、超时和唯一键冲突设计可观测日志及有限重试策略。
不要把事务对象跨 goroutine 共享。

HikariTish

GORM 事务与并发控制#

闭包事务#

手动事务#

上下文与超时#

默认事务与性能#

嵌套事务与保存点#

行锁#

乐观并发控制#

事务原则#

官方资料#

继续阅读

换条路线

HikariTish

GORM 事务与并发控制#

闭包事务#

手动事务#

上下文与超时#

默认事务与性能#

嵌套事务与保存点#

行锁#

乐观并发控制#

事务原则#

官方资料#

分享文章

沿着主题读

换条路线