Oto potencjalne rozwiązanie oparte na podejściu liczenia (nie testowałem go i nie ma błędów wyłapywania, ale powinno to przekazać ideę).
Podstawowa strategia to:Pozyskaj liczbę rekordów do zaktualizowania, zapisz każdy rekord asynchronicznie i wywołanie zwrotne w przypadku powodzenia, które zmniejszy liczbę i zamknie bazę danych, jeśli liczba osiągnie 0 (po zakończeniu ostatniej aktualizacji). Używając {safe:true}
możemy zapewnić, że każda aktualizacja zakończy się sukcesem.
Serwer mongo będzie używał jednego wątku na połączenie, więc dobrze jest albo a) zamknąć nieużywane połączenia, albo b) połączyć je/ponownie wykorzystać.
db.open(function (err, db) {
db.collection('foo', function (err, collection) {
var cursor = collection.find({});
cursor.count(function(err,count)){
var savesPending = count;
if(count == 0){
db.close();
return;
}
var saveFinished = function(){
savesPending--;
if(savesPending == 0){
db.close();
}
}
cursor.each(function (err, doc) {
if (doc != null) {
doc.newkey = 'foo'; // Make some changes
db.save(doc, {safe:true}, saveFinished);
}
});
})
});
});