事务操作
gdb
事务操作比较简单,可以通过两种操作方式来实现。一种是开启事务之后会返回一个事务操作对象*gdb.TX
,随后可以使用该对象进行如之前章节介绍的方法操作和链式操作;一种是以闭包的形式来操作事务,所有的事务逻辑在闭包中实现。接口文档: https://godoc.org/github.com/gogf/gf/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)
}
其他链式操作请参考【链式操作】章节。
Transaction
闭包操作
为方便事务操作,gdb
提供了事务的闭包操作,通过Transaction
方法实现,该方法定义如下:
...