Mongo DB Java 3.x驱动程序 - 按查询分组

Question

我想了解如何使用Mongo DB Java 3.x Driver实现group by查询。我想通过usernames对我的收藏进行分组，并通过结果DESC的count对结果进行排序。

这里是壳查询，我要实现的Java相当于：

db.stream.aggregate({ $group: {_id: '$username', tweetCount: {$sum: 1} } }, { $sort: {tweetCount: -1} }); 

这里是Java代码，我已经实现了：

BasicDBObject groupFields = new BasicDBObject("_id", "username"); 

// count the results and store into countOfResults 
groupFields.put("countOfResults", new BasicDBObject("$sum", 1)); 
BasicDBObject group = new BasicDBObject("$group", groupFields); 


// sort the results by countOfResults DESC 
BasicDBObject sortFields = new BasicDBObject("countOfResults", -1); 
BasicDBObject sort = new BasicDBObject("$sort", sortFields); 

List <BasicDBObject> pipeline = new ArrayList <BasicDBObject>(); 
pipeline.add(group); 
pipeline.add(sort); 

AggregateIterable <Document> output = collection.aggregate(pipeline); 

结果我需要的是计数文件按username分组。 countOfResults返回总数收集的文件。

Answer 1

您应该尽量不要在Mongo 3.x中使用旧对象（BasicDBObject）类型。你可以尝试这样的事情。

import static com.mongodb.client.model.Accumulators.*; 
import static com.mongodb.client.model.Aggregates.*; 
import static java.util.Arrays.asList; 

Bson group = group("$username", sum("tweetCount", 1)); 
Bson sort = sort(new Document("tweetCount", -1)); 
AggregateIterable <Document> output = collection.aggregate(asList(group, sort));