mongo:$存在于管道$查找中，未按预期工作

Question

我的两个系列是：

产品类别

{
    "_id" : ObjectId("5fca496b61e8a83e5cd0fb01"),
    "category_id" : "1",
    ...
}

产品

{
    "_id" : ObjectId("60684610f8f81d0013ce776d"),
    "primary_parent_category" : "1653",
    ...
}

在$lookup中使用localfield和foreignfield，我可以获得预期的结果。

db.getCollection('product_category').aggregate([
    {
    "$lookup": {
        "from": "product",
        "localField": "category_id",
        "foreignField": "primary_parent_category",
        "as": "products"
    }
    },
//     { "$match": { "products": { $exists: true, $not: { $size: 0 } } }},
    { "$match": { "products": { $exists: true, $ne: [] } }},
    {
    "$project":{
        "child_categories": 0,
        "featured_products": 0,
        "related_brands": 0,
        "child_category_names": 0
    }
    }
])

上面的工作正常，但我必须将$look kup中的管道模型用于另一个用例（用于添加$Geo近）。聚合查询如下所示。

db.getCollection('product_category').aggregate([
    {
    "$lookup": {
        "from": "product",
        "let": { "category_id": "$category_id" },
        "pipeline": [
             { "$match": { "product": { $exists: true, $ne: [] } }},      
             {
                 "$project":{
                     "child_categories": 0,
                     "featured_products": 0,
                     "related_brands": 0,
                     "child_category_names": 0
                 }
             }
        ],
        "as": "products"
    }
    }
])

这没有按预期工作，并返回大量条目。$match中的$exists没有得到正确执行。任何帮助，不胜感激。提前谢谢。

Answer 1

正确的方法是@hhharsha36和@turivishal提到的方法的结合。我不得不将$exist的匹配查询移到$lookup块之后，而变量映射匹配块保持不变。

db.getCollection('product_category').aggregate([
  {
    "$lookup": {
      "from": "product",
      "let": { "category_id": "$category_id" },
      "pipeline": [
    {
      "$match": {
        "$expr": 
          { "$eq": [ "$primary_parent_category",  "$$category_id" ] },
      }},
    {
      "$project":{
          "child_categories": 0,
          "featured_products": 0,
          "related_brands": 0,
          "child_category_names": 0
      }
    }
      ],
      "as": "products"
    }
  },
  { "$match": 
      { "products": 
      { 
          "$exists": true,
          "$ne": [],
      } 
      } 
   },
])

Answer 2

正如@turivishal所指出的，您必须在管道参数中的$match中使用$expr运算符。无论您试图使用$$引用临时MongoDB变量，都必须这样做。

{
  $match: {
    {
      $expr: {"$eq": ["$$<VAR-NAME-IN-LET>", "$<FOREIGN-KEY-IN-TARGET-COL>"]}
    }
  }
}

db.getCollection('product_category').aggregate([
  {
    "$lookup": {
      "from": "product",
      "let": { "category_id": "$category_id" },
      "pipeline": [
        {
          "$match": {
            "$expr": {
              { $eq: [ "$primary_parent_category",  "$$category_id" ] },
            }
            "product": { 
              $exists: true,
              $ne: [],
            },
          }
        },      
        {
          "$project":{
              "child_categories": 0,
              "featured_products": 0,
              "related_brands": 0,
              "child_category_names": 0
          }
        }
      ],
      "as": "products"
    }
  }
])