NodeJS+MySQL环境下ROLLBACK无法回滚事务问题排查

看了你的代码和问题描述，核心问题出在异步时序控制不当和事务上下文管理混乱上，下面具体分析并给出修复方案：

问题根源拆解 #

1. Async/Await与回调混用导致时序错乱 #

你在connection.query中同时使用了async回调和await，但原生mysql的query方法是基于回调的，并不返回Promise——这意味着await connection.query(...)根本不会等待回调函数执行完成。这种混用会让事务内的操作顺序完全失控：比如你的ROLLBACK可能在某些INSERT操作还没执行就触发了，或者事务内的多个操作分散在不同的异步任务里，根本不在同一个事务周期内。

2. 嵌套回调导致的事务上下文丢失 #

你的代码用了多层嵌套的回调函数，这不仅让逻辑变得混乱，还可能导致事务操作脱离同一个连接上下文。如果connection是从连接池获取的，每次调用connection.query都可能拿到不同的连接——而事务是绑定在单个连接上的，后续的INSERT和ROLLBACK如果不在同一个连接上执行，回滚自然不会生效。

3. 错误处理逻辑不严谨 #

在错误分支里，你嵌套调用ROLLBACK但没有正确等待其执行完成就返回响应，这可能导致回滚操作还没完成，请求就已经结束，事务回滚不彻底。

修复方案：用Promise+Async/Await重构事务逻辑 #

首先，我们需要把基于回调的query方法转换成Promise形式（如果用mysql2模块的话，本身就支持Promise API，直接用connection.promise().query()即可），这样才能用async/await正确控制异步时序：

// 先封装query为Promise（如果用mysql2可跳过这步）
const runQuery = (sql, params = []) => {
  return new Promise((resolve, reject) => {
    connection.query(sql, params, (err, results) => {
      if (err) reject(err);
      else resolve(results);
    });
  });
};

// 重构后的事务逻辑
async function handlePostTransaction(req, res) {
  try {
    // 1. 开启事务
    await runQuery(`START TRANSACTION;`);

    // 2. 第一个插入操作，获取post_id
    const results1 = await runQuery(`INSERT INTO... ; SELECT 198822;`);
    const post_id = results1[0].insertId;

    // 3. 第二个插入操作
    await runQuery(`INSERT INTO...`, [/* 这里传入对应的参数 */]);

    // 4. 第三个插入操作
    await runQuery(`INSERT INTO...`);

    // 测试回滚：这里主动调用ROLLBACK，替代原本的COMMIT
    await runQuery(`ROLLBACK;`);
    req.flash("flash", "事务已成功回滚");
    return res.redirect("back");
  } catch (err) {
    // 任何步骤出错，统一回滚
    try {
      await runQuery(`ROLLBACK;`);
    } catch (rollbackErr) {
      console.error("回滚操作出错：", rollbackErr);
    }
    req.flash("flash", "操作出错，已触发事务回滚");
    return res.redirect("/post");
  }
}

重构后的优势 #

• 严格的时序控制：通过async/await确保事务内的操作按顺序执行，不会出现"回滚先于插入完成"的情况。
• 统一的事务上下文：所有操作都复用同一个connection，保证事务绑定在正确的连接上。
• 清晰的错误处理：用try/catch统一捕获所有异常，任何一步出错都会触发回滚，避免嵌套回调的混乱。

内容的提问来源于stack exchange，提问作者Janez Kranjski