在 Node.js 中使用 MongoDB 事务

const { MongoClient, ObjectId } = require('mongodb');
 
// 连接到MongoDB数据库
const url = 'mongodb://localhost:27017';
const client = new MongoClient(url);
 
async function runTransaction() {
  try {
    // 连接到客户端
    await client.connect();
    const database = client.db('mydatabase');
    const collection = database.collection('documents');
 
    // 开始一个事务
    const session = client.startSession();
    session.startTransaction();
 
    try {
      // 在事务上下文中执行操作
      const document = await collection.findOneAndUpdate(
        { _id: ObjectId("要更新的文档的ObjectId字符串") },
        { $set: { field: "新的值" } },
        { session }
      );
 
      // 可以执行更多的数据库操作...
 
      // 提交事务
      await session.commitTransaction();
      console.log('文档更新成功，并且事务已提交');
    } catch (error) {
      // 如果有任何错误，回滚事务
      await session.abortTransaction();
      console.log('事务已回滚');
      throw error;
    } finally {
      // 结束会话
      await session.endSession();
    }
  } finally {
    // 关闭客户端连接
    await client.close();
  }
}
 
// 运行事务
runTransaction().catch(console.error);

这段代码展示了如何在Node.js中使用MongoDB的事务。首先，我们创建了一个MongoClient实例并连接到数据库。然后，我们开始一个事务，并在事务的上下文中执行了一个文档的更新操作。如果操作成功，我们提交事务；如果有任何错误，我们回滚事务并重新抛出错误。最后，我们结束会话并关闭客户端连接。