MongoDB 交易

MongoDB 交易：介绍和应用案例

javascript
const { MongoClient } = require("mongodb");
async function runTransaction(client) {
  const session = client.startSession();
  try {
    session.startTransaction();
    const ordersCollection = client.db("mydb").collection("orders");
    const productsCollection = client.db("mydb").collection("products");
    // 在事务中进行数据库操作
    const order = { orderId: 1, productId: 100, quantity: 10 };
    const product = { productId: 100, name: "Product A", stock: 50 };
    await ordersCollection.insertOne(order, { session });
    await productsCollection.updateOne(
      { productId: product.productId },
      { $inc: { stock: -order.quantity } },
      { session }
    );
    await session.commitTransaction();
    console.log("Transaction committed successfully.");
  } catch (error) {
    console.error("Error occurred during transaction:", error);
    session.abortTransaction();
  } finally {
    session.endSession();
  }
}
async function main() {
  const uri = "mongodb://localhost:27017/?replicaSet=rs0";
  const client = new MongoClient(uri);
  try {
    await client.connect();
    await runTransaction(client);
  } finally {
    await client.close();
  }
}
main().catch(console.error);