[MongoDB] Aggregate 예제1

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(

              new Document("$match", new Document("price", new Document("$gte", 50000))),

              new Document("$group", new Document("_id", "$prdt_nm")

                       .append("trd_sum", new Document("$sum", "$price"))

     )

);

for(Document doc:res_doc) {

       System.out.println(doc)

}

* test db에 있는 tn_trade 콜렉션에서 price >= 50000 이상인 document들을 prdt_nm 기준으로

   price의 합계를 구하는 예제임.