Node.js嵌套Promise问题：如何结合两个SQL查询结果构建对象

没问题，我来帮你搞定这个Node.js里嵌套Promise的问题！你现在的核心需求是在prodResultFunc里同时执行两个SQL查询，把它们的结果组合成对象返回对吧？之前单个查询的版本能跑，但多个查询就卡壳了，主要是没处理好多个Promise的等待和结果组合。

核心问题分析 #

你原来的prodResultFunc代码里，虽然发起了两个execDBQuery调用，但既没有等待它们完成，也没有把两个查询的结果关联起来——map里的async函数没有返回一个包含组合结果的Promise，导致Promise.all无法正确收集最终的对象数组。

解决方案1：用async/await顺序执行查询（简单直观） #

如果两个查询没有依赖关系，顺序执行的代码写起来更直白：

async function prodResultFunc(prodRowSet) {
  const results = await Promise.all(
    prodRowSet.map(async (objBatchRow) => {
      // 等待第一个查询完成并读取value-1
      const resultSet2 = await execDBQuery(sqlQuery2);
      const value1 = resultSet2[0].yourValue1Key; // 替换成实际读取逻辑
      
      // 等待第二个查询完成并读取value-2
      const resultSet3 = await execDBQuery(sqlQuery3);
      const value2 = resultSet3[0].yourValue2Key; // 替换成实际读取逻辑
      
      // 用两个值创建对象并返回
      return {
        value1,
        value2,
        // 可以添加objBatchRow里的其他属性
        batchId: objBatchRow.id
      };
    })
  );
  return results; // 一定要返回结果，这样外层才能拿到
}

解决方案2：用Promise.all并行执行查询（性能更优） #

如果两个查询之间没有依赖，推荐用Promise.all同时发起请求，减少总等待时间：

async function prodResultFunc(prodRowSet) {
  const results = await Promise.all(
    prodRowSet.map(async (objBatchRow) => {
      // 并行发起两个查询，等待两者都完成
      const [resultSet2, resultSet3] = await Promise.all([
        execDBQuery(sqlQuery2),
        execDBQuery(sqlQuery3)
      ]);
      
      // 分别读取两个结果的值
      const value1 = resultSet2[0].yourValue1Key;
      const value2 = resultSet3[0].yourValue2Key;
      
      // 返回组合后的对象
      return {
        value1,
        value2,
        batchId: objBatchRow.id
      };
    })
  );
  return results;
}

修正getMethod的链式调用 #

另外你的getMethod也需要调整，确保Promise链能正确传递结果，并且处理错误：

// 用async/await改写更简洁
async function getMethod() {
  try {
    // 先获取第一组查询结果
    const productionQueryRows = await execDBQuery(sqlQuery1);
    // 调用prodResultFunc获取最终组合结果
    const finalResult = await prodResultFunc(productionQueryRows);
    console.log(finalResult); // 输出给用户的最终结果
    return finalResult; // 如果需要把结果返回给调用getMethod的地方
  } catch (error) {
    // 一定要处理错误，避免未捕获的Promise异常
    console.error('查询过程出错:', error);
    throw error; // 可以选择抛出错误让上层处理，或者直接返回错误信息
  }
}

关键注意点 #

• 所有异步操作的结果都要通过await或者.then()等待，否则会拿到未完成的Promise或者undefined
• Promise.all会等待所有传入的Promise完成，返回结果数组，顺序和传入的Promise顺序一致
• 不要忘记错误处理，用try/catch（async/await模式）或者.catch()（链式调用模式）捕获异常，避免程序崩溃

内容的提问来源于stack exchange，提问作者Abhijit Thakre