Begin/Commit/Rollback
事务操作
开启事务操作可以通过执行db.Begin
方法,该方法返回事务的操作对象,类型为*gdb.Tx
,通过该对象执行后续的数据库操作,并可通过tx.Commit
提交修改,或者通过tx.Rollback
回滚修改。
if tx, err := db.Begin(); err == nil {
r, err := tx.Save("user", gdb.Map{
"uid" : 1,
"name" : "john",
})
tx.Rollback()
fmt.Println(r, err)
}
事务操作对象仍然可以通过或者tx.From
方法返回一个链式操作的对象,该对象与db.Table
或者db.From
方法返回值相同,只不过数据库操作在事务上执行,可提交或回滚。
r, err := tx.Table("user").Data(gdb.Map{"uid":1, "name": "john_1"}).Save()
tx.Commit()
fmt.Println(r, err)
}
其他链式操作请参考 章节。
Transaction
闭包操作
当给定的闭包方法返回的error
为nil
时,那么闭包执行结束后当前事务自动执行Commit
提交操作;否则自动执行Rollback
回滚操作。
如果闭包内部操作产生
panic
中断,该事务也将进行回滚。
db.Transaction(func(tx *gdb.TX) error {
// user
result, err := tx.Insert("user", g.Map{
"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
}
})