2

我目前正在从 mongoose 回滚到 node-mongodb-native。

所以我对这个话题很陌生。但是我目前的问题是想要在服务器启动时创建一个数据库集合，然后我可以通过应用程序使用它。不幸的是，我只在存储库中找到示例，您只能在连接函数的回调中直接执行数据库操作。

文档：

var mongodb = require("mongodb"),
    mongoServer = new mongodb.Server('localhost', 27017),
    dbConnector = new mongodb.Db('example', mongoServer);

db_connector.open(function(err, db) {
    if (err) throw new Error(err);

    // here I can do my queries etc.
});

但是，当我在某些路由回调中时，如何访问回调中的 db 对象？目前我唯一的想法是将应用程序包装到回调中：

var mongodb = require("mongodb"),
    express = require("express"),
    mongoServer = new mongodb.Server('localhost', 27017),
    dbConnector = new mongodb.Db('example', mongoServer);

var app = new express();

db_connector.open(function(err, db) {
    if (err) throw new Error(err);

    app.get('/products', function(req, res, next) {
        db.collection('products', function(err, collection) {
            if (err) next(new Error(err));
            collection.find({}, function(err, products) {
                res.send(products);
            });
        });
    });

});

但我认为这不应该是这样吗？

有没有办法创建一个同步数据库连接调用，然后我可以轻松地在整个应用程序中使用它是如何被猫鼬使用的？

问候博多

4

1 回答 1

3

Db.open 打开与 mongodb 的连接并返回对自身的引用。看到这里的源代码：https ://github.com/mongodb/node-mongodb-native/blob/master/lib/mongodb/db.js#L245

您所要做的就是推迟启动您的 express 应用程序在其端口上侦听并接收请求，直到您与 mongodb 建立连接。

所以你可以做的是：

var mongodb = require("mongodb"),
    express = require("express"),
    mongoServer = new mongodb.Server('localhost', 27017),
    dbConnector = new mongodb.Db('example', mongoServer),
    db;

var app = new express();

app.get('/products', function(req, res, next) {
  db.collection('products', function(err, collection) {
    if (err) next(new Error(err));
    collection.find({}, function(err, products) {
      res.send(products);
    });
  });
});

db_connector.open(function(err, opendb) {
  if (err) throw new Error(err);
  db = opendb;
  app.listen(3000);
});

不过，我不确定这是否是个好主意。如果连接中断或您重新启动了 mongodb 进程，此解决方案不允许您重新创建连接。因此，尽管上述方法可能有效，但创建一个方法来包装与 mongodb 的连接的创建可能是一个更好的主意。

于 2012-12-13T16:48:21.970 回答