如何重用带有承诺的 mongo 连接

Question

如何更改我的数据库连接调用中的内容，以便我可以执行 db.collection():

// Create a Mongo connection
Job.prototype.getDb = function() {
  if (!this.db)
    this.db = Mongo.connectAsync(this.options.connection);
  return this.db;
};

// I want to be able to do this
Job.prototype.test = function() {
  return this.db.collection('abc').findAsync()...
};

// Instead of this
Job.prototype.test = function() {
  return this.getDb().then(function(db) {
    return db.collection('abc').findAsync()...
  });
};

我的代码总是调用 getDb，因此确实会创建连接，所以这不是问题。例如：

this.getDb().then(test.bind(this));

但我实际上将许多这样的调用串联在一起，因此正在寻找一种更简洁的方法。

这有效 - 只是想知道是否有更好的整体方法来处理这个问题。

Job.prototype.getDb = function(id) {
  var self = this;
  return new P(function(resolve, reject) {
    if (!self.db) {
      return Mongo.connectAsync(self.options.connection)
      .then(function(c) {
        self.db = c;
        debug('Got new connection');
        resolve(c);
      });
    }
    debug('Got existing connection');
    resolve(self.db);
  });
};

我想这真的只是一个 mongo 连接问题，也许不仅仅是承诺。我看到的所有 Mongo 示例要么只是在连接回调中进行所有调用，要么使用某些框架（如 Express）并在启动时分配它。

Answer 1

I want to be able to do this
return this.db.collection('abc').findAsync()

不，当你不知道数据库是否已经连接时，这是不可能的。如果你一开始可能需要连接，那是异步的，那么 this.db 必须产生一个承诺，你需要使用 then.

请注意，使用 Bluebird，您可以稍微缩短该代码，并通过使用 .call() method:

避免冗长的 .then() 回调

Job.prototype.getDb = function() {
  if (!this.db)
    this.db = Mongo.connectAsync(this.options.connection);
  return this.db;
};
Job.prototype.test = function() {
  return this.getDb().call('collection', 'abc').call('findAsync');
};

如何重用带有承诺的 mongo 连接

How to reuse a mongo connection with promises

javascript

mongodb

promise

bluebird