Model对象也可以通过TX事务对象创建，通过事务对象创建的Model对象与通过DB数据库对象创建的Model对象功能是一样的，只不过前者的所有操作都是基于事务，而当事务提交或者回滚后，对应的Model对象不能被继续使用，否则会返回错误。因为该TX对象不能被继续使用，一个事务对象仅对应于一个事务流程，Commit/Rollback后即结束。更详细的介绍请参考 ORM事务操作 章节。

示例1，通过Transaction

为方便事务操作，gdb提供了事务的闭包操作，通过Transaction方法实现，该方法定义如下：

func (db DB) Transaction(f func(tx *TX) error) (err error)

当给定的闭包方法返回的error为nil时，那么闭包执行结束后当前事务自动执行Commit提交操作；否则自动执行Rollback回滚操作。

如果闭包内部操作产生panic中断，该事务也将进行回滚。

func Register() error {
	return g.DB().Transaction(func(tx *gdb.TX) error {
		var (
			result sql.Result
			err    error
		)
		// 写入用户基础数据
		result, err = tx.Table("user").Insert(g.Map{
			"name":  "john",
			"score": 100,
			//...
		})
		if err != nil {
			return err
		}
		// 写入用户详情数据，需要用到上一次写入得到的用户uid
		result, err = tx.Table("user_detail").Insert(g.Map{
			"uid":   result.LastInsertId(),
			"phone": "18010576258",
			//...
		})
		return err
	})
}

示例2，通过TX链式操作

我们也可以在链式操作中通过TX方法切换绑定的事务对象。多次链式操作可以绑定同一个事务对象，在该事务对象中执行对应的链式操作。

func Register() error {
	var (
		uid int64
		err error
	)
	tx, err := g.DB().Begin()
	if err != nil {
		return err
	}
	// 方法退出时检验返回值，
	// 如果结果成功则执行tx.Commit()提交,
	// 否则执行tx.Rollback()回滚操作。
	defer func() {
		if err != nil {
			tx.Rollback()
		} else {
			tx.Commit()
		}
	}()
	// 写入用户基础数据
	uid, err = AddUserInfo(tx, g.Map{
		"name":  "john",
		"score": 100,
		//...
	})
	if err != nil {
		return err
	}
	// 写入用户详情数据，需要用到上一次写入得到的用户uid
	err = AddUserDetail(tx, g.Map{
		"uid":   uid,
		"phone": "18010576259",
		//...
	})
	return err
}

func AddUserInfo(tx *gdb.TX, data g.Map) (int64, error) {
	result, err := g.Table("user").TX(tx).Data(data).Insert()
	if err != nil {
		return 0, err
	}
	uid, err := result.LastInsertId()
	if err != nil {
		return 0, err
	}
	return uid, nil
}

func AddUserDetail(tx *gdb.TX, data g.Map) error {
	_, err := g.Table("user_detail").TX(tx).Data(data).Insert()
	return err
}







Content Menu

  • No labels

7 Comments

  1. kim

    orm中如果对两个表进行了操作，每次操作都是单独声明一个model出来的，那么就是两个独立的事务，如何让后一个事务加入前一个事务中进行统一管理事务呢？

    1. 郭强

      你好，更新了一下文档，麻烦再看看呢。

      1. kim

        通过显式的tx对象来调用确实可以自己手动控制两张表的事务一致性。然而实际开发中代码需要松耦合，可能很多表的操作都是各自独立一个接口内部完成，而且这样写声明式事务的方式对开发人员来说要求比较高，事务一致性、回滚、提交都要开发人员一手一脚来顾及，容易踩坑，建议最好是能够通过一些配置或者方法参数的传递能够在底层智能地处理完事务问题。

        1. 郭强

          那你需要的就是Transaction方法，具体看示例1。

          1. kim

            实例1不需要手动提交和回滚，会不会导致事务挂起？

            1. 郭强

              当给定的闭包方法返回的error为nil时，那么闭包执行结束后当前事务自动执行Commit提交操作；否则自动执行Rollback回滚操作。

              1. kim

                明白，谢谢