How to count elements matching certain condition in array field and insert into projection with MongoDB java driver

user_12940880 0
Viewed 140

I have made Aggregations.lookup from two collections, that returned list of stores, each having field of array of displayed products, with each product having its price. The task is to receive projection, showing for each shop:

  1. Total amount of products
  2. Avg products price
  3. Price of the most expensive and the cheapest product
  4. And amount of products with price less than 10

The problem is I don't understand exactly how to fulfill the fourth task, cause i don't quite understand the syntax of projections.computed. Here's code

AggregateIterable<Document> it = storesCollection.aggregate(Arrays.asList(
                lookup("Products", "products", "name", "products_displayed")
                , project(fields(
                        include("name")
                        , excludeId()
                        , computed("total", computed("$size", "$products_displayed")) //total
                        , computed("avgprice", computed("$avg", "$products_displayed.price")) //avg
                        , computed("maxprice", computed("$max", "$products_displayed.price")) //max
                        , computed("minprice", computed("$min", "$products_displayed.price")) //min
                        , computed("total lt 10", computed("$size", )) // this is the problem: count total amount of products with prices less than 10
                    )
                )
            )
        );
aggregation-framework mongodb projection java
1 Answers

Well, here's how you can do this:

AggregateIterable<Document> it = storesCollection.aggregate(
                Arrays.asList(
                    lookup("Products", "products", "name", "products_displayed")
                    , project(fields(
                            excludeId()
                            , include("name")
                            , computed("total", computed("$size", "$products_displayed"))
                            , computed("avgprice", computed("$avg", "$products_displayed.price"))
                            , computed("maxprice", computed("$max", "$products_displayed.price"))
                            , computed("minprice", computed("$min", "$products_displayed.price"))
                            , computed("total_lt_100", computed("$size",
                                    eq("$filter", and(
                                                    eq("input", "$products_displayed"),
                                                    eq("as", "item"),
                                                    lt("cond", Arrays.asList("$$item.price", 100))
                                            )
                                    )))
                            )
                    )
                )
        );
user_129408800
Related