mongoose-transaction

main.js

// ESM syntax is supported.
import mongoose from "mongoose";
import { MongoMemoryReplSet , MongoMemoryServer } from "mongodb-memory-server";


const replSet = new MongoMemoryReplSet();
const mongod = new MongoMemoryServer();
var dbService = null
const startMongo = async () => {
  console.log('start mongodb')
  const uri = await mongod.getConnectionString();
  const port = await mongod.getPort();
  const dbPath = await mongod.getDbPath();
  const dbName = await mongod.getDbName();
  await replSet.waitUntilRunning();
   dbService = mongoose .connect( uri , { useNewUrlParser: true})
  .then(console.log("connection mongoo"));

};


startMongo();
var User = mongoose.model("User", new mongoose.Schema({ name: String , status : { type : String , enum : ['OK' , 'PENDING'] } }));
User.create({ name : "voratham" , status : 'OK' }).then( res =>  {
  // console.log('insert success :: ' , res)
  User.find().then( user => console.log('user :: ' , user))
})
const createUser = async () => {

  const session = await User.startSession();
  await session.startTransaction();

  try {
    const options = { session };
    const userTarget = await User.create({ name: "Thanaphon" , status: 'FAIL' });
    if(userTarget == null){
      throw new Error("not fond name on user collection !")
    }
    console.log("userTarget :: ", userTarget);
    const updateUser = await User.create(
      { name: "dream" },
      options
    );
    console.log("updateUser", updateUser);

    await session.commitTransaction();
    User.find().then( user => console.log('after commitTransaction :: ' , user))

  } catch (error) {
    console.log("error :: ", error && error.errmsg && error.errmsg || error);
    await session.abortTransaction();
    User.find().then( user => console.log('after abortTransaction :: ' , user))
    console.log('abortTransaction....')
    session.endSession();
  }
};

createUser();