在if else条件下回滚事务knex

const knex = require('knex')({
  client: 'mysql',
  connection: {
    host: 'localhost',
    user: 'your_database_user',
    password: 'your_database_password',
    database: 'your_database_name'
  }
});

async function performTransaction() {
  try {
    await knex.transaction(async (trx) => {
      // 在事务中执行数据库操作
      await knex('table1').transacting(trx).insert({ column1: 'value1' });
      await knex('table2').transacting(trx).insert({ column2: 'value2' });

      // 根据if else条件判断是否回滚事务
      if (condition) {
        await trx.rollback(); // 回滚事务
        console.log('事务已回滚');
      } else {
        await trx.commit(); // 提交事务
        console.log('事务已提交');
      }
    });
  } catch (error) {
    console.error('事务执行失败:', error);
  }
}

performTransaction();