node.js sequelize transaction using array for queries

Question

I would like to put the updates on the clothingModel inside a transaction, and if it commits then update reservationModel.

This is the code I am trying to rewrite into using sequelize.transaction

    try {
      data.clothes.forEach(async (clothing) => {
        await this.clothingModel.update(
          { price: clothing.price },
          { where: { id: clothing.clothingId } }
        );
      });
    } catch (e) {
      //throw exception
    }
    //if exception is not thrown
    this.reservationModel.update(
      { dropoffStatus: 'APPROVED' },
      { where: { id: data.reservationId } }
    );

But I have struggled to make it conform to the way transactions is used in sequelize

sequelize.transaction(function (t) {
  return User.create({
    firstName: 'Abraham',
    lastName: 'Lincoln'
  }, {transaction: t}).then(function (user) {
    return user.setShooter({
      firstName: 'John',
      lastName: 'Boothe'
    }, {transaction: t});
  });
}).then(function (result) {
  // Transaction has been committed
  // result is whatever the result of the promise chain returned to the transaction callback 
}).catch(function (err) {
  // Transaction has been rolled back
  // err is whatever rejected the promise chain returned to the transaction callback
});

Is it possible? If so, how?

Anatoly · Accepted Answer · 2020-11-27 11:51:14Z

1

It would be better to turn transaction callback into async to make it look like sequential code:

try {
  const createdUser = await sequelize.transaction(async t => {
    const user = await User.create({
      firstName: 'Abraham',
      lastName: 'Lincoln'
    }, {transaction: t});
    await user.setShooter({
        firstName: 'John',
        lastName: 'Boothe'
      }, {transaction: t});
    })
  });
  // transaction committed
  .. other code
} catch (err) {
  // transaction rolled back
}

Additional example with a cycle:

await sequelize.transaction(async t => {
  for(const clothing of data.clothes) {
     await this.clothingModel.update(
       { price: clothing.price },
       { where: { id: clothing.clothingId },
         transaction: t
       }
     );
  }
  // you can move this `update` outside the callback
  // if you wish to execute it out of transaction
  this.reservationModel.update(
    { dropoffStatus: 'APPROVED' },
    { where: { id: data.reservationId },
      transaction: t
    });
});

edited Nov 27, 2020 at 11:51

answered Nov 27, 2020 at 5:43

Anatoly

23.2k3 gold badges33 silver badges46 bronze badges

Sign up to request clarification or add additional context in comments.

4 Comments

Jonas Grønbek Over a year ago

I think this is more of a suggestion/proposal than an actual answer. I will give you an upvote, but it does not solve my problem

Anatoly Over a year ago

As I understood you wish to do several changes in the same transaction. If not please clarify a bit in your question what you're trying to achieve

Jonas Grønbek Over a year ago

I would like to use the data.clothes array for the queries inside of the transaction

Anatoly Over a year ago

I added an example with a cycle to my answer

Collectives™ on Stack Overflow

node.js sequelize transaction using array for queries

1 Answer 1

4 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

4 Comments

Your Answer

Sign up or log in

Post as a guest

Related