Node.js中MySQL嵌套回调循环异步查询导致结果为空的问题求解

• 嵌套回调的执行错位：callback模式的核心逻辑是，你定义的函数（也就是callback）不会和外层代码同步执行，而是等数据库查询这类异步操作返回结果后，才会被事件循环触发执行。你现在的代码执行流是“跳跃式”的，没有按照你写的代码从上到下的顺序跑。核心原因是所有数据库查询都是异步操作：调用connection.query的时候，函数不会等数据库把结果返回，发完SQL请求就立刻往下走代码。
• 循环内异步操作无等待：for循环里连续发起多次员工查询的时候，只是把N个查询请求全部发给了数据库，没有等任何一个查询的结果返回，就立刻执行了循环外面的console.table(table)。这时候所有查询的callback都还没触发，自然table是空的。
• 原有工具函数的设计缺陷：
  • 给get_query加了async关键字，但函数内部根本没有返回Promise，async完全没生效
  • 错误处理逻辑有bug：如果查询出错调用了callback(err)，没有return阻断执行，会紧接着再调用callback(res)，造成回调被触发两次的问题

第一步：把回调风格的查询函数改造成Promise形式 #

只有返回Promise的函数，才能配合await等待执行完成，也才能被Promise.all批量等待多个异步任务：

function get_query(table, field, value) {
  // 不再接收callback参数，直接返回Promise实例
  return new Promise((resolve, reject) => {
    connection.query(
      `SELECT * FROM ${table} WHERE ${field} = ?`,
      [value],
      (err, res) => {
        if (err) return reject(err); // 出错立即返回，阻断后续逻辑
        resolve(res); // 查询成功，把结果作为Promise返回值传出
      }
    )
  })
}

第二步：用async/await重写关联查询逻辑 #

把所有异步操作都加上await等待，遇到需要并行查询多个角色的员工数据的场景，用Promise.all把所有查询任务打包，等全部结果返回后再统一拼数据、打印：

async function view_department() {
  // 等待用户完成部门选择交互
  let department = await inquirer.prompt(department_questions);

  // 等待选中部门的查询结果
  const deptList = await get_query("department", "name", department.choices);
  const selectedDept = deptList[0];

  // 等待该部门下所有关联角色的查询结果
  const roleList = await get_query("role", "department_id", selectedDept.id);

  // 并行生成每个角色对应的员工查询任务，不需要排队等
  const employeeTasks = roleList.map(role => {
    return get_query("employee", "role_id", role.id);
  })
  // 等待所有员工查询全部完成
  const employeeResults = await Promise.all(employeeTasks);

  // 把二维的查询结果拍平成一维数组，此时所有数据都已经拿到
  const table = employeeResults.flat();
  console.table(table);
}

• 不需要在每个查询的回调里单独执行console.table：那样会因为每个员工查询完成就触发一次打印，造成多次重复输出的问题。只要等所有查询完成再统一打印一次即可。
• 不要在循环里用连续的await去串行查询员工：如果角色数量多，串行查询会大幅拉长响应时间，用Promise.all并行发请求效率更高。
• 如果需要兜底捕获全流程的错误，可以在view_department函数外层套try/catch，把查询过程中的数据库错误、交互错误统一捕获处理。

内容的提问来源于stack exchange，提问作者Tuan Le