Как обрабатывать соединение MongoDB и запросы в ExpressJS

Question

Я знаю, что этот вопрос уже задан более чем пару раз, но я не могу найти ответ на свой конкретный вопрос.

Я создал пример приложения с express-generator, и я создал модуль со всеми параметрами соединения.

/helpers/db.js

var MongoClient = require('mongodb').MongoClient; 
var ObjectId = require('mongodb').ObjectID; 
var url = 'mongodb://localhost:27017/piva'; 
var db; 

var database = { 
    connect: function(){ 
     MongoClient.connect(url, function(err, database) { 
      if(err) throw 'MongoDB connection error: ' + err; 
      console.log('connesso al db'); 
      db = database; 
     }); 
    }, 
    useDb: function(){ 
     return db; 
    } 
} 

module.exports = database; 

Если я позвоню в главном app.js файле require('./helpers/db').connect() и я требую модуля в одном из моих маршрутов с использованием

/routes/index.js

var db = require('../helpers/db').useDb(); 
router.get('/', function (req, res, next) { 
    db.collection('test').... 
    index.render({ 
    title: 'Home page' 
    }, res); 
}); 

он не работает, так как db возвращает undefined, а если я требую его внутри router.get, он работает. Я думаю, что я должен начать подключение до загрузки приложения, но я не знаю, как с этим справиться.

Я видел много Tuts или ответа, где они говорят, чтобы позвонить app.listen(3000); с обратным вызовом после Mongoclient.connect() подключился к БД, но я не знаю, как это сделать, так как мое приложение было создано с express-generator.

Answer 1

Измените свой файл подключения следующим образом и вызовите форму функции init.js. Он сгенерирует объект db, а затем вызовет его из любой точки.

var MongoClient = require('mongodb').MongoClient; 
var ObjectId = require('mongodb').ObjectID; 
var url = 'mongodb://localhost:27017/piva'; 
module.exports.init = function(callback){ 
MongoClient.connect(url, function(err, db){ 
    if(!err){ 
     console.log('mongodb connected'); 
    } 
    module.exports.db = db; 
    callback(err); 
}); 
};