Mongodb 中的聚合更新

Question

我正在尝试在一个对象（它是一个子文档）内切换布尔值，我很难更新数组中的特定对象。

文档：

"_id" : ObjectId("54afaabd88694dc019d3b628")
"Invitation" : [ 
    {
        "__v" : 0,
        "ID" : ObjectId("54af6ce091324fd00f97a15f"),
        "__t" : "USER",
        "_id" : ObjectId("54b4ceb50fc380001bea1752"),
        "Accepted" : false
    }, 
    {
        "__v" : 0,
        "ID" : ObjectId("54afac5412f5fdcc007a5c4d"),
        "__t" : "USER",
        "_id" : ObjectId("54b4cebe0fc380001bea1753"),
        "Accepted" : false
    }
],

控制器：

User.aggregate([{$match: {_id: ObjectId(54afaabd88694dc019d3b628)}},{$unwind: '$Invitation'},{$project: {_id: '$_id',Invitation: '$Invitation'}}],function(err,results){

    function updateInvitation(_id){

                var query = {'_id': _id, 'Invitation.ID': ObjectId("54af6ce091324fd00f97a15f")};
                var operator = {$inc: {'Invitation.Accepted': 1}}; 
                User.update(query,operator,{multi:true},function(err,updated){
                    if(err){
                        console.log(err);
                    }
                    console.log('updating'+updated);
                });
            }
            res.jsonp(results);
            updateInvitation(results[0]._id);
});

我尝试使用 $set 但没有成功，因为整个 Invitation 数组被替换为 'Accepted = 1' 如何使用特定的“ID”切换文档的“Accepted”字段。

Invitation.$.Accepted

位置运算符不适用于包含数组的字段，因此无法迭代到 Accepted 字段

编辑：

User.find({_id: req.user._id},'Invitation',function(err,docs){
    if(err){
        console.log(err);
    }
    console.log(docs);
    var results = [];
    async.each(docs,function(doc,err) {
        if(err){
            console.log('error'+ err);
        }
        async.each(docs.Invitation,function(invite,callback) {
console.log('second async');
            User.update(
                { '_id': doc._id, 'Invitation._id': invite._id },
                { '$set': {'Invitation.$.Accepted': !invite.Accepted}},
                function(err,doc) {
                    results.push(doc);
                    console.log('updated'+doc);
                    callback(err);
                }
            );
        });
    },function(err) {
        if (err)
            console.log(err);
        console.log(results);
    });

});

控件没有进入第二个 async.each，在第一个 async 上抛出错误，这是错误：

error-function () {
        if (called) throw new Error("Callback was already called.");
        called = true;
        fn.apply(root, arguments);
    }

Answer 1

我真的不认为即使作为馈线查询，聚合框架也不是在这里使用的正确操作。您所做的就是将数组“非规范化”为单个文档。真的应该没有必要。只需获取文档即可：

var query = {}; // whatever criteria

Users.find(query,"Invitation",function(err,docs) {
    if (err) {
        console.log(err);

    var results = [];        

    async.each(docs,function(doc,callback) {
        async.each(docs.Invitation,function(invite,callback) {
            Users.findOneAndUpdate(
                { "_id": doc._id, "Invitation._id": invite._id },
                { "$set": { "Invitation.$.Accepted": !invite.Accepted } },
                function(err,doc) {
                   results.push( doc );
                   callback(err);
                }
            );
        },callback);
    },function(err) {
        if (err)
            console.log(err);

        console.log(results);
    });    

});

因此，在响应您正在做的事情时迭代文档列表没有问题，只是您还想迭代数组成员。问题是，当您发出任何需要注意的.update() 时，异步调用就完成了。

所以我使用async.each，但您可能希望async.eachLimit 控制循环。元素的匹配来自positional $运算符，对应查询中匹配的数组元素。

这只是 JavaScript 代码，所以只需用!invite.accepted“切换”该值，这将反转它。为了获得更多乐趣，请通过从 .findOneAndUpdate() 推送修改后的文档来返回“结果”数组。

Answer 2

为此使用位置更新运算符： http://docs.mongodb.org/manual/reference/operator/update/positional/

User.update(
    {
        "_id": ObjectId("54afaabd88694dc019d3b628"),
        "Invitation": {"$elemMatch": {"ID" : ObjectId("54af6ce091324fd00f97a15f"), "Accepted":false}}
    },
    {
        "$set" : {
            "Invitation.$.Accepted" : true
        }
    },{multi:false, upsert:false, safe:true}, function (err, numAffectedDocuments){
      // TODO
    }
);

注意：您不需要聚合步骤，因为它实际上什么都不做。