Node-MSSQL查询事务

const sql = require('mssql');

// 创建数据库连接配置
const config = {
  server: '数据库服务器地址',
  database: '数据库名称',
  user: '用户名',
  password: '密码',
};

// 创建数据库连接
const pool = new sql.ConnectionPool(config);

// 连接数据库
pool.connect().then(() => {
  // 开始事务
  const transaction = new sql.Transaction(pool);

  // 开始事务
  transaction.begin().then(() => {
    // 执行查询语句
    const request = new sql.Request(transaction);
    request.query('SELECT * FROM 表名').then((result) => {
      // 处理查询结果
      console.log(result.recordset);

      // 提交事务
      transaction.commit().then(() => {
        console.log('事务已提交');
        pool.close();
      }).catch((error) => {
        console.log('提交事务失败', error);
        pool.close();
      });
    }).catch((error) => {
      // 回滚事务
      transaction.rollback().then(() => {
        console.log('事务已回滚');
        pool.close();
      }).catch((rollbackError) => {
        console.log('回滚事务失败', rollbackError);
        pool.close();
      });
    });
  }).catch((beginError) => {
    console.log('开始事务失败', beginError);
    pool.close();
  });
}).catch((connectError) => {
  console.log('数据库连接失败', connectError);
});