首页 > 代码库 > MongoDB的分组统计 group

MongoDB的分组统计 group

mongodb中的分组聚合用$group,它是不能进行sort的,使用格式如下:

{ $group: { _id: <expression>, <field1>: { <accumulator1> : <expression1> }, ... } }

其中_id属性是必须要有的,目的是用来指定分组的字段或依据,field1为自定义字段,accumulator为累加器,下面以统计每天用户注册数为列

db.user.aggregate([    {        $group:{            _id:{                year:{$year:"$time"},//time为注册时间 $year表示获取年份                month:{$month:"$time"},//$month获取月份                day:{$dayOfMonth:"$time"}//$dayOfMonth获取多少号            }            count:{$sum:1}//$sum为累计,1表示累加数        }    }])

如果只想注册地区为四川的则在$goup前增加一个$match:

{    $match:{         location:"SiChuan"    }},

以上两个聚合操作的java实现方式:

DBObject filterCond = new BasicDBObject();filterCond.put("location", "SiChuan");DBObject match = new BasicDBObject("$match", filterCond);DBObject group = new BasicDBObject();DBObject groupDate = new BasicDBObject();groupDate.put("year", new BasicDBObject("$year", "$time"));groupDate.put("month", new BasicDBObject("$month", "$time"));groupDate.put("day", new BasicDBObject("$dayOfMonth", "$time"));group.put("$group", new BasicDBObject("_id", groupDate));
AggregationOutput output = coll.aggregate(match, group); Iterator iterator = output.results().iterator();

 

第一次写博客,才发现语言组织能力真差,累死了,下班~~~

更多的聚合操作请参见这》》》http://docs.mongodb.org/manual/reference/operator/aggregation-pipeline/

 

MongoDB的分组统计 group