使用 Spring Mongodb 聚合 API 转换查询答案

【问题标题】：Convert query using Spring Mongodb Aggregation apis使用 Spring Mongodb 聚合 API 转换查询
【发布时间】：2017-05-11 17:58:34
【问题描述】：

db.flm_conversation.aggregate(
[
    {$match: {"conversationRecords.isPrimary":true,"conversationRecords.commentTime":{'$gte': new Date('2016-12-18 00:00:00'), '$lte': new Date('2016-12-18 23:59:59')} } },
    {$unwind:"$conversationRecords"},
    { $group: {
        _id: {
            "commentLevel": "$commentLevel",
            "time":{"$add": [
                { 
                    "$subtract": [
                        { "$subtract": [
                            "$conversationRecords.commentTime",
                            new Date(0) 
                        ]}
                        ,
                        { "$mod": [
                            { "$subtract": [
                               "$conversationRecords.commentTime", 
                                new Date(0)
                            ]},
                            1000 * 60 * 30
                        ]}
                    ]
                },
                new Date(0)
            ]}
        },
        count: { "$sum": 1 }
    }},
    { $group: {_id: "$_id.commentLevel",count: { "$sum": 1 },pointrecord:{$push: {time:"$_id.time",count:"$count"} } }},
    { $project: { _id: 1,count:1,pointrecord:1 } }
])

如何使用 Spring Mongodb Aggregation api 转换此查询？

AggregationOperation match = Aggregation.match(Criteria.where("conversationRecords.isPrimary").is(true)
        .and("conversationRecords.commentTime").gte(DateUtils.stringToDate("2016-12-18 00:00:00","yyyy-MM-dd HH:mm:ss")).lte(DateUtils.stringToDate("2016-12-18 23:59:59","yyyy-MM-dd HH:mm:ss")));
AggregationOperation unwind = Aggregation.unwind("conversationRecords");
AggregationOperation group = Aggregation.group("commentLevel");
Aggregation agg = newAggregation(match,unwind,group);
AggregationResults<SummaryRecordAggre>  groupResults
        = mongoTemplate.aggregate(agg, COLLECTION_NAME, SummaryRecordAggre.class);

我不知道组“$add”如何转换？我找到了 http://docs.spring.io/spring-data/mongodb/docs/current/reference/html/#mongo.aggregation

【问题讨论】：

您能补充一下到目前为止您尝试过的内容吗？从那里有人帮助你更容易。
我改变了我的描述。

标签： spring mongodb mongodb-query aggregation-framework

【解决方案1】：

你可以试试这样的。我删除了我认为不需要的额外运算符，但如果您需要，我们可以轻松地将它们放回去。

第一组是您需要使用 MongoDB 对象构建的东西，因为目前 Spring mongo 不支持所有聚合运算符。

第二组推送操作符的类似方式，因为您不能推送多个值。

AggregationOperation match = Aggregation.match(Criteria.where("conversationRecords.isPrimary").is(true)
        .and("conversationRecords.commentTime").gte(DateUtils.stringToDate("2016-12-18 00:00:00", "yyyy-MM-dd HH:mm:ss")).lte(DateUtils.stringToDate("2016-12-18 23:59:59", "yyyy-MM-dd HH:mm:ss")));
AggregationOperation unwind = Aggregation.unwind("conversationRecords");
AggregationOperation firstGroup = context -> context.getMappedObject(new BasicDBObject(
        "$group", new BasicDBObject(
        "_id", new BasicDBObject("commentLevel", "$commentLevel")
        .append(
                "time", new BasicDBObject(
                        "$subtract", new Object[]{"$conversationRecords.commentTime", new BasicDBObject(
                        "$mod", new Object[]{"$conversationRecords.commentTime", 1000 * 60 * 30})}))).append("count", new BasicDBObject("$sum", 1))));
AggregationOperation secondGroup = Aggregation.group("_id.commentLevel").count().as("count").push(new BasicDBObject("time", "$_id.time").append("count", "$count")).as("pointrecord");
AggregationOperation project = Aggregation.project("_id", "count", "pointrecord");
Aggregation agg = newAggregation(match, unwind, firstGroup, secondGroup, project);

这相当于下面的查询

[{
    "$match": {
        "conversationRecords.isPrimary": true,
        "conversationRecords.commentTime": {
            "$gte": {
                "$date": "2016-12-27T14:46:50.896Z"
            },
            "$lte": {
                "$date": "2016-12-27T14:46:50.896Z"
            }
        }
    }
}, {
    "$unwind": "$conversationRecords"
}, {
    "$group": {
        "_id": {
            "commentLevel": "$commentLevel",
            "time": {
                "$subtract": ["$conversationRecords.commentTime", {
                    "$mod": ["$conversationRecords.commentTime", 1800000]
                }]
            }
        },
        "count": {
            "$sum": 1
        }
    }
}, {
    "$group": {
        "_id": "$_id.commentLevel",
        "count": {
            "$sum": 1
        },
        "pointrecord": {
            "$push": {
                "time": "$_id.time",
                "count": "$count"
            }
        }
    }
}, {
    "$project": {
        "_id": 1,
        "count": 1,
        "pointrecord": 1
    }
}]
}

【讨论】：