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()

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