메뉴 건너뛰기

검색창 닫기

Cloudera, BigData, Semantic IoT, Hadoop, NoSQL

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


mongodb like검색한 결과를 기준으로 집계를 수행하는 java 소스

총관리자 2016.12.19 20:15 조회 수 : 2459

$match에서 집계 대상을 선정하고 $group에서 그룹핑하는 컬럼을 지정한다.

최종적으로 결과에 포함시킬 컬럼은 $project에서 지정한다(값이 1이면 최종 결과에 포함되고 0이면 포함하지 않음)


?
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
// MongoDB연결
        try {
            mongoClient = new MongoClient(new ServerAddress(db_server, Integer.parseInt(db_port)));
            db = mongoClient.getDB(db_name);
            table = db.getCollection(collection_name);
        } catch (Exception ex) {
            log.debug("MongoDB connection error : "+ex.getMessage());
            if(db != null) {
                db.cleanCursors(true);
                db = null;             
            }
            if(table != null) {table = null;}
            if(mongoClient != null ) {
                mongoClient.close();
            }
            throw ex;
        }
 
// 리턴 값
List<Map<String, String>> list = new ArrayList<Map<String, String>>();
// 집계 수행(ty=4이고 _uri가 "TicketCount/status/CONTENT_INST"포함하며 ct가 지금부터 5분전에 해당되는 data에 대해서..)
        DBObject match = new BasicDBObject();  //"$match", new BasicDBObject("ct", new BasicDBObject("$gte", "20161213T160000")));
        match.put("ty",4);
        match.put("_uri", new BasicDBObject("$regex", "TicketCount/status/CONTENT_INST"));
        //match.put("ct", new BasicDBObject("$gte", "20161213T160000"));
        long nowDate = new Date().getTime();
        long newDate = nowDate-(5*60*1000);
         
        match.put("ct", new BasicDBObject("$gte", Utils.dateFormat.format((new Date(newDate)))));
 
        //Forming Group parts(cr컬럼을 기준으로 grouping하고 con값을 sum하여 sum_con컬럼으로 담는다)
        DBObject group = new BasicDBObject();
        group.put("_id", "$cr");
        group.put("sum_con", new BasicDBObject("$sum", "$con"));
        //group.put("sum_con", new BasicDBObject("$sum", 1));
 
        //Forming Project parts(최종적으로 _id값을 cr컬럼으로 뽑아내고, _id는 뽑아내지 않으며 sum_con은 결과로서 뽑아낸다)
        DBObject project = new BasicDBObject();
        project.put("cr","$_id");
        project.put("_id",0);
        project.put("sum_con", 1);
 
        try {
            AggregationOutput output = db.getCollection("resource").aggregate(
                        new BasicDBObject("$match", match),
                        new BasicDBObject("$group", group),
                        new BasicDBObject("$project", project)
                        );
 
            //System.out.println("output : "+output.getCommandResult().getString("result"));
            Iterator<DBObject> itr = output.results().iterator();
             
            while(itr.hasNext()) {
                DBObject dbObject =itr.next();
                //JSONObject jsonObject = JSONObject.fromObject(dbObject.toString());
                //Map<String, String> newMap = castMap(dbObject.toMap(), String.class, String.class);
                @SuppressWarnings("unchecked")
                Map<String, String> newMap = makeStringMap(dbObject.toMap());
                list.add(newMap);
            }  
             
            return list;
        } catch (Exception e) {
            log.debug("Exception : "+e.getMessage());
            throw e;
        } finally {
            if(db != null) {
                db.cleanCursors(true);
                table = null;
                db = null;             
            }
            if(mongoClient != null ) {
                mongoClient.close();
            }
        }


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