事务处理

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

使用示例:

  1. func Register() error {
  2. var r sql.Result
  3. var err error
  4. tx, err := g.DB().Begin()
  5. if err != nil {
  6. return err
  7. }
  8. // 方法退出时检验返回值,
  9. // 如果结果成功则执行tx.Commit()提交,
  10. // 否则执行tx.Rollback()回滚操作。
  11. defer func() {
  12. if err != nil {
  13. tx.Rollback()
  14. } else {
  15. tx.Commit()
  16. }
  17. }()
  18. // 写入用户基础数据
  19. r, err = tx.Table("user").Insert(g.Map{
  20. "name": "john",
  21. "score": 100,
  22. //...
  23. })
  24. if err != nil {
  25. return err
  26. }
  27. // 写入用户详情数据,需要用到上一次写入得到的用户uid
  28. r, err = tx.Table("user_detail").Insert(g.Map{
  29. "uid": r.LastInsertId(),
  30. "phone": "18010576258",
  31. //...
  32. })
  33. if err != nil {
  34. return err
  35. }
  36. return nil
  37. }

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