使用 Java 驱动程序聚合 MongoDB

mongodb java aggregation-framework

2022-09-02 11:19:38

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

我想从收藏的所有项目中获取 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语法。

答案 1

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

蒙戈司机 3 ：

聚合文档

MongoCollection<Document> collection = database.getCollection("myCollection");

AggregateIterable<Document> 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);
}

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

蒙戈司机 2 ：

聚合文档

Iterable<DBObject> 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);
}

查询转换逻辑：感谢此链接

答案 2

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

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

AggregateIterable<Document> 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。