mongodb 聚合java_JAVA mongodb 聚合几种查询方式详解

在 Java 中使用 MongoDB 聚合查询非常简单，可以使用 MongoDB 的官方 Java 驱动程序来实现。以下是几种常见的 MongoDB 聚合查询方式：

1. 使用 Aggregation 类

Aggregation 类是 MongoDB 官方 Java 驱动程序中的一个类，用于构建聚合查询。它提供了多个方法来实现聚合查询，如 match()、group()、sort() 等。下面是一个简单的聚合查询示例：

MongoClient mongoClient = new MongoClient();
MongoDatabase database = mongoClient.getDatabase("mydb");
MongoCollection<Document> collection = database.getCollection("mycoll");

AggregateIterable<Document> iterable = collection.aggregate(
    Arrays.asList(
        Aggregates.match(Filters.eq("status", "A")),
        Aggregates.group("$cust_id", sum("total", "$amount"))
    )
);

for (Document document : iterable) {
    System.out.println(document);
}

2. 使用 Pipeline 类

Pipeline 类是 Aggregation 类的一个子类，它提供了更多的方法来构建聚合查询，如 limit()、skip()、unwind() 等。下面是一个使用 Pipeline 类的聚合查询示例：

MongoClient mongoClient = new MongoClient();
MongoDatabase database = mongoClient.getDatabase("mydb");
MongoCollection<Document> collection = database.getCollection("mycoll");

List<Bson> pipeline = Arrays.asList(
    match(eq("status", "A")),
    group("$cust_id", sum("total", "$amount"))
);

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

for (Document document : iterable) {
    System.out.println(document);
}

3. 使用 Aggregates 静态导入类

如果你使用的是 Java 8 或更高版本，可以使用静态导入 Aggregates 类来简化聚合查询的代码。下面是一个使用静态导入 Aggregates 类的聚合查询示例：

MongoClient mongoClient = new MongoClient();
MongoDatabase database = mongoClient.getDatabase("mydb");
MongoCollection<Document> collection = database.getCollection("mycoll");

List<Bson> pipeline = Arrays.asList(
    match(eq("status", "A")),
    group("$cust_id", sum("total", "$amount"))
);

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

for (Document document : iterable) {
    System.out.println(document);
}

这些都是常见的 MongoDB 聚合查询方式，你可以根据自己的需求选择最适合的方式来实现聚合查询。