返回子文档数组与用户定义数组的交集？

Question

我正在尝试使用Mongo聚合框架来找出我文档中的数组和另一个用户定义的数组之间的交集。我没有得到正确的结果，我的猜测是因为我在数组中有数组。

这是我的数据集。

我的文档：

{
    "_id" : 1,
    "pendingEntries" : [ 
        {
            "entryID" : ObjectId("5701b4c3c6b126083332e65f"),
            "tags" : [ 
                {
                    "tagKey" : "owner",
                    "tagValue" : "john"
                }, 
                {
                    "tagKey" : "ErrorCode",
                    "tagValue" : "7001"
                }, 
                {
                    "tagKey" : "ErrorDescription",
                    "tagValue" : "error123"
                }
            ],
            "entryTime" : ISODate("2016-04-04T00:26:43.167Z")
        }
    ]
},

/* 1 */
{
    "_id" : 2,
    "pendingEntries" : [ 
        {
            "entryID" : ObjectId("5701b4c3c6b126083332e65d"),
            "tags" : [ 
                {
                    "tagKey" : "owner",
                    "tagValue" : "peter"
                }, 
                {
                    "tagKey" : "ErrorCode",
                    "tagValue" : "6001"
                }, 
                {
                    "tagKey" : "JIRA",
                    "tagValue" : "Oabc-123"
                }
            ],
            "entryTime" : ISODate("2016-04-04T00:26:43.167Z")
        }
    ]
},

/* 2 */
{
    "_id" : 3,
    "pendingEntries" : [ 
        {
            "entryID" : ObjectId("5701b4c3c6b126083332e65c"),
            "tags" : [ 
                {
                    "tagKey" : "owner",
                    "tagValue" : "abc"
                }, 
                {
                    "tagKey" : "ErrorCode",
                    "tagValue" : "6001"
                }, 
                {
                    "tagKey" : "JIRA",
                    "tagValue" : "abc-123"
                }
            ],
            "entryTime" : ISODate("2016-04-04T00:26:43.167Z")
        }
    ]
}

我的查询：

db.entrylike.aggregate(
   [
     { $project: { "pendingEntries.entryID": 1, "common": { $setIntersection: [ "$pendingEntries.tags", [{ "tagKey" : "ErrorCode", "tagValue" : "7001" }] ] } } }
   ]
)

结果：

{
    "result" : [ 
        {
            "_id" : 1,
            "pendingEntries" : [ 
                {
                    "entryID" : ObjectId("5701b4c3c6b126083332e65f")
                }
            ],
            "common" : []
        }, 
        {
            "_id" : 2,
            "pendingEntries" : [ 
                {
                    "entryID" : ObjectId("5701b4c3c6b126083332e65d")
                }
            ],
            "common" : []
        }, 
        {
            "_id" : 3,
            "pendingEntries" : [ 
                {
                    "entryID" : ObjectId("5701b4c3c6b126083332e65c")
                }
            ],
            "common" : []
        }
    ],
    "ok" : 1
}

我不希望第一个公共字段为空。有人能告诉我我做错了什么吗？或者我能采取的任何变通办法。

我正在使用MongoDB 3.0.8。我知道Mongob 3.2可以提供一些功能来满足我的需求，但3.2升级不会很快在我们的管道中，如果可能的话，我希望使用Mongo3.0解决这个问题。

Answer 1

公共字段为空的原因是“pendingEntries”数组和用户定义的数组没有公共元素。您真正想要的是返回一个数组，该数组包含出现在“标记”数组和用户定义数组中的元素。要做到这一点，只需使用$map操作符，并将$setIntersection操作符应用于“Pendingeries”数组中的每个子文档“tags”。

db.entrylike.aggregate([
    { "$project": { 
        "common": { 
            "$map": { 
                "input": "$pendingEntries", 
                "as": "p",
                "in": { 
                    "entryID": "$$p.entryID",
                    "tags": { 
                        "$setIntersection": [ 
                            "$$p.tags", 
                            { "$literal": [
                                { 
                                    "tagKey" : "ErrorCode", 
                                    "tagValue" : "7001" 
                                }
                            ]}
                        ]
                    }
                }
            }
        }
    }}
])

返回：

{
    "_id" : 1,
    "common" : [
        {
            "entryID" : ObjectId("5701b4c3c6b126083332e65f"),
            "tags" : [
                {
                    "tagKey" : "ErrorCode",
                    "tagValue" : "7001"
                }
            ]
        }
    ]
}
{
    "_id" : 2,
    "common" : [
        {
            "entryID" : ObjectId("5701b4c3c6b126083332e65d"),
            "tags" : [ ]
        }
    ]
}
{
    "_id" : 3,
    "common" : [
        {
            "entryID" : ObjectId("5701b4c3c6b126083332e65c"),
            "tags" : [ ]
        }
    ]
}