如何使用MongoDB $lookup与$unionWith获取两集合数据并排除指定组

你的$lookup语句有三个核心错误，导致排除条件失效：

• lookup语法冲突：同时使用localField/foreignField和let+pipeline两种模式，MongoDB不支持这种混合写法，会导致变量和逻辑混乱。
• 变量作用域错误：let里的$groupId、$userId引用的是user集合的字段，但你实际需要对比的是stocks和items集合的字段，变量定义完全不符合需求。
• 匹配逻辑错误：你试图用$nin排除单个groupId，但实际要排除的是userId和groupId同时匹配的组合；另外items集合字段是userid（小写d），你的条件中变量引用逻辑也不成立。

正确实现方式 #

下面提供两种可行方案，按需选择：

方案一：从user集合关联查询 #

如果你需要先从user集合筛选userId=1的文档，再关联获取stock和item数据：

db.user.aggregate([
  // 筛选userid=1的用户
  { $match: { userid: 1 } },
  {
    $lookup: {
      from: "stocks",
      let: { target_uid: "$userid" },
      pipeline: [
        // 获取stocks中对应用户的数据
        { $match: { $expr: { $eq: ["$userId", "$$target_uid"] } } },
        // 合并items数据并排除重复组合
        {
          $unionWith: {
            coll: "items",
            pipeline: [
              { $match: { userid: 1 } },
              {
                $match: {
                  $expr: {
                    $not: {
                      $in: [
                        { uid: "$userid", gid: "$groupId" },
                        { $map: { input: "$$ROOT", as: "stock", in: { uid: "$$stock.userId", gid: "$$stock.groupId" } } }
                      ]
                    }
                  }
                }
              }
            ]
          }
        }
      ],
      as: "stock_items"
    }
  }
])

方案二：直接合并两个集合处理 #

如果不需要关联user集合，直接提取stocks和items的目标数据：

db.stocks.aggregate([
  // 先筛选stocks中userId=1的条目
  { $match: { userId: 1 } },
  {
    $unionWith: {
      coll: "items",
      pipeline: [
        { $match: { userid: 1 } },
        // 查找与stocks重复的(userId, groupId)组合
        {
          $lookup: {
            from: "stocks",
            let: { item_uid: "$userid", item_gid: "$groupId" },
            pipeline: [
              { $match: { $expr: { $and: [{ $eq: ["$userId", "$$item_uid"] }, { $eq: ["$groupId", "$$item_gid"] }] } } }
            ],
            as: "duplicates"
          }
        },
        // 排除存在重复的条目
        { $match: { duplicates: { $size: 0 } } },
        // 清理临时字段
        { $unset: "duplicates" }
      ]
    }
  }
])

执行后会得到预期结果：包含stocks中userId=1的条目，以及items中userId=1且groupId未在stocks的userId=1条目中出现的两个条目。

内容的提问来源于stack exchange，提问作者Anil Kumar H P