可以看到，通过常规的事务方法来管理事务有很多重复性的操作，并且存在遗忘提交/回滚操作来关闭事务的风险，因此为方便安全执行事务操作，ORM组件同样提供了事务的闭包操作，通过Transaction方法实现，该方法定义如下：

func (db DB) Transaction(ctx context.Context, f func(ctx context.Context, tx *TX) error) (err error)

当给定的闭包方法返回的error为nil时，那么闭包执行结束后当前事务自动执行Commit提交操作；否则自动执行Rollback回滚操作。闭包中的context.Context参数为goframe v1.16版本后新增的上下文变量，主要用于链路跟踪传递以及嵌套事务管理。由于上下文变量是嵌套事务管理的重要参数，因此上下文变量通过显示的参数传递定义。

如果闭包内部操作产生panic中断，该事务也将自动进行回滚，以保证操作安全。

使用示例：

db.Transaction(context.TODO(), func(ctx context.Context, tx *gdb.TX) error {
	// user
	result, err := tx.Ctx(ctx).Insert("user", g.Map{
		"passport": "john",
		"password": "12345678",
		"nickname": "JohnGuo",
	})
	if err != nil {
		return err
	}
	// user_detail
	id, err := result.LastInsertId()
	if err != nil {
		return err
	}
	_, err = tx.Ctx(ctx).Insert("user_detail", g.Map{
		"uid":       id,
		"site":      "https://johng.cn",
		"true_name": "GuoQiang",
	})
	if err != nil {
		return err
	}
	return nil
})
  • No labels

1 Comment

  1. 超级蒙哥马利

    闭包事务中，有一个操作是往另一个数据库（库名：delicious_log）中插入一条日志，我是这么写的：
    _, errLog := tx.Ctx(ctx).Model("order_state_log").Schema("delicious_log").
       Insert(g.Map{
          "store_id":   StoreId,
          "order_id":   OrderId,
          "state":      0,
          "user_id":    UserId,
          "operate_ip": r.GetClientIp(),
       })
    可是是报错了：

     "Error 1146: Table 'delicious.order_state_log' doesn't exist, SHOW FULL COLUMNS FROM `order_state_log`"

    也就是说这条操作实际还是在delicious库中操作的，根本没切换到delicious_log库

    那垮库事务不这么写该怎么写啊？