mongo组多次

问题描述 投票:0回答:2

我们假设我有这组数据:

{ ValidFrom: "2019-03-25T16:01:55.714+0000", ValidTo: "2019-03-25T16:01:55.714+0000" },    
{ ValidFrom: "2019-03-26T16:01:55.714+0000", ValidTo: "2019-03-25T16:01:55.714+0000" },    
{ ValidFrom: "2019-03-25T16:01:55.714+0000", ValidTo: "2019-03-27T16:01:55.714+0000" }

我想通过一个查询看到这个结果:

{ "Day": "2019-03-25", ValidFromCount: 2, ValidToCount: 2 },    
{ "Day": "2019-03-26", ValidFromCount: 1, ValidToCount: 0 },    
{ "Day": "2019-03-27", ValidFromCount: 0, ValidToCount: 1 }

目前我写了这个聚合但我现在卡住了:

 {
     $addFields: {
            ValidFromDay: { $dateToString: { format: "%Y-%m-%d", date: "$ValidFrom" } },
            ValidUntilDay: { $dateToString: { format: "%Y-%m-%d", date: "$ValidUntil" } }
     }
 },
 {
     $group : {
        _id: { FromDate: '$ValidFromDay', ToDate: '$ValidUntilDay' },
        Count: { "$sum": 1 },
     }
 }, 
 {
     $group : {
        _id: null,
        FromDates: { "$addToSet": { "Date": "$_id.FromDate", "FromCount": { "$sum": "$Count" } } },
        ToDate: { "$addToSet": { "Date": "$_id.ToDate", "UntilCount": "$Count" } }
     }
 }

是否有可能以某种方式产生我正在寻找的结果?

mongodb aggregation-framework
2个回答
2
投票

您需要添加一个包含2个字段的数组,而不仅仅是2个字段。它会让你放松它并按日期计算:

{
     $addFields: {
            boundary: [
                { day: {$dateToString: { format: "%Y-%m-%d", date: "$ValidFrom" } }, from: 1 },
                { day: { $dateToString: { format: "%Y-%m-%d", date: "$ValidTo" } } , to: 1 }
                ]
     }
},
{
    $unwind: "$boundary"
},
{
    $group: {
        _id: "$boundary.day",
        ValidFromCount: {$sum: "$boundary.from"},
        ValidToCount: {$sum: "$boundary.to"},
    }
}

0
投票

我想这会做你想要的。管道有三个阶段。 A$project构建一个单独的日,月和年字段。

> projector
{
    "$project" : {
        "day" : {
            "$dayOfMonth" : "$ValidFrom"
        },
        "month" : {
            "$month" : "$ValidFrom"
        },
        "year" : {
            "$year" : "$ValidFrom"
        },
        "ValidFrom" : 1
    }
}

然后一个$group创建总数,并通过使用_id {year, month, day}个人日计数。

> grouper
{
    "$group" : {
        "_id" : {
            "year" : "$year",
            "month" : "$month",
            "day" : "$day"
        },
        "ValidFromCount" : {
            "$sum" : 1
        },
        "ValidToCount" : {
            "$sum" : 1
        }
    }
}

最后,投影消除虚假场并将Day字段转换为您想要的格式。

> converter
{
    "$project" : {
        "_id" : 0,
        "Day" : {
            "$concat" : [
                {
                    "$toString" : "$_id.year"
                },
                "-",
                {
                    "$toString" : "$_id.month"
                },
                "-",
                {
                    "$toString" : "$_id.day"
                }
            ]
        },
        "ValidFromCount" : 1,
        "ValidToCount" : 1
    }
}

运行只是执行(我在集合so2中创建了你的数据):

> db.so2.find()
{ "_id" : ObjectId("5ca75adfd1a64a2919883a8d"), "ValidFrom" : "2019-03-25T16:01:55.714+0000", "ValidTo" : "2019-03-25T16:01:55.714+0000" }
{ "_id" : ObjectId("5ca75adfd1a64a2919883a8e"), "ValidFrom" : "2019-03-26T16:01:55.714+0000", "ValidTo" : "2019-03-25T16:01:55.714+0000" }
{ "_id" : ObjectId("5ca75adfd1a64a2919883a8f"), "ValidFrom" : "2019-03-25T16:01:55.714+0000", "ValidTo" : "2019-03-27T16:01:55.714+0000" }
>
> db.so3.aggregate([projector,grouper,converter])
{ "ValidFromCount" : 1, "ValidToCount" : 1, "Day" : "2019-3-26" }
{ "ValidFromCount" : 2, "ValidToCount" : 2, "Day" : "2019-3-25" }
>

我不确定你提供的测试数据是否正确,因为第二个文件似乎可以追溯到时间,所以ValidToValidFrom之前。

© www.soinside.com 2019 - 2024. All rights reserved.