事务

Overview

在本指南中，您可以学习如何使用 MongoDB Go Driver 执行事务。 事务允许您运行一系列操作，这些操作在提交事务之前不会更改任何数据。如果事务中的任何操作返回错误，驱动程序就会取消事务，并在所有数据更改变得可见之前予以丢弃。

在 MongoDB 中，事务在逻辑会话中运行。会话是一组要按顺序运行的相关读取或写入操作。会话可以实现一组操作的因果一致性，或支持在 ACID 事务中执行操作。MongoDB 保证事务操作中涉及的数据保持一致，即使操作遇到意外错误。

使用 Go 驱动程序时，您可以从 Client 实例创建一个新会话，并将其类型定义为 Session。我们建议您将客户端重复用于多个会话和事务，而不是每次都实例化新客户端。

方法

使用 StartSession() 方法启动会话后，可使用 Session 接口提供的方法集修改会话状态。下表介绍了这些方法：

Session 接口还提供检索会话属性和修改可变会话属性的方法。有关更多信息，请参阅 API 文档。

例子

以下示例显示如何通过以下步骤创建会话、创建事务以及提交多文档插入操作：

1. 使用 StartSession() 方法从客户端创建会话。

2. 使用 WithTransaction() 方法启动事务。

3. 插入多个文档。 WithTransaction()方法执行插入并提交ACID 事务。 如果任何操作导致错误， WithTransaction()则会中止ACID 事务。

4. 使用 EndSession() 方法关闭 ACID 事务和会话。

wc := writeconcern.New(writeconcern.WMajority())
txnOptions := options.Transaction().SetWriteConcern(wc)
session, err := client.StartSession()
if err != nil {
	panic(err)
}
defer session.EndSession(context.TODO())
result, err := session.WithTransaction(context.TODO(), func(ctx mongo.SessionContext) (interface{}, error) {
	result, err := coll.InsertMany(ctx, []interface{}{
		bson.D{{"title", "The Bluest Eye"}, {"author", "Toni Morrison"}},
		bson.D{{"title", "Sula"}, {"author", "Toni Morrison"}},
		bson.D{{"title", "Song of Solomon"}, {"author", "Toni Morrison"}},
	})
	return result, err
}, txnOptions)

如果您需要对事务拥有更多控制，您可以在完整代码示例中找出一个说明如何手动创建、提交和结束事务的示例

更多信息

有关插入操作的更多信息，请参阅 插入文档基础知识页面。

有关写关注的更多信息，请参阅“修改 CRUD 操作的执行”基础知识页面。

有关在 Go 驱动程序中使用会话和事务的更多示例，请参阅关于多文档 ACID 事务的开发者博客文章。