// use default connection const t = await sequelize.transaction(); // use specific database const con = new this.sequelize.Sequelize(process.env.DB) const transaction: Transaction = await con.transaction()// First, we start a transaction and save it into a variable const t = await sequelize.transaction(); try { // Then, we do some calls passing this transaction as an option: const user = await User.create({ firstName: 'Bart', lastName: 'Simpson' }, { transaction: t }); await user.addSibling({ firstName: 'Lisa', lastName: 'Simpson' }, { transaction: t }); // If the execution reaches this line, no errors were thrown. // We commit the transaction. await t.commit(); } catch (error) { // If the execution reaches this line, an error was thrown. // We rollback the transaction. await t.rollback(); }//TransactionExecutor.js import { DbConnection } from './dataSource'; const { Transaction } = require('sequelize'); const executeTransaction = (callBack) => { return DbConnection().transaction({ isolationLevel: Transaction.ISOLATION_LEVELS.READ_COMMITTED, }, (t) => callBack(t)); }; export { executeTransaction, };try { const result = 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 }); return user; }); // If the execution reaches this line, the transaction has been committed successfully // `result` is whatever was returned from the transaction callback (the `user`, in this case) } catch (error) { // If the execution reaches this line, an error occurred. // The transaction has already been rolled back automatically by Sequelize! }return sequelize.transaction().then(function (t) { return User.create({ firstName: 'Homer', lastName: 'Simpson' }, {transaction: t}).then(function (user) { return user.addSibling({ firstName: 'Lisa', lastName: 'Simpson' }, {transaction: t}); }).then(function () { return t.commit(); }).catch(function (err) { return t.rollback(); }); });