node.jsでmongodb collection getallを呼び出す方法は？

Question

私はmongo dbからの通知の全リストを取るが、空の（[]）配列も返す。私はコールバックまたはそれより短い方法が必要であることを知っている。 node.jsによるmongodbからのデータの収集に関する考えはありますか？私はこの/通知し法（http://127.0.0.1:5000/Notifies）を呼び出した場合

var MongoClient = require('mongodb').MongoClient; 
var express = require("express"); 
var app = express(); 


format = require('util').format; 
MongoClient.connect('mongodb://127.0.0.1:27017/Test', function (err, db) { 
    if (err) { 
     throw err; 
    } else { 
     console.log("successfully connected to the database"); 
    } 
    db.close(); 
}); 

app.get('/Notifies', function (req, res) { 

    // BAD! Creates a new connection pool for every request 
    console.log('connected'); 
    MongoClient.connect('mongodb://127.0.0.1:27017/Test', function (err, db) { 
     if (err) throw err; 

     var coll = db.collection('Notifies'); 
     var arr = []; 
     coll.find({}, function (err, docs) { 
      docs.each(function (err, doc) { 
       if (doc) { 
        console.log(doc); 
        arr.push(doc); 

       } else { 
        res.end(); 
       } 
      }); 
     }); 
     return res.json(arr); 
    }); 
}); 

var port = Number(process.env.PORT || 5000); 
app.listen(port, function() { 
    console.log("Listening on " + port); 
}) 

Answer 1

ので、それは

MongoClient.connect('mongodb://127.0.0.1:27017/Test', function (err, db) { 
    if (err) throw err; 

    var coll = db.collection('Notifies'); 

coll.find({}).toArray(function (err,result) { 
       if(err){ 
        res.send(err); 
       } 
        else{ 

         res.send(JSON.stringify(result)); 
       } 
      }) 

}); 

Answer 2

問題は、実際のDB操作が発生する前に、関数内から空の配列を返すされています。あなたはfind関数に行return res.json(arr); を移動する必要があります。

app.get('/Notifies', function (req, res) { 

    // BAD! Creates a new connection pool for every request 
    console.log('connected'); 
    MongoClient.connect('mongodb://127.0.0.1:27017/Test', function (err, db) { 
     if (err) throw err; 

     var coll = db.collection('Notifies'); 
     var arr = []; 
     coll.find({}, function (err, docs) { 
      console.log(docs); 
      docs.each(function (err, doc) { 
       if (doc) { 
        console.log(doc); 
        arr.push(doc); 

       } else { 
        res.end(); 
       } 
      }); 
      return res.json(arr); 
     }); 
    }); 
}); 

また、将来の使用のために、ネストされた関数内の変数名を再利用していない（あなたは変数err使う3つの機能を持っています）。