mongodb 按照时间聚类 java

project可以对值进行更名操作以及concat, substr, add, mutiply, mod 操作

$group 最重要的，聚类操作。

group必须有_id属性，用来标识那些被聚集的属性。但是_id的值可以为null，用于求和求平均。

在group的时候可以同时对属性名称进行修改

$group: {

  $_id : {month: {$month: "$date"}, day: {$day: "$date"}},

  $totalPrice: {$sum: {$multiply: ["$price", "$quantity"]}},

  $averagePrice: {$avg: ["$price"]},

  count: {$sum, 1} 

} 

_id, totalPrice, averagePrice, count 都会分别作为一个属性返回。

另外的属性还包括

$sort, 按照某个属性排序

 {$sort: {age: 1, money: -1}}

 $skip, $limit 表示越过多少或者仅返回多少条目。

$unwind 将数组的元素拆开。

$out 表示为输出的结果新建一个collection

{$out: "authors"} ，它必须作为最后pipeline的最后一个stage

 一个聚类的例子，完全使用java实现

DBObject fields  = new BasicDBObject("url", "$uri")
DBObject project = new BasicDBObject("$project", fields)

DBObject idField   = new BasicDBObject("_id", new BasicDBObject("url", "$url"));
idField.put("count", new BasicDBObject("$sum", 1));
DBObject group     = new BasicDBObject("$group", idField);

DBObject sort      = new BasicDBObject("$sort", new BasicDBObject("count", -1));
List<DBObject> pipeline = Arrays.asList(project, group, sort);
AggregationOutput output = collection.aggregate(pipeline);

for(DBObject result: output.results())
  System.out.println(result)

上面的代码中DBObject的组装相当麻烦且看不出json的架构，因为一个更好的做法是从json转化

DBObject project = JSON.parse("{$project: {"url": \"$uri\"}}")

DBObject group   = JSON.parse("{$group: {_id: {"url": "$url"}}}")

DBObject sort    = JSON.parse("{$sort: {count: -1}}")