如何用Mongoose同时查询两个集合并实现统一分页排序？

要实现合并两个Model的查询结果，同时统一应用筛选、排序和分页规则，你可以采用以下两种方案：

方案一：使用MongoDB $unionWith聚合（推荐） #

MongoDB 4.4及以上版本支持$unionWith聚合操作符，能在数据库层面直接合并两个集合的数据，再统一处理筛选、排序和分页，性能远优于客户端合并。

实现代码 #

const result = await Model1.aggregate([
  // 筛选Model1中符合条件的数据
  { $match: { example: 'test' } },
  // 合并Model2的集合，并对Model2应用相同筛选条件
  {
    $unionWith: {
      coll: Model2.collection.name,
      pipeline: [
        { $match: { example: 'test' } }
      ]
    }
  },
  // 按created_at降序统一排序
  { $sort: { created_at: -1 } },
  // 执行分页：先跳过(page-1)*limit条数据，再返回limit条
  { $skip: (page - 1) * limit },
  { $limit: limit }
])

注意事项 #

• 确保MongoDB版本≥4.4，否则$unionWith无法使用
• 两个集合的created_at字段类型需一致（建议都是Date类型），否则排序会出错
• 可根据需求调整两个集合各自的pipeline，比如给不同集合设置不同的筛选规则

方案二：客户端合并数据（适合小数据量场景） #

如果你的MongoDB版本较低，或者数据量很小，可以先分别查询两个集合的符合条件数据，再在客户端完成合并、排序和分页。

实现代码 #

// 并行查询两个Model的符合条件数据，各自先排序
const [dataFromModel1, dataFromModel2] = await Promise.all([
  Model1.find({ example: 'test' }).sort({ created_at: -1 }).exec(),
  Model2.find({ example: 'test' }).sort({ created_at: -1 }).exec()
])

// 合并两个数据集
const combinedData = [...dataFromModel1, ...dataFromModel2]

// 统一按created_at降序排序（合并后需重新排序，因为两个集合的时间可能交叉）
combinedData.sort((itemA, itemB) => {
  return itemB.created_at.getTime() - itemA.created_at.getTime()
})

// 手动计算分页范围并截取结果
const startIdx = (page - 1) * limit
const paginatedResult = combinedData.slice(startIdx, startIdx + limit)

注意事项 #

• 此方案会将所有符合条件的数据加载到客户端内存，数据量大时会导致性能问题，仅适合小数据量场景
• 若两个Model的字段结构差异较大，后续使用结果时需处理字段缺失的情况

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