메뉴 건너뛰기

검색창 닫기

Cloudera, BigData, Semantic IoT, Hadoop, NoSQL

Cloudera CDH/CDP 및 Hadoop EcoSystem, Semantic IoT등의 개발/운영 기술을 정리합니다. gooper@gooper.com로 문의 주세요.


mongodb mongodb aggregation query를 Java code로 변환한 샘플

총관리자 2016.12.15 18:30 조회 수 : 2732

* MongoDB shell 구문을 Java Code로 표현하면 아래와 같다.

?
1
2
3
4
5
db.employee.aggregate({$unwind: '$dp.fin.Record'},      
{$match:{"dp.mon":"patch.metrics",'dp.fin.Record':{$exists:1}}},     
{$group:{_id: '$dp.fin.Record', count:{$sum:1}}},     
{$project:{count:'$count'}},   {$group:{_id:'Total
Count',total:{$sum:'$count'}}});


-->

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
DBCollection table=null;
MongoClient mongoClient=null;
DB db = null;
 
mongoClient = new MongoClient(new ServerAddress(db_server, Integer.parseInt(db_port)));
db = mongoClient.getDB(db_name);
table = db.getCollection(collection_name);
 
 
//Forming Unwind parts
DBObject unwind = new BasicDBObject("$unwind","$dp.fin.record");
 
//Forming Match parts
DBObject match = new BasicDBObject();
match.put("dp.mon","patch.metrics");
match.put("dp.fin.Record", new BasicDBObject("$exists",1));
 
//Forming Group parts
DBObject group1 = new BasicDBObject();
group1.put("_id", "$dp.fin.Record");
group1.put("count", new BasicDBObject("$sum", 1));
 
//Forming Project parts
DBObject project = new BasicDBObject();
project.put("count", "$count");
 
//Forming Group parts
DBObject group2 = new BasicDBObject();
group2.put("_id", "Total Count");
group2.put("total", new BasicDBObject("$sum", "$count"));
 
 
/**
 * Executing aggregation
 */
AggregationOutput output = table.getCollection("employee").aggregate(unwind,                                                                                           
          new BasicDBObject("$match",match),                                                                                       
          new BasicDBObject("$group",group1),                                                                                          
          new BasicDBObject("$project",project),                                                                                           
          new BasicDBObject("$group",group2));
 
// 결과확인    
System.out.println("output : "+output);;


이 게시물을
이 글의 추천인 목록 목록
쓰기 태그
위로