事务

因果一致性(Causal Consistency)

MongoDB在某些客户端会话中实现因果一致性。因果一致性模型ACID 一致性保证在分布式系统中，会话中的操作按因果顺序运行。客户端观察到的结果与因果关系或操作之间的依赖关系一致。示例，如果您执行一系列操作，其中一个操作在逻辑上依赖于另一个操作的结果，则任何后续读取都会反映这种依赖关系。

为了保证因果一致性，客户端端会话必须满足以下要求：

• 启动会话时，驱动程序必须启用因果一致性选项。该选项默认启用。

• 操作必须在单个线程的单个会话中运行。否则，会话或线程必须相互传达optime和集群时间值。 要查看传达这些值的两个会话的示例，请参阅MongoDB Server手册中的因果一致性示例。

• 您必须使用 majority读关注（read concern）。

• 您必须使用 majority写关注（write concern）。这是默认的写关注（write concern）值。

下表描述了因果一致会话提供的ACID 一致性保证：

Core API

Core API 提供以下方法来执行事务：

• startSession(): creates a new ClientSession instance

• startTransaction()：开始新事务

• commitTransaction()：在创建活动事务的会话中提交活动事务

• abortTransaction()：在创建事务的会话中结束活跃事务

• endSession()：结束活动会话

使用该 API 时，必须执行以下步骤：

• 将该会话实例传递给您想在该会话中运行的每个操作。

• 实现 catch 块，您可以在其中识别服务器事务错误并实现错误处理逻辑。

以下代码演示如何使用 Core API 执行事务：

async function coreTest(client) {
  const session = client.startSession();
  try {
    session.startTransaction();
    const savingsColl = client.db("bank").collection("savings_accounts");
    await savingsColl.findOneAndUpdate(
      {account_id: "9876"}, 
      {$inc: {amount: -100 }}, 
      { session });
    const checkingColl = client.db("bank").collection("checking_accounts");
    await checkingColl.findOneAndUpdate(
      {account_id: "9876"}, 
      {$inc: {amount: 100 }}, 
      { session });
    // ... perform other operations
    await session.commitTransaction();
    console.log("Transaction committed.");
  } catch (error) {
    console.log("An error occurred during the transaction:" + error);
    await session.abortTransaction();
  } finally {
    await session.endSession();
  }
}

const session = client1.startSession();
client2.db('myDB').collection('myColl').insertOne({ name: 'Jane Eyre' }, { session });

要查看使用此 API 的完全可运行的示例，请参阅使用 Core API 用法示例。

便捷事务 API

便捷事务 API 提供以下实施事务的方法：

• withSession()：运行会话中传递给它的回调。API 会自动处理会话的创建和终止。

• withTransaction(): Runs the callback passed to it within a transaction and calls the commitTransaction() method when the callback returns.

这些方法返回 回调 返回的值。例如，如果您传递给 withTransaction() 方法的 回调 返回文档 { hello: "world" }，则 withTransaction() 方法也会返回该文档。

使用便捷事务 API 时，您可以将回调的返回值作为 withTransaction() 和 withSession() 方法的返回值传播，以便在代码中的其他位置使用它们。

使用该 API 时，必须执行以下步骤：

• 将该会话实例传递给您想在该会话中运行的每个操作。

• 为会话中的每个操作执行异步 await 事务语法。

• 避免并行，例如调用 Promise.all() 方法。并行使用会话，通常会导致服务器错误。

以下代码演示如何使用 Convenient Transaction API 执行事务：

async function convTest(client) {
  let txnRes = await client.withSession(async (session) =>
    session.withTransaction(async (session) => {
      const savingsColl = client.db("bank").collection("savings_accounts");
      await savingsColl.findOneAndUpdate(
        {account_id: "9876"}, 
        {$inc: {amount: -100 }}, 
        { session });
  
      const checkingColl = client.db("bank").collection("checking_accounts");
      await checkingColl.findOneAndUpdate(
        {account_id: "9876"}, 
        {$inc: {amount: 100 }}, 
        { session });
      // ... perform other operations
      return "Transaction committed.";
    }, null)
  );
  console.log(txnRes);
}

要查看使用此 API 完全可运行的示例，请参阅使用便捷事务 API 用法示例。

便捷事务 API错误处理

便捷事务 API 包含了针对这些错误类型的重试逻辑。驱动程序会自动重试事务，直到成功提交。

核心API错误处理

如果使用 Core API执行ACID 事务，则必须在应用程序中添加以下错误处理函数：

• 一个函数，当驱动程序遇到以下情况时，该函数会重试整个事务： TransientTransactionError

• 一个函数，当驱动程序遇到以下情况时，该函数会重试提交操作： UnknownTransactionCommitResult

这些函数必须运行，直到成功提交或出现其他错误。有关此重试逻辑的示例，请参阅服务器手册中驱动程序API页面上的核心API部分。