使用goframe的ORM组件进行事务操作比较简便，可以通过两种操作方式来实现。

1. 一种是Begin开启事务之后会返回一个事务操作对象*gdb.TX，随后可以使用该对象进行如之前章节介绍的方法操作和链式操作。
2. 一种是以Transacton闭包方法的形式来操作事务，所有的事务逻辑在闭包中实现，并且支持非常便捷的嵌套事务，嵌套事务在业务操作中透明无感知。

接口文档： https://godoc.org/github.com/gogf/gf/database/gdb#TX

常规事务方法

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

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{
        "id"   :  1,
        "name" : "john",
    })
    tx.Rollback()
    fmt.Println(r, err)
}

3. 事务提交操作

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

4. 事务链式操作

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

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

其他链式操作请参考 ORM链式操作(重点) 章节。

Transaction

闭包操作

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

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

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

使用示例：

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

Transaction嵌套事务

从GoFramegoframe版本v1.15.7开始，提供了对数据库嵌套事务的支持。需要注意的是，数据库服务往往并不支持嵌套事务，而是依靠16版本开始，提供了对数据库嵌套事务的支持。需要注意的是，数据库服务往往并不支持嵌套事务，而是依靠ORM组件层通过Transaction Save Point特性实现的。相关方法：

// Begin starts a nested transaction procedure. 
func (tx *TX) Begin() error

// Commit commits current transaction.
// Note that it releases previous saved transaction point if it's in a nested transaction procedure,
// or else it commits the hole transaction.
func (tx *TX) Commit() error

// Rollback aborts current transaction.
// Note that it aborts current transaction if it's in a nested transaction procedure,
// or else it aborts the hole transaction.
func (tx *TX) Rollback() error

// SavePoint performs `SAVEPOINT xxx` SQL statement that saves transaction at current point.
// The parameter `point` specifies the point name that will be saved to server.
func (tx *TX) SavePoint(point string) error

// RollbackTo performs `ROLLBACK TO SAVEPOINT xxx` SQL statement that rollbacks to specified saved transaction.
// The parameter `point` specifies the point name that was saved previously.
func (tx *TX) RollbackTo(point string) error

// Transaction wraps the transaction logic using function `f`.
// It rollbacks the transaction and returns the error from function `f` if
// it returns non-nil error. It commits the transaction and returns nil if
// function `f` returns nil.
//
// Note that, you should not Commit or Rollback the transaction in function `f`
// as it is automatically handled by this function.
func (tx *TX) Transaction(ctx context.Context, f func(ctx context.Context, tx *TX) error) (err error)

同样的，我们推荐使用Transaction闭包方法来实现嵌套事务操作。为了保证文档的全面性，因此我们这里仍然从最基本的事务操作方法开始来介绍嵌套事务操作。

1. 基本操作

一个简单的示例SQL，包含两个字段id和name：

CREATE TABLE `user` (
  `id` int(10) unsigned NOT NULL COMMENT '用户ID',
  `name` varchar(45) NOT NULL COMMENT '用户名称',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

示例程序代码：

tx, err := db.Begin()
if err != nil {
	panic(err)
}
if err = tx.Begin(); err != nil {
	panic(err)
}
_, err = tx.Model(table).Data(g.Map{"id": 1, "name": "john"}).Insert()
if err = tx.Rollback(); err != nil {
	panic(err)
}
_, err = tx.Model(table).Data(g.Map{"id": 2, "name": "smith"}).Insert()
if err = tx.Commit(); err != nil {
	panic(err)
}

db.Begin与tx.Begin

可以看到，在我们的嵌套事务中出现了db.Begin和tx.Begin两种事务开启方式，两者有什么区别呢？db.Begin是在数据库服务上真正开启一个事务操作，并返回一个事务操作对象tx，随后所有的事务操作都是通过该tx事务对象来操作管理。tx.Begin表示在当前事务操作中开启嵌套事务，默认情况下会对嵌套事务的SavePoint采用自动命名，命名格式为transactionN，其中的N表示嵌套的层级数量，如果您看到日志中出现SAVEPOINT `transaction1`表示当前嵌套层级为2（从0开始计算）。

更详细的日志

goframe的ORM拥有相当完善的日志记录机制，如果您打开SQL日志，那么将会看到以下日志信息，展示了整个数据库请求的详细执行流程：

2021-05-0222 1321:4012:1510.483776 [DEBU] [  04 ms] [default] SAVEPOINT[1] `transaction0`BEGIN
2021-05-0222 1321:4012:1510.485776 [DEBU] [  20 ms] [default] SHOW[1] FULL SAVEPOINT `transaction0`
2021-05-22 21:12:10.789 [DEBU] [ 13 ms] [default] [1] SHOW FULL COLUMNS FROM `user`
2021-05-0222 1321:4012:1510.486790 [DEBU] [  01 ms] [default] [1] INSERT INTO `user`(`id`,`name`) VALUES(1,'john') 
2021-05-0222 1321:4012:1510.486791 [DEBU] [  01 ms] [default] [1] ROLLBACK TO SAVEPOINT `transaction0`
2021-05-0222 1321:4012:1510.486791 [DEBU] [  0 ms] [default] [1] INSERT INTO `user`(`id`,`name`) VALUES(2,'smith') 
2021-05-0222 1321:4012:1510.487792 [DEBU] [  1 ms] [default] [1] COMMIT

其中的[1]表示ORM组件记录的事务ID，多个真实的事务同时操作时，每个事务的ID将会不同。在同一个真实事务下的嵌套事务的事务ID是一样的。

执行后查询数据库结果：

mysql> select * from `user`;
+----+-------+
| id | name  |
+----+-------+
|  2 | smith |
+----+-------+
1 row in set (0.00 sec)

可以看到第一个操作被成功回滚，只有第二个操作执行并提交成功。

2. 闭包操作

我们也可以通过闭包操作来实现嵌套事务，同样也是通过Transaction方法实现。

我们也可以通过闭包操作来实现嵌套事务，同样也是通过Transaction方法实现。

Code Block
language go
db.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { // Nested transaction 1. if err := tx.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { _, err := tx.Model(table).Ctx(ctx).Data(g.Map{"id": 1, "name": "john"}).Insert() return err }); err != nil { return err } // Nested transaction 2, panic. if err := tx.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { _, err := tx.Model(table).Ctx(ctx).Data(g.Map{"id": 2, "name": "smith"}).Insert() // Create a panic that can make this transaction rollback automatically. panic("error") return err }); err != nil { return err } return nil })

嵌套事务的闭包嵌套中也可以不使用其中的tx对象，而是直接使用db对象或者dao包，这种方式更常见一些。特别是方法层级调用时，这样使得对于开发者来说并不用关心tx对象的传递，也并不用关心当前事务是否需要嵌套执行，一切都由组件自动识别。但是务必记得将ctx上下文变量层层传递下去。例如：

Code Block
language go
db.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { // Nested transaction 1. if err := db.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { _, err := db.Model(table).Ctx(ctx).Data(g.Map{"id": 1, "name": "john"}).Insert() return err }); err != nil { return err } // Nested transaction 2, panic. if err := db.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { _, err := db.Model(table).Ctx(ctx).Data(g.Map{"id": 2, "name": "smith"}).Insert() // Create a panic that can make this transaction rollback automatically. panic("error") return err }); err != nil { return err } return nil })

如果您打开SQL日志，那么执行后将会看到以下日志信息，展示了整个数据库请求的详细执行流程：

Code Block
language xml
2021-05-22 21:18:46.672 [DEBU] [ 2 ms] [default] [1] BEGIN 2021-05-22 21:18:46.672 [DEBU] [ 0 ms] [default] [1] SAVEPOINT `transaction0` 2021-05-22 21:18:46.673 [DEBU] [ 0 ms] [default] [1] SHOW FULL COLUMNS FROM `user` 2021-05-22 21:18:46.674 [DEBU] [ 0 ms] [default] [1] INSERT INTO `user`(`id`,`name`) VALUES(1,'john') 2021-05-22 21:18:46.674 [DEBU] [ 0 ms] [default] [1] RELEASE SAVEPOINT `transaction0` 2021-05-22 21:18:46.675 [DEBU] [ 1 ms] [default] [1] SAVEPOINT `transaction0` 2021-05-22 21:18:46.675 [DEBU] [ 0 ms] [default] [1] INSERT INTO `user`(`name`,`id`) VALUES('smith',2) 2021-05-22 21:18:46.675 [DEBU] [ 0 ms] [default] [1] ROLLBACK TO SAVEPOINT `transaction0` 2021-05-22 21:18:46.676 [DEBU] [ 1 ms] [default] [1] ROLLBACK

Warning
假如ctx上下文变量没有层层传递下去，那么嵌套事务将会失败，我们来看一个错误的例子：
Tip
Transaction方式可以实现对嵌套事务操作的无限层级嵌套，但是不推荐层级过深的嵌套事务，否则业务逻辑上可能不太好维护。本示例演示的是只有一个层级的事务嵌套操作。 Code Block language go if err = db.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { // Nested transaction 1. if err := tx db.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { _, err := tx db.Model(table).Ctx(ctx).Data(g.Map{"id": 1, "name": "john"}).Insert() return err }); err != nil { return err } // Nested transaction 2, panic. if err := tx db.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error { _, err := tx db.Model(table).Data(g.Map{"id": 2, "name": "smith"}).Insert() // Create a panic that can make this transaction rollback automatically. panic("error") return err }); err != nil { return err } return nil }) ; err != nil { panic(err) }

这个示例中，最后的事务执行失败之后，所有的操作都将会回滚。执行后，什么数据都不会写入。如果您打开SQL日志，那么将会看到以下日志信息，展示了整个数据库请求的详细执行流程：

打开SQL执行日志，执行后，您将会看到以下日志内容： Code Block language xml 2021-05-22 21:29:38.841 [DEBU] [ 3 ms] [default] [1] BEGIN 2021-05-22 21:29:38.842
Code Block
language xml
2021-05-02 13:42:01.935 [DEBU] [ 1 ms] [default] [1] SAVEPOINT `transaction0` 2021-05- 02 22 13 21: 42 29: 01 38. 939 843 [DEBU] [ 4 1 ms] [default] [1] SHOW FULL COLUMNS FROM `user` 2021-05- 02 22 13 21: 42 29: 01 38. 940 845 [DEBU] [ 0 2 ms] [default] [1] INSERT INTO `user`(`id`,`name`) VALUES(1,'john') 2021-05- 02 22 13 21: 42 29: 01 38. 940 845 [DEBU] [ 0 ms] [default] [1] RELEASE SAVEPOINT `transaction0` 2021-05- 02 22 13 21: 42 29: 01 38. 940 846 [DEBU] [ 0 1 ms] [default] [1] SAVEPOINT `transaction0` 2021-05- 02 22 13 21: 42 29: 01 38. 941 847 [DEBU] [ 0 1 ms] [default] INSERT INTO `user`(`id`,`name`) VALUES(2,'smith') 2021-05- 02 22 13 21: 42 29: 01 38. 941 848 [DEBU] [ 0 ms] [default] [1] ROLLBACK TO SAVEPOINT `transaction0` 2021-05- 02 22 13 21: 42 29: 01 38. 941 848 [DEBU] [ 0 ms] [default] [1] ROLLBACK 可以看到，第二条INSERT操作没有使用到事务，那么该操作将会被真正提交到数据库执行，并不能被回滚。

3. SavePoint/RollbackTo

开发者也可以灵活使用Transaction Save Point特性，并实现自定义的SavePoint命名以及指定Point回滚操作。

tx, err := db.Begin()
if err != nil {
	panic(err)
}
defer func() {
	if err := recover(); err != nil {
		_ = tx.Rollback()
	}
}()
if _, err = tx.Model(table).Data(g.Map{"id": 1, "name": "john"}).Insert(); err != nil {
	panic(err)
}
if err = tx.SavePoint("MyPoint"); err != nil {
	panic(err)
}
if _, err = tx.Model(table).Data(g.Map{"id": 2, "name": "smith"}).Insert(); err != nil {
	panic(err)
}
if _, err = tx.Model(table).Data(g.Map{"id": 3, "name": "green"}).Insert(); err != nil {
	panic(err)
}
if err = tx.RollbackTo("MyPoint"); err != nil {
	panic(err)
}
if err = tx.Commit(); err != nil {
	panic(err)
}

如果您打开SQL日志，那么将会看到以下日志信息，展示了整个数据库请求的详细执行流程：

2021-05-02 13:59:36.788 [DEBU] [  3 ms] [default] SHOW FULL COLUMNS FROM `user`
2021-05-02 13:59:36.788 [DEBU] [  0 ms] [default] INSERT INTO `user`(`name`,`id`) VALUES('john',1) 
2021-05-02 13:59:36.789 [DEBU] [  1 ms] [default] SAVEPOINT `MyPoint`
2021-05-02 13:59:36.789 [DEBU] [  0 ms] [default] INSERT INTO `user`(`id`,`name`) VALUES(2,'smith') 
2021-05-02 13:59:36.789 [DEBU] [  0 ms] [default] INSERT INTO `user`(`name`,`id`) VALUES('green',3) 
2021-05-02 13:59:36.789 [DEBU] [  0 ms] [default] ROLLBACK TO SAVEPOINT `MyPoint`
2021-05-02 13:59:36.791 [DEBU] [  2 ms] [default] COMMIT

执行后查询数据库结果：

mysql> select * from `user`;
+----+------+
| id | name |
+----+------+
|  1 | john |
+----+------+
1 row in set (0.00 sec)

可以看到，通过在第一个Insert操作后保存了一个SavePoint名称MyPoint，随后的几次操作都通过RollbackTo方法被回滚掉了，因此只有第一次Insert操作被成功提交执行。