Mongoose - 循环嵌入文档数组以将新值推送到一个字段？

Question

我有一个包含一组嵌入式文档（“cmets”）的文档，以及一个如下所示的示例：

{
    "_id" : ObjectId("539e9213209e743d107e7202"),
    "article" : "article1",
    "comments" : [
        {
            "comment" : "comment1",
            "created" : ISODate("2014-06-16T06:43:38Z"),
            "_id" : ObjectId("539e921a209e743d107e7203"),
            "read" : {
                "marked" : false
            },
            "timesent" : {
                "datetime" : "Mon Jun 16 2014 02:43:38 GMT-0400 (EDT)",
                "hour" : 2,
                "minute" : "43",
                "second" : 38,
                "am" : true,
                "month" : 5,
                "day" : 16,
                "year" : 2014
            }
        }
    ]
}

对于 cmets 数组中的每条评论，有没有办法批量更新字段 "read" : {"marked" : true}？

我正在使用 node.js，并且有这样的想法（有问题的部分以

开头

如果 (req.body.readComment) {..

// update the article with this id (accessed by PUT at
// http://localhost:4200/api/v1/articles/:article_id)
.put(function(req, res) {

    Article.findById(req.params.article_id, function(err, article) {

        if (err)
            res.send(err);

        if (req.body.comment) {

            article.comments.push({

                comment : req.body.comment,
                timesent :
                {
                    datetime : req.body.datetimeNow,
                    hour : req.body.hourNow,
                    minute : req.body.minuteNow,
                    second : req.body.secondNow,
                    am : req.body.amNow,
                    month : req.body.monthNow,
                    day : req.body.dayNow,
                    year : req.body.yearNow 
                },
                read :
                {
                    marked : req.body.readComment,
                    datetime : req.body.readCommentDatetime
                },
                created : req.body.datetimeNow

            });

        } // if newComment


    if (req.body.readComment) {

      var comments = // some sort of .find ?
      var embeddedDoc;
      for (var i=0, length=comments.length; i < length; i++){
        embeddedDoc = comments[i];
        embeddedDoc_id = // something to find the embedded doc_id ?
        console.log(i);

                article.comments.push({ // maybe push to the embedded doc_id

                    read :
                    {
                        marked : req.body.readComment,
                        datetime : req.body.readCommentDatetime
                    }

                });

      };

    } // if readComment == true (from ajax .put)


        // save the article, and check for errors
        article.save(function(err) {

            if (err)
                res.send(err);

        res.json({ message: 'Update "' + req.params.article_id });

        });

    });

})

Answer 1

由于每个评论都需要在数组中进行标识，因此“批量”一词并不真正适用，因为它们本质上是分开的。至于能够说“更新所有这些'cmets'并将它们标记为true”，不直接支持。

但另一方面，您可以通过批量更新操作来简化此操作。因此，对于“评论”_id 值的“列表”，您可以这样做：

var bulk = collection.initializeOrderedBulkOp();

comments.forEach(function(commentId) {
    bulk.find({ "comments._id": commentId }).updateOne({ 
        "$set": { "comments.$.read.marked": false }
    });

    counter++;
    if ( counter % 500 == 0 ) {
        bulk.execute(function(err,result) {
           // do something with the result
           bulk = collection.initializeOrderedBulkOp();
           counter = 0;
        });
    }
});

// Catch any under or over the 500's
if ( counter > 0 ) 
    bulk.execute(function(err,result) {
       // do something with the result here
    });

这至少可以避免您为每个发送到 API 的“评论”_id“通过网络”向服务器实例发送更新。通过对结果进行批处理，可以减少流量并减少等待回调响应的时间。

您可能会使用“异步”来改进此示例，因此即使循环输入列表也是一种非阻塞操作。批处理大小可能会有所不同，但这只是保持在 16MB BSON 硬限制以下的安全示例，因为整个“请求”等于一个 BSON 文档。