如何将回调风格MongoDB查询转为Promise并通过Promise.all批量执行？

嗨，我来帮你解决这个问题～你之前的思路方向是对的，想用Promise.all批量处理多个查询，但问题出在**myFunc是基于回调的函数，它本身不会返回Promise**，所以你用map生成的数组里其实全是undefined，Promise.all自然没法正常工作。

下面是正确的实现步骤：

1. 把回调风格的函数包装成Promise版本 #

我们需要先给myFunc做一层包装，让它返回Promise对象。你可以手动写包装函数，或者利用Node.js内置的util.promisify工具（如果是Node.js环境的话）：

手动包装版本 #

function myFuncPromise(sport) {
  return new Promise((resolve, reject) => {
    myFunc(sport, (error, result) => {
      if (error) {
        // 出错时reject Promise
        reject(error);
      } else {
        // 成功时resolve结果
        resolve(result);
      }
    });
  });
}

用util.promisify简化（Node.js环境） #

如果你的运行环境是Node.js，直接用内置工具更省心：

const { promisify } = require('util');
// 把myFunc转成返回Promise的函数
const myFuncPromise = promisify(myFunc);

2. 构建Promise数组并批量执行 #

现在我们可以用包装后的函数生成Promise数组，再通过Promise.all批量处理：

const sportList = ['football', 'volleyball'];
// 用map生成每个sport对应的Promise实例
const promises = sportList.map(sport => myFuncPromise(sport));

// 批量执行所有Promise
Promise.all(promises)
  .then(allResults => {
    // allResults是一个数组，顺序和sportList对应，每个元素是对应sport的查询结果
    console.log('所有查询结果:', allResults);
    // 这里可以继续处理结果
  })
  .catch(error => {
    // 如果任意一个查询失败，会直接进入catch分支
    console.error('查询出错:', error);
    // 处理错误逻辑
  });

为什么原来的写法不行？ #

你之前的代码sportList.map(function(val){ return myFunc(val); })里，myFunc执行后没有返回值（它的逻辑是靠回调传递结果），所以map出来的数组里每个元素都是undefined，而Promise.all需要的是Promise实例数组，自然无法正确触发批量执行。

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