transactions - Node.js 7 如何将sequelize事务与async/await一起使用？

Question

Node.js 7 及更高版本已经支持 async/await 语法。我应该如何在后续事务中使用 async/await？

Answer 1

let transaction;    

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

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

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

  // step 3
  await Model.update({}, { where: { id }, transaction });

  // commit
  await transaction.commit();

} catch (err) {
  // Rollback transaction only if the transaction object is defined
  if (transaction) await transaction.rollback();
}