재

Question

내가 노드/익스프레스/MongoDB를/Mongoskin와 응용 프로그램을 짓고 있어요

나는 문서의 모음 갱신이 코드가 있습니다

db.collection('invoices').find().toArray(function(err, dbDocs) { 
    if (err) throw err; 

    // Change one, none or several fields named 'paid' in the fetched invoices array 
    ... 

    // Loop trough the changed dbDocs and use it to update the database. 
    for (var i = 0, j = dbDocs.length; i < j; i += 1) { 
    db.collection('invoices').update({_id:dbDocs[i]._id}, {$set:{ paid: dbDocs[i].paid }}, function(err, result) { 
     if (err) throw err; 

     // Trigger a redirect after the last iteration. 
     if (!err && (i === dbDocs.length - 1)) { 
     console.log('"i" is right now: ', i); 
     res.redirect('/superadmin/fakturor'); 
     } 
    }); 
    } 
}); 

을 update() 함수가 콜백을 가지고 있고 콜백이 마침내 발생하면 for-loop가 이미 끝났기 때문에 리디렉션이 네 번 호출됩니다. 리디렉션이 한 번 호출되도록 지정합니다. 즉, 마지막 반복 이후이며 오류가 없습니다.

어떻게 작동하도록이 코드를 다시 작성합니까?

Answer 1

먼저 마음 i = dbDocs.length 그것을해야한다 : 이제 i == dbDocs.length-1

,이 시도 :

for (var i = 0; i < dbDocs.length; i += 1) { 
    (function (i) { 
     db.collection('invoices').update({ _id: dbDocs[i]._id }, { $set: { paid: dbDocs[i].paid } }, function (err, result) { 
      if (err) throw err; 

      // Trigger a redirect after the last iteration. 
      if (!err && (i == dbDocs.length-1)) { 
       console.log('i: ', i); 
       res.redirect('/superadmin/fakturor'); 
      } 
     }); 
    })(i) 
} 
} 

Answer 2

를 이것은 당신이 다루는 일부 도우미 기능을 사용할 수있는에서 async library의 일반적인 사용 사례 귀하 동시성 문제.

async.each(arr, iterator, callback)을 사용할 수 있으며 배열의 각 구성원에 iterator()이 호출됩니다. 모든 반복기가 완료되면 callback 함수가 호출됩니다.

var async = require('async'); 

var updateDoc = function (elem, cb) { 
    db.collection('invoices').update({_id:elem._id}, {$set:{ paid: elem.paid }}, cb); 
} 

var done = function (err) { 
    if (err) 
    return console.error(err.message); 
    res.redirect('/superadmin/fakturor'); 
} 

async.each(dbDocs, updateDoc, done);