Geschachteltes Versprechen in einer for-Schleife, die sich nicht wie erwartet verhält

Question

Ich habe Probleme beim Erweitern einer Promise innerhalb einer . Ich versuche DB-Updates in einer for-Schleife durchzuführen und schließe dann die Datenbank, nachdem alle Datensätze verarbeitet wurden. Die Anwendung wird jedoch sofort mit process.exit() beendet, was bedeutet, dass process.exit() ausgeführt wurde, noch bevor alle Datenbankaktualisierungen abgeschlossen wurden. Ich bin mir ziemlich sicher, dass ich mit dem verschachtelten Versprechen etwas falsch mache.

var myDB; 

function doSomething() { 
    return MongoClient.connect(DB_CONNECTION).then(function(db) { 
     myDB = db; 
     var collection = db.collection(COLLETION_NAME); 
     for (var i = 0; i < 10; i++) { 

      promise.then(function{ 
       collection.update({ 
        symbol: items[i].symbol 
       }, { 
        $set: { 
         value: 123 
        } 
       }, { 
        upsert: true 
       }); 
      }); 
     } 
    }) 
} 

var promise = doSomething(); 
promise.then(function(){ 
    console.log("DONE"); 
    myDB.close(); 
    process.exit(); 
}); 

Answer 1

aktualisiert Code gemäß @RayonDabre ‚s Vorschlag

function doSomething() { 
    return MongoClient.connect(DB_CONNECTION).then(function(db) { 
     myDB = db; 
     var collection = db.collection(COLLECTION_NAME); 
     var promises = []; 

     for (var i = 0; i < 10; i++) { 
      var innerPromise = collection.update({ 
       symbol: items[i].symbol 
      }, { 
       $set: { 
        value: 123 
       } 
      }, { 
       upsert: true 
      }); 
      promises.push(innerPromise); 
     } 
     return Promise.all(promises); 
    }); 
} 


var promise = doSomething(); 
promise.then(function(){ 
    console.log("DONE"); 
    myDB.close(); 
    process.exit(); 
}); 

Answer 2

Es sieht so aus, als ob Sie von der MongoClient.connect-Methode ein Versprechen erhalten, warum also nicht zusammen verwenden. Ich habe zusammen eine schnelle Probe gestellt unten basierend auf Ihren Code:

function doSomething(db) { 
    return new Promise(function(resolve, reject){ 
     var collection = db.collection(COLLETION_NAME); 
     for (var i = 0; i < 10; i++) { 
      collection.update({ 
       symbol: items[i].symbol 
      }, { 
       $set: { 
        value: 123 
       } 
      }, { 
       upsert: true 
      }); 
     } 

     resolve(db); 
    }) 
} 

function connectToDB() { 
    return MongoClient.connect(DB_CONNECTION); 
} 

function closeDB(db) { 
    return new Promise(function(resolve, reject){ 
     db.close(); 
     resolve(); 
    }); 
} 

connectToDB().then(function(db){ 
    return doSomething(db); 
}).then(function(db){ 
    return closeDB(db); 
}).then(function(){ 
    console.log("DONE"); 
    process.exit(); 
}).catch(function(error){ 
    console.log('Something went wrong: ' + error); 
});