如何避免Mongoose空查询结果存入数组？求更优方案

看起来你在处理Mongoose查询结果的时候碰到了一个性能痛点——当find()没匹配到数据返回空数组、findOne()返回null时，这些无效结果会混进目标数组，事后用filterMessage()过滤在数据量大的时候确实不太高效。我来给你几个更优的解决方案，从查询层面到Promise处理阶段都有，你可以根据业务场景选择：

1. 在数据库查询层面优化（性能最优，优先推荐） #

针对findOne()关联查询场景 #

如果你的findOne()是用来获取关联文档（比如从GroupMessageMap关联查询消息），直接用Mongoose的populate功能就能在数据库层面完成关联+过滤，避免拿到null结果：

// 示例：用populate直接拉取有效关联消息，自动跳过无匹配的情况
const groupMessageMaps = await GroupMessageMap.find({ group: /* 你的查询条件 */ })
  .populate({
    path: 'message', // 替换成你的关联消息字段名
    match: { /* 可选：如果需要额外过滤消息的条件，比如时间范围等 */ },
    options: { limit: size, skip: (page - 1) * size } // 直接在这里处理分页
  })
  .exec();

// 提取非null的关联消息，一步到位
const validMessages = groupMessageMaps.map(item => item.message).filter(Boolean);

这种方式把关联查询和过滤都交给数据库，比你循环调用findOne()高效得多，而且返回的结果里不会有多余的null。

针对find()无匹配场景 #

如果find()返回空数组是因为查询条件没匹配到数据，可以先通过exists判断是否有匹配文档，再决定是否执行查询：

// 先检查是否存在匹配数据，避免执行无意义的查询
const hasMatchingDocs = await GroupMessageMap.exists({ group: /* 你的查询条件 */ });
if (hasMatchingDocs) {
  const matchedResults = await GroupMessageMap.find({ group: /* 你的查询条件 */ });
  promises.push(matchedResults);
}
// 没有匹配的话就不往promises里加，从根源避免空数组混入

2. 在Promise处理阶段提前过滤 #

如果业务逻辑限制没法在查询层面优化，那就在每个查询完成后立刻判断结果是否有效，再决定是否加入目标数组：

async media(receiverId, page, size, callback) {
  const validResults = [];
  const groupMessageMaps = await GroupMessageMap.find({ group: /* 你的查询条件 */ });

  // 遍历的时候逐个处理查询，只保留有效结果
  for (const map of groupMessageMaps) {
    const queryResult = await SomeModel.findOne({ /* 你的查询条件 */ });
    // 判断结果是否有效：非null，且如果是数组的话长度大于0
    if (queryResult && (!Array.isArray(queryResult) || queryResult.length > 0)) {
      validResults.push(queryResult);
    }
  }

  // 这里validResults已经是过滤后的有效数据，直接用就行
  callback(null, validResults);
}

这种方式避免了把大量无效数据先存入数组再过滤，减少了内存占用，数据量越大效果越明显。

3. 并行查询场景用Promise.allSettled过滤 #

如果你的查询是并行执行的，用Promise.allSettled可以拿到每个Promise的执行状态，然后只提取成功且有效的结果：

async media(receiverId, page, size, callback) {
  const groupMessageMaps = await GroupMessageMap.find({ group: /* 你的查询条件 */ });
  
  // 生成所有并行查询的Promise
  const queryPromises = groupMessageMaps.map(map => 
    SomeModel.findOne({ /* 你的查询条件 */ })
  );

  // 等待所有Promise完成，不管成功失败
  const settledResults = await Promise.allSettled(queryPromises);

  // 过滤出成功且有效的数据
  const validResults = settledResults
    .filter(res => res.status === 'fulfilled') // 只保留成功的Promise
    .map(res => res.value)
    .filter(item => item && (!Array.isArray(item) || item.length > 0)); // 过滤空值/空数组

  callback(null, validResults);
}

这种方式不会因为某个查询失败导致整个批量查询报错，同时也能提前过滤无效结果，适合高并发的批量查询场景。

总的来说，优先选方案1，把过滤逻辑交给数据库是性能最好的；如果业务限制没法用方案1，方案2和3能帮你在应用层面减少无效数据的处理开销。

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