mise à jour plusieurs documents avec MongoDB

Question

Comment itérer un tableau d'objets à mettre à jour des documents avec MongoDB et conserver les documents modifiés pour revenir dans la réponse

Notez les commentaires dans le code

.put(function (req, res) { 

    var data = req.body.data; 
    var documents = []; 
    for (var item in data) { 

     var id = data[item]._id; 
     var document = data[item]; 

     Item.update({ _id: id }, document, { overwrite: true }, function (err, item) { 
      if (err) { 
      res.send({'error':'Error'}); 
      } 
      Item.findById(id, function (err, document) { 
      if (err) { 
       res.send({}); 
      } 
      documents.push(document); // documents are pushed 
      }); 

     });   
    } 
    documents ; // value is [] 
    res.json({ 
     items: documents 
    });   
}) 

Answer 1

Utilisez Promise.all() et .findByIdAndUpdate() à la place. Tant que votre soutient les contructs enviroment de ES6, ou vous importez quelque chose qui fournit le Promise.all():

Promise.all(
    req.body.data.map(function(doc) { 
     var id = doc._id; 
     delete doc._id; 
     return Item.findByIdAndUpdate(id,doc,{ "new": true }); 
    }) 
).then(function(documents) { 
    res.json({ "items": documents }) 
}); 

Pas besoin de bibliothèques externes.

Answer 2

Puisque update est asynchrone, votre documents est vide et revient immédiatement. Créez des promesses pour chacune des mises à jour. Créez également un tableau de promesses externe. Poussez ces promesses à ce tableau, et envoyez la réponse lorsque tout est fait. J'utilise le Q library

.put(function (req, res) { 

    var data = req.body.data; 
    var documents = []; 
    var promises = [] 
    for (var item in data) { 

     var id = data[item]._id; 
     var document = data[item]; 
     var itemDefer = Q.defer(); 

     Item.update({ _id: id }, document, { overwrite: true }, function (err, item) { 
      if (err) { 
      res.send({'error':'Error'}); 
      } 
      Item.findById(id, function (err, document) { 
      if (err) { 
       itemDefer.reject(err); 
      } 
      itemDefer.resolve(document); 
      }); 
     }); 
     promises.push(itemDefer.promise);  
    } 
    Q.all(promises).then(function(documents) { 
     res.json({items: documents});  
    }, then(function(err) { 
     res.send({}) 
    })) 

})