java 操作mongodb 聚合查询

在 Java 中操作 MongoDB 进行聚合查询可以使用 MongoDB 的 Java 驱动程序。下面是一个简单的示例代码，它演示了如何使用 Java 驱动程序执行 MongoDB 聚合查询：

import com.mongodb.MongoClient;
import com.mongodb.client.AggregateIterable;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;

import java.util.Arrays;

public class MongoDBAggregationExample {
    public static void main(String[] args) {
        // 创建 MongoDB 客户端
        MongoClient mongoClient = new MongoClient("localhost", 27017);

        // 获取数据库
        MongoDatabase database = mongoClient.getDatabase("test");

        // 执行聚合查询
        AggregateIterable<Document> result = database.getCollection("sales").aggregate(Arrays.asList(
                new Document("$group", new Document("_id", "$product").append("total", new Document("$sum", "$quantity"))),
                new Document("$sort", new Document("total", -1))
        ));

        // 打印结果
        for (Document doc : result) {
            System.out.println(doc.toJson());
        }

        // 关闭客户端
        mongoClient.close();
    }
}

在这个示例中，我们创建了一个 `MongoClient` 对象来连接 MongoDB 数据库。然后，我们获取了 `test` 数据库，并对 `sales` 集合执行了一个聚合查询。这个聚合查询使用了 `$group` 和 `$sum` 操作符来计算每个产品的总销量，并使用 `$sort` 操作符按降序排列结果。最后，我们遍历了查询结果并打印了每个文档的 JSON 表示。

需要注意的是，聚合查询返回的结果是一个 `AggregateIterable<Document>` 对象，可以通过迭代器来遍历结果集合。在遍历结果时，可以使用 `toJson()` 方法将每个文档转换为 JSON 格式的字符串，或者使用 `get()` 方法获取文档中的字段值。