nodejs中的Sql批处理，如果任何一个查询执行失败，都应该撤销更改

const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'mydatabase'
});

// 开始事务
connection.beginTransaction(function(err) {
  if (err) throw err;

  // 定义要执行的SQL语句
  const sqlStatements = [
    'UPDATE users SET age = age + 1 WHERE id = 1',
    'UPDATE users SET age = age - 1 WHERE id = 2',
    'DELETE FROM users WHERE id = 3'
  ];

  // 执行SQL语句
  sqlStatements.forEach(sql => {
    connection.query(sql, function(error, results, fields) {
      if (error) {
        // 发生错误时回滚事务
        return connection.rollback(function() {
          throw error;
        });
      }
    });
  });

  // 提交事务
  connection.commit(function(err) {
    if (err) {
      // 发生错误时回滚事务
      return connection.rollback(function() {
        throw err;
      });
    }
    console.log('Sql批处理执行成功！');
  });

  // 关闭数据库连接
  connection.end();
});