1

当我在整个应用程序中调用 db.open 或 db.connect 时，如何共享返回的 db 对象？

我有一个 dbconnect.js 模块，如下所示：

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;

我在我的 app.js 中使用这个 dbconnect.js 作为：

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);
        });
}

在控制台中，db 和 collection 变量显示空值，我还尝试删除 dbconnect.js 中的 db.close() 调用，但没有用，但是当我将其放在 dbManager 中的 dbconnect.js 文件中时，插入工作。打开功能，我该怎么做？或任何类似的替代方案？

4

1 回答 1

2

你不能这样做，因为 dbManager.open( 是异步方法，但你试图从模块同步获取数据。

尝试这个：

在 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;
})

在 app.js 中：

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

这不是很漂亮的方式，但是，我希望，解释你的错误

于 2013-03-05T09:31:27.720 回答