MongoDB 事务简介

创建事务会话

事务通常通过 API 方法之一，利用应用程序语言的相应 MongoDB 驱动程序，从外部应用程序编写和执行。

为了演示目的，我们将通过 MongoDB shell 逐步介绍事务的创建过程。我们将使用一个示例数据库和集合来帮助您理解事务在实践中如何工作。

注意：如果事务会话在初始 startTransaction() 方法之后运行超过 60 秒，MongoDB 将自动中止操作。发生这种情况是因为事务通常在自动工作的应用程序中执行，而不是由人员在 shell 中发出命令。以下步骤用于概念化从开始到结束的事务会话。

首先，我们有一个名为 literature 的简单数据库，其中包含一个名为 authors 的集合。快速运行一个 find() 查询，我们可以看到包含作者姓名及其作品标题的文档结构。

db.authors.find()

[
  {
    _id: ObjectId("620397dd4b871fc65c193106"),
    first_name: 'James',
    last_name: 'Joyce',
    title: 'Ulysses'
  },
  {
    _id: ObjectId("620398016ed0bb9e23785973"),
    first_name: 'William',
    last_name: 'Gibson',
    title: 'Neuromancer'
  },
  {
    _id: ObjectId("6203981d6ed0bb9e23785974"),
    first_name: 'George',
    last_name: 'Orwell',
    title: 'Homage to Catalonia'
  },
  {
    _id: ObjectId("620398516ed0bb9e23785975"),
    first_name: 'James',
    last_name: 'Baldwin',
    title: 'The Fire Next Time'
  }
]

现在我们有了数据库，我们可以展示如何在 MongoDB shell 中直接使用事务的步骤。我们还将演示在一个会话中进行的事务如何可能对外部源不可见。

首先，我们需要创建一个会话，就像您使用 API 时一样。

var session = db.getMongo().startSession()

这个新创建的 session 变量将存储会话对象。

下一步是通过调用 startTransaction() 方法来启动事务

session.startTransaction(
    { "readConcern": { "level": "snapshot" },
      "writeConcern": { "w": "majority }
     }
)

startTransaction() 方法有两个选项，readConcern 和 writeConcern。您可以在MongoDB 的文档中详细了解这些选项。我们将 readConcern 的 level 设置为 snapshot，如果事务以 writeConcern “majority” 提交，则它会返回多数已提交数据的快照。

当您使用 w: "majority" 写入关注和 "snapshot" 读取关注级别进行提交时，这保证了操作具有多数已提交数据的同步快照。如果没有特定要求，这种写入和读取关注的配置可以被认为是很好的默认设置。

如果成功，该方法不会返回任何内容；如果出现任何错误，则需要中止事务，我们将在稍后讨论。

在事务会话中工作

现在您已经启动了事务会话，您必须在上一节的 session 变量的上下文中运行语句。

在会话中用一个变量表示您的集合有助于简化语法。您可以这样做：

var authors = session.getDatabase('literature').getCollection('authors')

这个新创建的变量将像在事务会话之外的 shell 中工作时的 db.authors 一样。您可以通过打开第二个 shell 窗口，连接到您的集群，并运行 db.authors.find() 来验证这一点。这两个语句都将返回相同的文档。

在会话内部，我们现在要模拟外部应用程序可能执行的操作，并向数据库添加一条记录。我们可以通过以下方式对 authors 集合进行操作：

authors.insertOne( {
    "first_name": "Virginie",
    "last_name": "Despentes",
    "title": "Vernon Subutex") }
)

MongoDB 将返回成功

{
  acknowledged: true,
  insertedId: ObjectId("6203a075c374636bc6976baa")
}

如果我们现在在会话中运行 authors.find()，我们将返回之前的结果，其中包含我们添加的内容。

[
  {
    _id: ObjectId("620397dd4b871fc65c193106"),
    first_name: 'James',
    last_name: 'Joyce',
    best_title: 'Ulysses'
  },
  {
    _id: ObjectId("620398016ed0bb9e23785973"),
    first_name: 'William',
    last_name: 'Gibson',
    best_title: 'Neuromancer'
  },
  {
    _id: ObjectId("6203981d6ed0bb9e23785974"),
    first_name: 'George',
    last_name: 'Orwell',
    best_title: 'Homage to Catalonia'
  },
  {
    _id: ObjectId("620398516ed0bb9e23785975"),
    first_name: 'James',
    last_name: 'Baldwin',
    best_title: 'The Fire Next Time'
  },
  {
    _id: ObjectId("6203a075c374636bc6976baa"),
    first_name: 'Virginie',
    last_name: 'Despentes',
    best_title: 'Vernon Subutex'
  }
]

由于此事务会话尚未提交，因此我们在会话外部的 MongoDB shell 中不会看到相同的结果。为了确认，我们在另一个 MongoDB shell 实例中运行 db.authors.find()，并返回原始文档。

[
  {
    _id: ObjectId("620397dd4b871fc65c193106"),
    first_name: 'James',
    last_name: 'Joyce',
    best_title: 'Ulysses'
  },
  {
    _id: ObjectId("620398016ed0bb9e23785973"),
    first_name: 'William',
    last_name: 'Gibson',
    best_title: 'Neuromancer'
  },
  {
    _id: ObjectId("6203981d6ed0bb9e23785974"),
    first_name: 'George',
    last_name: 'Orwell',
    best_title: 'Homage to Catalonia'
  },
  {
    _id: ObjectId("620398516ed0bb9e23785975"),
    first_name: 'James',
    last_name: 'Baldwin',
    best_title: 'The Fire Next Time'
  }
]

这种差异表明事务目前仍处于不确定状态。它可能成功并提交到数据库，也可能失败并被中止。无论哪种方式，数据库都将最终处于一致状态。它将包含新记录，或者回滚到事务会话开始之前的相同状态。

我们在会话中运行 commitTransaction() 方法，以提交事务并将数据库带到新的一致状态。

session.commitTransaction()

现在，新记录将同时存在于两个实例中：进行事务会话的 MongoDB shell 和事务之外的 MongoDB shell。

中止事务

现在我们已经从启动会话到提交会话，我们可以探讨事务的另一种结果。

此路径开始时相同，仅在提交点发生变化。如果我们想丢弃事务正在进行的更改，则在会话 shell 中使用 abortTransaction() 方法如下：

session.abortTransaction()

此方法取消事务会话并丢弃任何潜在更改。数据库不会产生新的一致状态，而是回滚更改，保持与事务会话首次启动时相同的状态。