Comment puis-je utiliser un cursor.forEach() dans MongoDB en utilisant Node.js ?

La réponse dépend du pilote que vous utilisez. Tous les pilotes MongoDB que je connais ont cursor.forEach() mis en œuvre d'une manière ou d'une autre.

Voici quelques exemples :

nœud-mongodb-natif

collection.find(query).forEach(function(doc) {
  // handle
}, function(err) {
  // done or error
});

mongojs

db.collection.find(query).forEach(function(err, doc) {
  // handle
});

moine

collection.find(query, { stream: true })
  .each(function(doc){
    // handle doc
  })
  .error(function(err){
    // handle error
  })
  .success(function(){
    // final callback
  });

mangouste

collection.find(query).stream()
  .on('data', function(doc){
    // handle doc
  })
  .on('error', function(err){
    // handle error
  })
  .on('end', function(){
    // final callback
  });

Mise à jour des documents dans .forEach rappel

Le seul problème avec la mise à jour des documents à l'intérieur de .forEach rappel est que vous ne savez pas quand tous les documents sont mis à jour.

Pour résoudre ce problème, vous devez utiliser une solution de flux de contrôle asynchrone. Voici quelques options :

• asynchrone
• promesses (when.js, bluebird)

Voici un exemple d'utilisation de async , en utilisant sa queue fonctionnalité :

var q = async.queue(function (doc, callback) {
  // code for your update
  collection.update({
    _id: doc._id
  }, {
    $set: {hi: 'there'}
  }, {
    w: 1
  }, callback);
}, Infinity);

var cursor = collection.find(query);
cursor.each(function(err, doc) {
  if (err) throw err;
  if (doc) q.push(doc); // dispatching doc to async.queue
});

q.drain = function() {
  if (cursor.isClosed()) {
    console.log('all items have been processed');
    db.close();
  }
}