Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

基本介绍

使用GoFrame ORM组件进行事务操作非常简便、安全,可以通过两种操作方式来实现。

  1. 常规操作:通过Begin开启事务之后会返回一个事务操作接口gdb.TX,随后可以使用该接口进行如之前章节介绍的方法操作和链式操作。常规操作容易漏掉关闭事务,有一定的事务操作安全风险。
  2. 闭包操作:通过Transaction闭包方法的形式来操作事务,所有的事务逻辑在闭包中实现,闭包结束后自动关闭事务保障事务操作安全。并且闭包操作支持非常便捷的嵌套事务,嵌套事务在业务操作中透明无感知。
Tip

我们推荐事务操作均统一采用Transaction闭包方式实现。

接口文档: gdb事务操作比较简单,可以通过两种操作方式来实现。一种是开启事务之后会返回一个事务操作对象*gdb.TX,随后可以使用该对象进行如之前章节介绍的方法操作和链式操作;一种是以闭包的形式来操作事务,所有的事务逻辑在闭包中实现。接口文档: https://godocpkg.go.orgdev/github.com/gogf/gf/v2/database/gdb#TX

Begin/Commit/Rollback事务操作

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

开启事务操作后,请务必在不需要使用该对象时,使用Commit/Rollback操作关闭掉该事务,推荐充分利用好defer方法。

1. 开启事务操作

if tx, err := db.Begin(); err == nil {
    fmt.Println("开启事务操作")
}

事务操作对象可以执行所有db对象的方法,具体请参考 API文档

2. 事务回滚操作

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

3. 事务提交操作

if tx, err := db.Begin(); err == nil {
    r, err := tx.Save("user", gdb.Map{
        "uid"  :  1,
        "name" : "john",
    })
    tx.Commit()
    fmt.Println(r, err)
}

4. 事务链式操作

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

if tx, err := db.Begin(); err == nil {
    r, err := tx.Table("user").Data(gdb.Map{"uid":1, "name": "john_1"}).Save()
    tx.Commit()
    fmt.Println(r, err)
}

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

Transaction闭包操作

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

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

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

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

使用示例:

相关文档

Children Display
alltrue
excerptTypesimple

db.Transaction(func(tx *gdb.TX) error { // user result, err := tx.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.Insert("user_detail", g.Map{ "uid": id, "site": "https://johng.cn", "true_name": "GuoQiang", }) if err != nil { return err } return nil })





Panel
titleContent Menu

Table of Contents