如何使用Mongo模板在java中进行聚合

Question

我是MongoDB的新手！

有人能帮助我如何编写java代码来转换下面的mongo聚合查询吗？目前，我正在一个具有“spring-boot-starter-data-mongob”作为依赖项的Spring Boot应用程序中编写它。我正在考虑使用Mongo模板使用下面的查询获取分组文档。

db.getCollection('test').aggregate([  
{
    $group: {
        _id: { name: "$name", zip: "$recipients.0.address.postalcode" },
        groupedDocs: { $addToSet: "$$ROOT" }
    }
}
]);

Answer 1

使用MongoTemboard是正确的想法。您需要首先创建聚合，如下所示：

var aggregation = Aggregation.newAggregation(
    Aggregation.group(Fields.from(
            Fields.field("name"),
            Fields.field("zip", "recipients.0.address.postalcode")
        )
    ).addToSet("$$ROOT")
);

当然，您可以使用静态导入使其更加简洁，我这样写是为了更好地找到类。我不确定$$根引用，您可能需要查找它。有了它，您可以调用MongoTemplate：

return mongoTemplate.aggregate(aggregation, "Test", Test.class);