node.js - 如何在 mongoose/mongodb 中使用不等于运算符？

Question

这是文档的结构。

{
    "_id" : ObjectId("5548f1cc0dcd6bd925a71ae2"), //document id
    "messages" : [
        {
            "subject" : "NEW ++ SUBJECT",
            "from" : ObjectId("5534b2992a104ed914435c31"),
            "_id" : ObjectId("5548f1cc0dcd6bd925a71ae3"),
            "created" : ISODate("2015-05-05T16:37:32.832Z"),
            "read" : false,
            "message" : "FIRST MESSAGE",
            "participants" : [
                ObjectId("5534b2992a104ed914435c31"),
                ObjectId("5530af38576214dd3553331c")
            ]
        },
        {
            "subject" : "dfgsd",
            "from" : ObjectId("5534b2992a104ed914435c98"),//logged In USer
            "_id" : ObjectId("5548f1df0dcd6bd925a71ae4"),
            "created" : ISODate("2015-05-05T16:37:51.455Z"),
            "read" : false,
            "message" : "rdfgdgfd",
            "participants" : [
                ObjectId("5534b2992a104ed914435c98"),//logged In USer
                ObjectId("5530af38576214dd3553331c")
            ]
        }
    "participants" : [
        ObjectId("5534b2992a104ed914435c98"),//logged In USer
        ObjectId("5534b2992a104ed914435c31"),
        ObjectId("5530af38576214dd3553331c")
    ],
    "__v" : 3

}

我想获取消息数组的消息对象，其“读取”值为“假”且“来自”不等于登录用户(此处登录用户为5534b2992a104ed914435c98)。并且文档的“参与者”数组必须包含登录的用户 ID (5534b2992a104ed914435c98)。这是我尝试过的查询。

db.conversations.find({participants:ObjectId('5534b2992a104ed914435c98'),'messag‌​es.read':false,'messages.from':{$ne:ObjectId('5534b2992a104ed914435c98')}}).prett‌​y().

基本上我正在尝试获取未读消息的数量。我对 mongodb/mongoose 很陌生。如果您发现问题中有错误，请纠正我。

Answer 1

如果您尝试根据以下条件获取未读消息的数量:“read”值为“false”且“from”不等于登录用户(此处登录用户为 5534b2992a104ed914435c98)，并且文档的 'participants' 数组必须包含登录用户 ID 5534b2 992a104ed914435c98，然后是aggregation framework 方法应该可以帮助您获得所需的结果。

聚合管道应具有第一个管道阶段 $match满足上述条件的查询。这会过滤出需要在管道流中进一步处理的文档。

对于不使用 $unwind 的解决方案运算符在处理之前首先展​​平消息数组，请考虑 $filter 和 $size 运算符如下:

var pipeline = [
    {
        "$match": {
            "participants": ObjectId("5534b2992a104ed914435c98"),
            "messages.read" : false,
            "messages.from" : { "$ne": ObjectId('5534b2992a104ed914435c98') }
        }
    },    
    {
        "$project": {
            "_id": 0,
            "unread_messages": {
                "$size": {
                    "$filter": {
                        "input": "$messages",
                        "as": "msg",
                        "cond": {
                            "$and": [
                                { "$not": [ "$$msg.read" ] },
                                { "$ne": ["$$msg.from", ObjectId('5534b2992a104ed914435c98')]}
                            ]
                        }
                    }
                }
            }
        }

    }
]

db.conversations.aggregate(pipeline)

如果您使用的驱动程序不支持上述运算符，请考虑在 $match 之后设置下一个管道阶段。作为$unwind该操作用于解构 messages 数组，以便您可以为每个元素输出一个文档。

使用$match进一步过滤需要对解构的消息使用运算符，以仅允许那些满足先前条件的消息在管道中进一步处理。

这一步操作对于下一个管道阶段($group)是必需的。运算符，它按指定的标识符表达式对传入文档进行分组并应用 $sum累加器表达式到每个组，以便您可以获得该组中的文档总数。

最后一个阶段使用 $project运算符通过抑制 _id 字段来 reshape 流中的最终结果文档，并添加一个新字段 unread_messages，该字段描述 read 字段值为 false 的消息总数。

最终的聚合管道如下所示:

var pipeline = [
    {
        "$match": {
            "participants": ObjectId("5534b2992a104ed914435c98"),
            "messages.read" : false,
            "messages.from" : { "$ne": ObjectId('5534b2992a104ed914435c98') }
        }
    },
    {
        "$unwind": "$messages"
    },
    {
        "$match": {
            "participants": ObjectId("5534b2992a104ed914435c98"),
            "messages.read" : false,
            "messages.from" : { "$ne": ObjectId('5534b2992a104ed914435c98') }
        }
    },
    {
        "$group": {
            "_id": null,
            "count": {
                "$sum": 1
            }
        }
    },
    {
        "$project": {
            "_id": 0,
            "unread_messages": "$count"
        }

    }
]

您可以在 Mongoose 聚合中使用它，如下所示:

Conversations.aggregate(pipeline, function (err, res) {
    if (err) return handleError(err);
    console.log(res); // [ { unread_messages: 34 } ] <-- this is a made up value :-)
});)

或者使用聚合管道构建器:

Conversations.aggregate()
    .match({
            "participants": ObjectId("5534b2992a104ed914435c98"),
            "messages.read" : false,
            "messages.from" : { "$ne": ObjectId('5534b2992a104ed914435c98') }
    })
    .unwind("messages")
    .match({
            "participants": ObjectId("5534b2992a104ed914435c98"),
            "messages.read" : false,
            "messages.from" : { "$ne": ObjectId('5534b2992a104ed914435c98') }
    })
    .group({ "_id": null, "unread_messages": { "$sum": 1 } })
    .select("-id unread_messages")
    .exec(function (err, res) {
        if (err) return handleError(err);
        console.log(res); // [ { unread_messages: 34 } ] <-- this is a made up value :-)
});