mongodb的高级操作（聚合框架）

group by 查询 不要用java驱动带的group by ，要用2.2版本后的aggregate聚合框架来搞，经过试验速度快一倍

参考

官网：http://docs.mongodb.org/manual/reference/sql-aggregation-comparison/
实例：http://www.yeetrack.com/?p=649

观看例子前，请先看上面对的2个参考文档，特别是官网的

例子

[java] view plaincopy

1. // 首先利$match筛选出where条件
2. BasicDBObject[] array = {
3. new BasicDBObject("startTimeLong", new BasicDBObject("$gte",beginTime)),
4. new BasicDBObject("startTimeLong", new BasicDBObject("$lt",endTime)) };
5. BasicDBObject cond = new BasicDBObject();
6. cond.put("$and", array);
7. DBObject match = new BasicDBObject("$match", cond);
8. // 利用$project拼装group需要的数据，包含optCode列、processTime列
9. DBObject fields = new BasicDBObject("optCode", 1); // 接口
10. fields.put("processTime", 1);// 耗时
11. fields.put("provinceCode", 1);// 省份
12. fields.put("channelSubCode", 1);// 渠道
13. fields.put("platFormCode", 1);// 平台
14. DBObject project = new BasicDBObject("$project", fields);
15. // 利用$group进行分组
16. DBObject _group = new BasicDBObject("provinceCode", "$provinceCode");
17. _group.put("channelSubCode", "$channelSubCode");
18. _group.put("platFormCode", "$platFormCode");
19. _group.put("optCode", "$optCode");
20. DBObject groupFields = new BasicDBObject("_id", _group);
21. //总数
22. groupFields.put("count", new BasicDBObject("$sum", 1));
23. //求和
24. groupFields.put("processTime_sum", new BasicDBObject("$sum","$processTime"));
25. DBObject group = new BasicDBObject("$group", groupFields);
26. AggregationOutput output = MongodbUtil.getLogInfoCollection().aggregate(match, project, group);