MongoDB 数据库秒杀

const { MongoClient } = require('mongodb');

async function run() {
  const uri = "your_mongodb_connection_string";
  const client = new MongoClient(uri);

  try {
    await client.connect();
    const database = client.db('your_database_name');
    const collection = database.collection('products');

    const session = client.startSession();
    session.startTransaction();

    try {
      const product = await collection.findOne({ _id: 'product_id', stock: { $gt: 0 } }, { session });
      if (!product) {
        throw new Error('Out of stock');
      }

      await collection.updateOne({ _id: 'product_id' }, { $inc: { stock: -1 } }, { session });
      await session.commitTransaction();
      console.log('Purchase successful');
    } catch (error) {
      await session.abortTransaction();
      console.error('Transaction aborted:', error);
    }
  } finally {
    await client.close();
  }
}

run().catch(console.dir);