如何在spring data mongo db中使用聚合来使用$month

Question

我使用的是MongoDB，我必须在spring数据mongo DB中使用$date的聚合查询。这是我的用户收藏。

{
    "_id" : NumberLong(70289),
    "_class" : "com.samepinch.domain.user.User",
    "age" : 25,
    "roles" : [
        "ROLE_MODERATOR",
        "ROLE_USER"
    ],
    "firstName" : "Abhi",
    "lastName" : "Saini",
    "email" : "[e-mail]",
    "createdDate" : ISODate("2015-12-04T12:29:57.604Z"),
    "updatedDate" : ISODate("2016-02-10T06:23:13.314Z")
}

 db.users.aggregate([{ $project : { month_joined : { $month : "$createdDate" } } } ,{ $group : { _id : {month_joined:"$month_joined"} , number : { $sum : 1 } } },{ $sort : { "_id.month_joined" : 1 } }])

{ "_id" : { "month_joined" : 1 }, "number" : 19 }
{ "_id" : { "month_joined" : 2 }, "number" : 7 }
{ "_id" : { "month_joined" : 9 }, "number" : 16 }
{ "_id" : { "month_joined" : 10 }, "number" : 12 }
{ "_id" : { "month_joined" : 11 }, "number" : 11 }
{ "_id" : { "month_joined" : 12 }, "number" : 13 }

现在我必须使用MongoTemplate在spring data mongodb中编写这个查询。我是使用聚合的新手。他们是任何简单的方法来使用它。请帮忙

谢谢你。

Answer 1

您可以尝试先在投影操作中使用SpEL和dexpression投影字段，然后在group操作中按新字段分组：

Aggregation agg = newAggregation(
    project("id").andExpression("month(createdDate)").as("month_joined"),
    group("month_joined").count().as("number"),
    project("number").and("month_joined").previousOperation(),
    sort(ASC, "number")
);

AggregationResults<JoinCount> results = mongoTemplate.aggregate(agg, 
                                                     "collectionName", JoinCount.class);
List<JoinCount> joinCount = results.getMappedResults();

在上面，通过newaggrege静态工厂方法创建了一个新的聚合，您将向该方法传递一个聚合操作列表。这些聚合操作定义了聚合的聚合管道。

在第一步中，通过在项目操作中使用SpELandexpression来投影输入集合中的字段。

在第二步中，您使用group操作为每个“month_joined”值定义一个组，您通过count()聚合运算符聚合该值的发生计数，并在一个名为“number”的新字段中收集结果。

第三步，选择字段“number”并为前面的组操作（因此调用PreviousOperation())生成的_id字段创建一个别名，名称为“month_joined”。

作为第四步，通过排序操作按发生次数升序对分组的month_joined文档的结果列表进行排序。

最后，调用MongoTemplate上的aggregate()方法，以便让MongoDB使用创建的聚合作为参数执行实际的聚合操作。

要筛选当前年份的管道中的文档，您需要投影一个新字段，该字段保存日期的年份部分，然后在投影步骤之后发出一个匹配运算符，类似于

Aggregation agg = newAggregation(
    project("id")
        .andExpression("month(createdDate)").as("month_joined")
        .andExpression("year(createdDate)").as("year"),
    match(Criteria.where("year").is(2016)),
    group("month_joined").count().as("number"),
    project("number").and("month_joined").previousOperation(),
    sort(ASC, "number")
);

AggregationResults<JoinCount> results = mongoTemplate.aggregate(agg, 
                                                     "collectionName", JoinCount.class);
List<JoinCount> joinCount = results.getMappedResults();