sharing mongodb connection object globally in a node js app

Question

sharing mongodb connection object globally in a node js app

how do i share the db object returned from when i call db.open or db.connect across the entire app?

i have a dbconnect.js module as follows :

var mongodb = require('mongodb');
var global_db  = '';

// Define options. Note poolSize.
var serverOptions = {
   'auto_reconnect': true,
   'poolSize': 5
};

// Now create the server, passing our options.
var serv = new mongodb.Server('localhost', 27017, serverOptions);

// At this point, there is no connection made to the server.

// Create a handle to the Mongo database called 'myDB'.
var dbManager = new mongodb.Db('myDB', serv);

// NOW we initialize ALL 5 connections:
dbManager.open(function (error, db) {
  // Do something with the connection.
  global_db = db;
  // Make sure to call db.close() when ALL connections need
  // to be shut down.
  db.close();
});

function getConnection()
{
   return global_db;
} 

exports.getConnection = getConnection;

and i am using this dbconnect.js in my app.js as:

var http = require('http');
var db = require('./dbconnect').getConnection();
var collection = db.collection('testcollection');
console.log(db);
console.log(collection);

var server = http.createServer();

server.on('request',route);

server.listen(8000,'127.0.0.1');

console.log('Server running at http://127.0.0.1:8000');

function route(request,response)
{
    var url = request.url;
    var doc = {};
    doc[url] = 'ok';
    collection.insert(doc,{w:1},function(err,result)
        {
            if(err) console.log(err);
            else console.log(result);
        });
}

in the console, the db and collection variable show empty values, i also tried removing the db.close() call in dbconnect.js but to no use, however the insertion works when i place it inside dbconnect.js file in the dbManager.open function, how do i do this?or any similar alternatives?

node.js
mongodb

Answer 1

You can't do that, because dbManager.open( is async method, but you trying to get data from module synchronously.

Try this:

In dbconnect.js

var on_db_ready = null;
module.exports = {
                db_ready:function(db_ready_callback){
                     on_db_ready = db_ready_callback;
                     //here we call callback if already have db
                     if (global_db) on_db_ready(global_db);
                 },
                 getConnection:getConnection
                };
dbManager.open(function (error, db) {
 if (on_db_ready) on_db_ready(db);
  global_db= db;
})

in app.js:

var db = require('./dbconnect').db_ready(function(db){
  //Here i have my database
  //or can use getConnection method
});

this is not very beautiful way, but, I hope, explain your mistake