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

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