Java MongoDB 投影

Question

我指的是 mongodb 官方投影页面，我在其中遇到了以下示例，其中过滤了子文档中的数组元素： https://docs.mongodb.com/manual/reference/operator/aggregation/filter/#exp._S_filter

db.sales.aggregate([
   {
      $project: {
         items: {
            $filter: {
               input: "$items",
               as: "item",
               cond: { $gte: [ "$$item.price", 100 ] }
            }
         }
      }
   }
])

我正在尝试在 Java 中实现它，但我没有正确执行，子文档数组中的元素没有被过滤。

输入集合：

{
   _id: 0,
   items: [
     { item_id: 43, quantity: 2, price: 10 },
     { item_id: 2, quantity: 1, price: 240 }
   ]
}
{
   _id: 1,
   items: [
     { item_id: 23, quantity: 3, price: 110 },
     { item_id: 103, quantity: 4, price: 5 },
     { item_id: 38, quantity: 1, price: 300 }
   ]
}
{
    _id: 2,
    items: [
       { item_id: 4, quantity: 1, price: 23 }
    ]
}

预期输出集合：

{
   "_id" : 0,
   "items" : [
      { "item_id" : 2, "quantity" : 1, "price" : 240 }
   ]
}
{
   "_id" : 1,
   "items" : [
      { "item_id" : 23, "quantity" : 3, "price" : 110 },
      { "item_id" : 38, "quantity" : 1, "price" : 300 }
   ]
}
{ "_id" : 2, "items" : [ ] }

在Java(mongo Driver 3.9.1)中，这就是我正在做的：

Bson priceFilter = Filters.gte("items.price", 100);
mongoCollection.aggregate(
  Aggregates.project(Projections.fields(priceFilter))
);

如何使用子文档数组的聚合函数进行投影，我需要根据某些条件从子文档数组中过滤掉元素？

Answer 1

在MongoDB Java Driver 3.9.1, collection.aggregate()需要一个java.util.List 作为参数。所以你需要用下面的代码替换你的 Java 代码。

mongoCollection.aggregate(
  Arrays.asList(
    Aggregates.project(Projections.computed("items",
      new Document().append("$filter",
        new Document().append("input", "$items").append("as", "item").append("cond", 
        new Document().append("$gte", Arrays.asList("$$item.price",100))))))
    )
);

Java MongoDB 投影

Java MongoDB Projection

mongodb

mongodb-java

mongodb-query

aggregation-framework