Begin/Commit/Rollback事务操作

    开启事务操作可以通过执行db.Begin方法,该方法返回事务的操作对象,类型为*gdb.Tx,通过该对象执行后续的数据库操作,并可通过tx.Commit提交修改,或者通过tx.Rollback回滚修改。

    1. if tx, err := db.Begin(); err == nil {
    2. r, err := tx.Save("user", gdb.Map{
    3. "uid" : 1,
    4. "name" : "john",
    5. })
    6. tx.Rollback()
    7. fmt.Println(r, err)
    8. }

    事务操作对象仍然可以通过或者tx.From方法返回一个链式操作的对象,该对象与db.Table或者db.From方法返回值相同,只不过数据库操作在事务上执行,可提交或回滚。

    1. r, err := tx.Table("user").Data(gdb.Map{"uid":1, "name": "john_1"}).Save()
    2. tx.Commit()
    3. fmt.Println(r, err)
    4. }

    其他链式操作请参考 章节。

    Transaction闭包操作

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

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

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