使用Java驱动程序进行MongoDB聚合

我需要你帮助将MongoDB聚合框架与java驱动程序一起使用。 即使有这个文档 ，我也不明白如何编写我的请求。

我想从我的collections中的所有项目中获取200个最早的视图。 这是我的mongo查询（在控制台模式下工作方式如下）：

db.myCollection.aggregate( {$unwind : "$views"}, {$match : {"views.isActive" : true}}, {$sort : {"views.date" : 1}}, {$limit : 200}, {$project : {"_id" : 0, "url" : "$views.url", "date" : "$views.date"}} ) 

此集合中的项目具有一个或多个视图。 我的问题不是请求结果，我想知道java语法。

Answer 1

终于找到了解决方案，我得到的结果与原始请求相同。

Mongo Driver 3：

聚合文档

 MongoCollection collection = database.getCollection("myCollection"); AggregateIterable output = collection.aggregate(Arrays.asList( new Document("$unwind", "$views"), new Document("$match", new Document("views.isActive", true)), new Document("$sort", new Document("views.date", 1)), new Document("$limit", 200), new Document("$project", new Document("_id", 0) .append("url", "$views.url") .append("date", "$views.date")) )); // Print for demo for (Document dbObject : output) { System.out.println(dbObject); } 

您可以使用静态导入使其更具可读性：
import static com.mongodb.client.model.Aggregates.*; 。
请参阅koulini回答complet示例 。

Mongo Driver 2：

聚合文档

 Iterable output = collection.aggregate(Arrays.asList( (DBObject) new BasicDBObject("$unwind", "$views"), (DBObject) new BasicDBObject("$match", new BasicDBObject("views.isActive", true)), (DBObject) new BasicDBObject("$sort", new BasicDBObject("views.date", 1)), (DBObject) new BasicDBObject("$limit", 200), (DBObject) new BasicDBObject("$project", new BasicDBObject("_id", 0) .append("url", "$views.url") .append("date", "$views.date")) )).results(); // Print for demo for (DBObject dbObject : output) { System.out.println(dbObject); } 

---

查询转换逻辑： 感谢这个链接

Answer 2

使用前面的示例作为指南，以下是使用mongo驱动程序3及以上的方法：

 MongoCollection collection = database.getCollection("myCollection"); AggregateIterable output = collection.aggregate(Arrays.asList( new Document("$unwind", "$views"), new Document("$match", new Document("views.isActive", true)) )); for (Document doc : output) { ... } 

Answer 3

值得指出的是，通过使用MongoDB的Java聚合方法，您可以大大改善这里的答案所显示的代码。

让我们以代码为例，OP对自己问题的回答。

 AggregateIterable output = collection.aggregate(Arrays.asList( new Document("$unwind", "$views"), new Document("$match", new Document("views.isActive", true)), new Document("$sort", new Document("views.date", 1)), new Document("$limit", 200), new Document("$project", new Document("_id", 0) .append("url", "$views.url") .append("date", "$views.date")) )); 

我们可以按如下方式重写上面的代码;

 import static com.mongodb.client.model.Aggregates.*; AggregateIterable output = collection.aggregate(Arrays.asList( unwind("$views"), match(new Document("views.isActive",true)), sort(new Document("views.date",1)), limit(200), project(new Document("_id",0) .append("url","$views.url") .append("date","$views.date")) )); 

显然，您将需要相应的静态导入，但除此之外，第二个示例中的代码更清晰 ， 更安全 （因为您不必每次都自己键入运算符），更可读和更美观的 IMO。

Answer 4

这是一种通过departmentId计算员工的简单方法。详细信息： 使用Java API进行聚合

  Map empCountMap = new HashMap<>(); AggregateIterable iterable = getMongoCollection().aggregate(Arrays.asList( new Document("$match", new Document("active", Boolean.TRUE) .append("region", "India")), new Document("$group", new Document("_id", "$" + "deptId").append("count", new Document("$sum", 1))))); iterable.forEach(new Block() { @Override public void apply(final Document document) { empCountMap.put((Long) document.get("_id"), (Integer) document.get("count")); } });