[MongoDB] Aggregate 예제2

Aggregate 예제1보다 몽고쉘에서 수행하는 형태로 작성해 보기....

new Document 방식 보다는 아래 방식이 더 비슷해 보입니다.

MongoClient mongo = ~~~ 생략...

MongoDatabase db = mongo.getDatabase("test");  // test db

MongoCollection<Document> coll_trd = db.getCollection("tn_trade");

AggregateIterable<Document>  res_doc = coll_trd.aggregate (

       

      Arrays.asList(

                    Aggregates.match(

                                            Filters.gte("price", 50000)

                    ),

                   Aggregates.group("$prdt_nm", sum("tot_sum", "$price")

                   )

      )

);

for(Document doc:res_doc) {

       System.out.printf("prdt_nm=%s, tot_sum=%d \n", doc.getString("_id"), doc.getInteger("tot_sum"));

}