MongoDB 事务简介

创建事务会话

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

为了演示，我们将逐步介绍通过 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 中看到相同的返回结果（该 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()

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