MongoDB4.0不支持$unionWith 如何实现两集合合并查询及分页过滤

DevOps 小满

2026-10-1

问题1：$skip的放置位置

$skip需要放在$replaceRoot之后、$limit之前。你需要先完成两个集合数据的合并、展开为独立文档之后，再执行分页的跳过逻辑，否则会出现分页数据错位、数量不准的问题。

问题2：$match的配置方法

和原$unionWith的逻辑对齐，你需要在两处添加$match：

每个$lookup的子pipeline中添加过滤条件，提前过滤掉不符合要求的数据，减少不必要的资源消耗
全局合并展开后再添加一次$match，确保最终返回的所有数据都符合过滤规则，避免子pipeline过滤遗漏

修正后的完整实现代码

const bothValues = await ValueA.aggregate([
  // 取任意一条ValueA作为聚合锚点
  { $limit: 1 },
  {
    $lookup: {
      from: 'valueB',
      pipeline: [
        // 提前过滤valueB中符合条件的数据
        { $match: { isAvailable: true } },
        { $sort: { rank: -1, _id: -1 } }
      ],
      as: 'valueB',
    },
  },
  {
    $lookup: {
      from: 'ValueA',
      pipeline: [
        // 提前过滤ValueA中符合条件的数据
        { $match: { isAvailable: true } },
        { $sort: { rank: -1, _id: -1 } }
      ],
      as: 'ValueA',
    },
  },
  // 合并两个集合的结果数组
  {
    $project: {
      Union: { $concatArrays: ['$valueB', '$ValueA'] },
    },
  },
  // 展开为独立文档
  { $unwind: '$Union' },
  // 重置根节点为合并后的文档
  { $replaceRoot: { newRoot: '$Union' } },
  // 全局排序，和原$unionWith逻辑完全对齐
  { $sort: { rank: -1, _id: -1 } },
  // 分页跳过
  { $skip: skip },
  // 分页限制
  { $limit: 30 },
]);