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

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

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

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

    使用示例:

    1. g.DB().Transaction(context.TODO(), func(ctx context.Context, tx *gdb.TX) error {
    2. // user
    3. result, err := tx.Ctx(ctx).Insert("user", g.Map{
    4. "passport": "john",
    5. "password": "12345678",
    6. "nickname": "JohnGuo",
    7. })
    8. if err != nil {
    9. return err
    10. }
    11. // user_detail
    12. id, err := result.LastInsertId()
    13. if err != nil {
    14. return err
    15. }
    16. _, err = tx.Ctx(ctx).Insert("user_detail", g.Map{
    17. "uid": id,
    18. "site": "https://johng.cn",
    19. "true_name": "GuoQiang",
    20. })
    21. if err != nil {
    22. return err
    23. }
    24. return nil
    25. })