Node.js | MongoDB count（）：データの挿入前後のカウントの取得

Question

データの挿入が成功したことを確認するために、データベース内のアイテムの数を取得しようとしています。私は、これはいくつかの簡単な関数を使用して実装することができます知っている：

1. は
2. 挿入
3. 要約

注CONSOLE.LOG

挿入した後、カウント取得を挿入する前に数えなさい

dbName.equal(insertSize, result.insertedCount) 

ただし、私はjavascriptを初めて使用しています私は非同期コールバックを実装する必要があると思っているので、これを理解したいと思いました。

挿入機能

var insertMany = function() { 

    // get initial count 
    var count1 = getDbCount(); 

    // Insert new 'data' 
    MongoClient.connect(url, function(err, db) { 
     var col = db.collection(collectionName); 
     col.insert(data, {w:1}, function(err,result) {}); 
     db.close(); 
    }); 

    /** This needs to be implemented through next/callback 
     after the insert operation **/ 
    var count2 = getDbCount(); 

    /** These final console logs should be executed after all 
     other operations are completed **/  
    console.log('[Count] Start: ' + count1 + ' | End:' +count2); 
    console.log('[Insert] Expected: ' + data.length + ' | Actual: ' + (count2 - count1)); 

}; 

は、必要な操作が完了する前にリターンが発生しているので、私はエラーを取得しています

var getDbCount = function() { 
    MongoClient.connect(url, function(err, db) { 
     if (err) console.log(err); 

     var col = db.collection(collectionName); 

     col.count({}, function(err, count) { 
      if (err) console.log(err); 
      db.close(); 
      console.log('docs count: ' + count); 
      // This log works fine 
     }); 

    }); 

    return count; // this is returning as undefined since this is 
        // executing before the count operation is completed 
}; 

DBカウント機能を取得します。

ありがとうございました。

---

[EDIT]同様にgetCount機能約束

と私は開始と同様にgetCount機能への約束を追加しました：

var getCount = function() { 

    var dbCount = 0; 

    var promise = new Promise(function(resolve, reject) { 

     MongoClient.connect(url, function(err, db) { 

      if (err) { 
       console.log('Unable to connect to server', err); 
      } else { 
       console.log('Database connection established:' + dbName); 
      } 

      // Get the collection 
      var col = db.collection(collectionName); 

      col.count({}, function(err, count) { 
       if (err) console.log(err); 
       db.close(); 
       console.log('docs count: ' + count); 
       resolve(null); 
       dbCount = count; 
      }); 

     }); 

    }); 

    promise.then(function() { 
     return dbCount; 
    }); 

}; 

console.log(getCount()); 

は、出力はまだです： 未定義 データベース接続確立された：testdb ドキュメント数：500

それから、（{return count}）コードはpromise {db.count（）}の前に実行されています。データベース操作が完了する前にundefinedを返します。

Answer 1

一般的に問題は、関数が返ってきたときに値が既に存在することが予想されることです。非同期関数の場合は、そうでない場合がよくあります。非同期処理に関する膨大な情報があります（Javaのような並列処理と誤解されることはありません）。私はあなたの状況に合わせなければならない例を作成しました

：

https://jsfiddle.net/rh3gx76x/1/

var dummyCount = 5 
getCount = function() { 
    return new Promise(function(resolve, reject) { 
     setTimeout(function() { // this would be your db call, counting your documents 
      resolve(dummyCount); // dummy for number of documents found 
     }, 100 * Math.random()); 
    }); 
}; 

insertMany = function() { 
    return new Promise(function(resolve, reject) { 
     setTimeout(function() { // this would be your db call, writing your documents 
      dummyCount += 2; 
      resolve(); 
     }, 100 * Math.random()); 
    }); 
}; 

runIt = function(callback) { 
    var count1; 
    getCount().then(function(count) { 
     console.log("First callback with value ", count); 
     count1 = count; 
     insertMany().then(function() { 
     getCount().then(function(count2){ 
      console.log("Second callback with value ", count2); 
       callback(null, count1, count2); 
     }); 
     }) 
    }) 
} 

runIt(function(err, count1, count2) { 
    console.log("count1: " + count1 + ", count2: " + count2); 
}); 

最後に一つ。 「非同期」パッケージをチェックアウトすることができます。これは、多くのヘルパー関数と制御フローを提供する問題で多くの助けになります。

Answer 2

操作が完了する前にリターンが発生しているのは、javacriptから継承されたnodejsのasynchronousデザインです。 Mongoose.connect()からのコールバックは、プログラムが前進して、returnに遭遇している間、操作を行うために残されます。

エラーステートメントにあなたの問題を解決した回避策を提供していないため、ここで何が間違っているのかについてはコメントできません。しかし、あなたが始めたものを終わらせるための最初の努力を考えれば、Mongoose.connect()が完了してからreturnステートメントが実行されるようにする最良の方法は、JavaScriptのpromiseを使用することです。約束を使用すると、Mongoose.connect()が実行され、コントロールをreturn文に渡します。

挿入機能：

var insertMany = function() { 

// get initial count 
var count1 = getDbCount(); 

// Insert new 'data' 
var promise = new Promise(
    function(resolve,reject){ 
     MongoClient.connect(url, function(err, db) { 
     var col = db.collection(collectionName); 
     col.insert(data, {w:1}, function(err,result) {}); 
     db.close(); 
     resolve(null); 
     }); 
    } 
); 
    promise.then(function(val){  
    var count2 = getDbCount(); 

    /** These final console logs should be executed after all 
    other operations are completed **/ 
    console.log('[Count] Start: ' + count1 + ' | End:' +count2); 
    console.log('[Insert] Expected: ' + data.length + ' | Actual: ' + (count2 - count1)); 
}); 

同様に、あなたはGetDB機能に約束を追加することができます

あなたのコードは次のようになります。 約束の実行中にキーポイントは次のとおり

1. then()が約束を実行した後に同期して実行される機能の一部を含みます。これはresolveによって呼び出され、渡されたパラメータは関数のコールバックcatchで受信されます。
2. catch()には、約束事でエラーが発生したときに呼び出される関数の部分が含まれています。これはrejectによって呼び出され、渡されたパラメータはcatch関数のコールバックで受信されます。

EDIT：約束の代替は、それが約束とは異なり、外部モジュールであるという事実が異なる、async.jsです。