使用管道聚合查找和匹配不起作用 mongodb

Question

我有这两个简单的集合：

项目：

{
    "id" : "111",
    "name" : "apple",
    "status" : "active"
}    
{
    "id" : "222",
    "name" : "banana",
    "status" : "active"
}

库存：

{
    "item_id" : "111",
    "qty" : 3,
    "branch" : "main"
}
{
    "item_id" : "222",
    "qty" : 3
}

现在我只想 return 具有“status”==“active”和“branch”的项目存在且等于库存集合中的“main”。我在下面有这段代码，但它 return 所有文件，第二个文件有一个空的“信息”数组。

db.getCollection('items')
.aggregate([
  {$match:{$and:[
                {"status":'active'},
                {"name":{$exists:true}}
            ]
}},
{$lookup:{
    as:"info",
    from:"inventory",
    let:{fruitId:"$id"},
    pipeline:[
     {$match:{
         $and:[
            {$expr:{$eq:["$item_id","$$fruitId"]}},
            {"branch":{$eq:"main"}},
            {"branch":{$exists:true}}
         ]         
         }    
     }
    ]    
}}
])

谁能告诉我如何解决这个问题？

Answer 1

您的代码运行良好。我认为您只需要在管道的最后一个 $match 阶段。

db.items.aggregate([
  {
    $match: {
      $and: [
        { "status": "active" },
        { "name": { $exists: true } }
      ]
    }
  },
  {
    $lookup: {
      as: "info",
      from: "inventory",
      let: { fruitId: "$id" },
      pipeline: [
        {
          $match: {
            $and: [
              { $expr: { $eq: [ "$item_id", "$$fruitId" ] } },
              { "branch": { $eq: "main" } },
              { "branch": { $exists: true } }
            ]
          }
        }
      ]
    }
  },
  {
    "$match": {
      "info": { "$ne": [] }
    }
  }
])

mongoplayground

Answer 2

查询

匹配
在 id/item_id 上查找，并将分支与“main”匹配（如果它不存在，则无论如何都会为 false）
只保留非空

*query 和@YuTing 差不多，反正我已经写了，所以我发了，替代查找语法的细微差别

Test code here

items.aggregate(
[{"$match":
  {"$expr":
   {"$and":
    [{"$eq":["$status", "active"]},
     {"$ne":[{"$type":"$name"}, "missing"]}]}}},
 {"$lookup":
  {"from":"inventory",
   "localField":"id",
   "foreignField":"item_id",
   "pipeline":[{"$match":{"$expr":{"$eq":["$branch", "main"]}}}],
   "as":"inventory"}},
 {"$match":{"$expr":{"$ne":["$inventory", []]}}},
 {"$unset":["inventory"]}])

使用管道聚合查找和匹配不起作用 mongodb

Aggregate Lookup with pipeline and match not working mongodb

pipeline

aggregate

mongodb