hoangbits/sequelize transaction await

transaction would always be undefined in catch block?

@ljinke: it's just updated.:))

@legiahoang
I am using the same thing for my project, first create the user and then after creating a role for that, I am defined the relationship in the database as well. in my case user still in the database, is it possible for delete that user entry?

Really fine method 👍

you should move this
Model.destroy({where: {id}}, {transaction});
to
Model.destroy({where: {id}, transaction}); since destroy function only take 1 parameter according to
http://docs.sequelizejs.com/class/lib/model.js~Model.html#static-method-destroy

@legiahoang hello I am using same method inside to async.waterfall but is not working so please provide me any solution.

router.post('/upload',async function(req, res){

const transaction =  await db.sequelize.transaction();

try {	
	var ArrayData =[];
	var branchId =0;
	async.waterfall([
	   function getDBZoneList(done) {
			models.ZoneList.findAll({
				where:{
					 status: 1
				}
			}).then(function(ZoneList) {
				migrationDataArray.push(ZoneList)
				done(null, ArrayData);
			});	
	   },
	   function setBranches(ArrayData,done) {
			models.Branch.create({
					name: "Test Branch1",
					status: 1,
				},transaction).then(function(insertData) {
						branchId= insertData.id;
						
						var subbranch =[{
							name: "Sub Branch2",
							parentId: branchId,
							status: 1,
						},{
							name: "Sub Branch3",
							parentId: branchId,
							status: 1,
						}];
						
						models.Branch.bulkCreate(subbranch,transaction).then(function(insertData) {
							done(null, ArrayData);
						});
				})   
	   },
	    function setLabels(ArrayData,done) {
			models.Label.create({
					name: "Test Label",
					branchId:branchId
					status: 1,
				},transaction).then(function(insertData) {
						branchId= insertData.id;
						
						var subLabel =[{
							name: "Sub Label2",
							branchId: branchId,
							status: 1,
						},{
							name: "Sub Label3",
							branchId: branchId,
							status: 1,
						}];
						
						models.Label.bulkCreate(subLabel,transaction).then(function(insertData) {
							done(null, ArrayData);
						});
				})   
	   }],						
	   function(err,ArrayData) {
			if(err){
				await transaction.rollback();
				res.json({ success: 0, message: "error" });
			}else{
				await transaction.commit();
				res.json({ success: 1, message: "Success",data:ArrayData });
			}
	   });
catch (ex) {
	await transaction.rollback();
	res.json({ success: 0, message: "error" });
}	   

});

This does not seem to work any longer as destroy has multiple options...

maybe

let transaction;
try {
 // get transaction
  transaction = await sequelize.transaction();

  // step 1
  await Model.destroy({where: {id}}, {transaction});

  // step 2
  await Model.create({}, {transaction});

  // commit
  await transaction.commit();

} catch (err) {
  // Rollback transaction if any errors were encountered
  if(transaction){
      await transaction.rollback();
  }
}