java操作mongodb（聚合函数）-分组找出每组的最大值

转自：

http://blog.csdn.net/maosijunzi/article/details/42105927

数据库数据如下：

 

上代码：

[java] view plaincopyprint?

1. public static void main(String[] args) {  
2.          UserDao userDao = new UserDao();  
3.          userDao.juhe();  
4.     }  
5.   
6.     public void juhe() {  
7.         DB myMongo = MongoManager.getDB("myMongo");  
8.         DBCollection userCollection = myMongo.getCollection("user");  
9.   
10.         // 使用 count 统计数量  
11.         System.out.println(userCollection.count());  
12.   
13.         // 使用distinct 统计所有的address  
14.         List distinct = userCollection.distinct("address");  
15.         System.out.println(distinct);  
16.   
17.         //使用group 查询每年（year）中age最大的人  
18.         BasicDBObject key = new BasicDBObject("year",true);     
19.         BasicDBObject cond = new BasicDBObject("id",new BasicDBObject(QueryOperators.GT,0));     
20.         BasicDBObject initial = new BasicDBObject("age",0);     
21.         String reduce = "function (doc,prev){"  
22.                             +"if(doc.age>prev.age){"  
23.                                 +"prev.age=doc.age;"  
24.                                 +"prev.name=doc.name"  
25.                             +"}"  
26.                         +"}";  
27.         BasicDBList group =  (BasicDBList) userCollection.group(key,cond,initial,reduce);      
28.         System.out.println(group);   
29.   
30.     }  

 

输出结果如下：

[plain] view plaincopyprint?

1. 11  
2. [ "1" , "2" , "5" , "6" , "7" , "8" , "9" , "11" , "12"]  
3. [ { "year" : 2014.0 , "age" : 17.0 , "name" : "2"} , { "year" : 2013.0 , "age" : 17.0 , "name" : "2"}]