MongoDB聚合管道$unionWith子管道$Type变量未解析问题咨询

$unionWith的子管道是独立执行的，执行上下文仅指向被联合的目标集合，无法访问上游阶段输出的文档字段。你在子管道$match中写的"$Type"不会解析为上游主文档的Type字段值，只会去匹配目标集合里Type字段值为字符串"$Type"的文档，自然无法得到预期结果。
$unionWith本身的定位是做两个结果集的全量合并，不支持向上游读取动态字段值做过滤，单管道内无法直接用它实现你要的动态匹配逻辑。

方案1：单聚合管道实现（推荐） #

用自连接$lookup实现，不需要拆分查询，逻辑更顺：

db.getCollection("col").aggregate([
  // 匹配指定_id的主文档
  {$match: {'_id': ObjectId('62722c260ee18a304784d8cf')}},
  // 自连接同集合，拉取所有Type和主文档一致的文档
  {$lookup: {
    from: "col",
    localField: "Type",
    foreignField: "Type",
    as: "sameTypeDocs"
  }},
  // 合并主文档和同类型文档为一个数组
  {$project: {
    res: {$concatArrays: [["$$ROOT"], "$sameTypeDocs"]}
  }},
  // 拆解为独立文档
  {$unwind: "$res"},
  {$replaceRoot: {newRoot: "$res"}},
  // 去重，避免主文档重复返回
  {$group: {
    _id: "$_id",
    doc: {$first: "$$ROOT"}
  }},
  {$replaceRoot: {newRoot: "$doc"}}
])

方案2：分两步查询+$unionWith #

如果一定要用$unionWith，需要先查出主文档的Type值作为常量，再传入聚合管道：

// 第一步：查询主文档拿到Type值
const mainDoc = db.getCollection("col").findOne(
  {_id: ObjectId('62722c260ee18a304784d8cf')},
  {Type: 1}
)

// 第二步：执行聚合，Type作为固定值传入子管道
db.getCollection("col").aggregate([
  {$match: {'_id': ObjectId('62722c260ee18a304784d8cf')}},
  {$unionWith: {
    coll: "col",
    pipeline: [
      // 排除主文档本身避免重复
      {$match: {
        Type: mainDoc.Type,
        _id: {$ne: mainDoc._id}
      }}
    ]
  }}
])

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