mongo多文档事务|极客笔记

mongo多文档事务

在MongoDB中，事务是用来确保一系列操作要么全部成功要么全部失败的机制。在之前的版本中，MongoDB并不支持事务操作，但从MongoDB 4.0版本开始，它引入了对多文档事务的支持。

事务的基本概念

事务是由一系列操作组成的逻辑单元，这些操作要么全部成功提交，要么全部失败回滚。MongoDB的事务是针对多文档操作而言的，多个文档在一起组成一个事务单元。

开启事务

在MongoDB中，我们可以使用startSession()方法来开启一个事务会话，并在该会话中执行事务操作。下面是一个简单的示例代码：

const session = db.getMongo().startSession();
session.startTransaction();

try {
    // 在事务中执行多个操作
    db.collection1.insertOne({ key1: "value1" }, { session: session });

    db.collection2.updateOne({ key2: "value2" }, { $set: { key3: "value3" }}, { session: session });

    // 提交事务
    session.commitTransaction();
} catch (error) {
    // 回滚事务
    session.abortTransaction();
    throw error;
} finally {
    session.endSession();
}

在上面的代码中，我们首先通过startSession()方法开启了一个事务会话，然后在该会话中执行了一系列的操作，最后通过commitTransaction()方法提交事务或者通过abortTransaction()方法回滚事务。

多文档事务操作

在一个事务中，我们可以通过session对象来执行多文档的操作。下面是一个包含多个操作的事务示例：

const session = db.getMongo().startSession();
session.startTransaction();

try {
    const result1 = db.collection1.insertOne({ key1: "value1" }, { session: session });
    const result2 = db.collection2.updateOne({ key2: "value2" }, { $set: { key3: "value3" }}, { session: session });

    // 检查操作结果
    if (result1.insertedCount === 1 && result2.modifiedCount === 1) {
        session.commitTransaction();
    } else {
        session.abortTransaction();
        throw new Error("Transaction failed");
    }
} catch (error) {
    session.abortTransaction();
    throw error;
} finally {
    session.endSession();
}

在上面的示例中，我们执行了一个插入操作和一个更新操作，并在最后检查操作结果来决定是提交事务还是回滚事务。