JavaScript – Mongodb节点驱动程序2.0.*与Bluebird 2.9.* promisification

所以还有一些关于这个问题的其他查询,如：
How can I promisify the MongoDB native Javascript driver using bluebird?

然而,似乎没有解决最新版本的驱动程序,这似乎在尝试承诺时有问题.目前我可以通过做MongoClient工作：

Promise.promisifyAll(mongodb.MongoClient); //在这里使用.Prototype不能保证

然而,无论我尝试收藏似乎没有使用*异步调用操作,它可能会调用它们,但是它们永远不会被解决或拒绝,所以他们只是陷入困境.

在以前的版本中,您将只是Promise.promisifyAll(mongodb),并且您已经完成了,但我不确定如何在新驱动程序中正确处理此问题.

以下是使用mongo直接promisification connectAsync创建的集合的示例输出,然后从返回的数据库获取集合.一旦我尝试在收集上做任何事情,它只是挂起,并承诺不从它返回：

{s：
{pkFactory：
{[Function：ObjectID]
索引：14727641,
createPk：[Function：createPk],
createFromTime：[Function：createFromTime],
createFromHexString：[Function：createFromHexString],
isValid：[Function：isValid],
ObjectID：[Circular]
ObjectId：[Circular]
createPkAsync：[Object],
createFromTimeAsync：[Object],
createFromHexStringAsync：[Object],
isValidAsync：[Object],
bindAsync：[Object],
toStringAsync：[Object],
callAsync：[Object],
applyAsync：[Object],
lazyAsync：[Object]
throttleAsync：[Object],
debounceAsync：[对象],
delayAsync：[Object],
everyAsync：[Object]
cancelAsync：[Object],
afterasync：[Object],
onceAsync：[Object],
fillAsync：[Object]},
DB：
{domain：[Object],
_events：{},
_maxListeners：未定义,
s：[对象]
serverConfig：[Getter],
bufferMaxEntries：[Getter],
databaseName：[Getter]
选项：[Getter],
native_parser：[Getter],
slaveOk：[Getter],
writeConcern：[Getter]},
拓扑结构：
{domain：[Object],
_events：[Object]
_maxListeners：未定义,
connectTimeoutMS：500,
s：[对象]
bson：[Getter],
isMasterDoc：[Getter]
poolSize：[Getter]
autoReconnect：[Getter],
主持人：[Getter],
端口：[Getter],
emitOpen：false,
socketTimeoutMS：0},
dbname：’some-db-name’,
选项：{},
命名空间：’some-namespace’,
readPreference：null,
原料：未定义,
slaveOk：false,
serializefunction：undefined,
internalHint：null,
collectionHint：null,
name：’some-collection-name’}}

解决方法

您可以在要求之后直接承诺,如 bluebird API docs所示,如下所示：

var Promise = require("bluebird");
var MongoDB = Promise.promisifyAll(require("mongodb"));
var util = require('util');

console.log(util.inspect(MongoDB,{ showHidden: true }));

使用bluebird 2.9.14和mongodb驱动程序2.0.22,我得到这个(简化的)结果：

// ....
  Collection: 
   { [Function]
     [length]: 6,[name]: '',[arguments]: [Getter/Setter],[caller]: [Getter/Setter],[prototype]: 
      { [constructor]: [Circular],collectionName: [Getter],// .... 
        findAsync: [Object],insertOneAsync: [Object],insertManyAsync: [Object],bulkWriteAsync: [Object],insertAsync: [Object],updateOneAsync: [Object],replaceOneAsync: [Object],updateManyAsync: [Object],updateAsync: [Object],deleteOneAsync: [Object],removeOneAsync: [Object],deleteManyAsync: [Object],removeManyAsync: [Object],removeAsync: [Object],saveAsync: [Object],findOneAsync: [Object],// ....

并成功查询：

MongoDB.connectAsync('mongodb://localhost:27017/test').then(function(db) {
    return db.collection("orders").findOneAsync({});
}).then(function(orders) {
    console.log(orders);
}).catch(function(err) {
    console.log(err);
});

UPDATE

使用MongoClient对象也是如此：

var Promise = require("bluebird");
var MongoDB = Promise.promisifyAll(require("mongodb"));
var MongoClient = Promise.promisifyAll(MongoDB.MongoClient);

MongoClient.connectAsync('mongodb://localhost:27017/test').then(function(db) {
    return db.collection("orders").find({}).toArrayAsync();
}).then(function(orders) {
    console.log(orders)
}).catch(function(err) {
    console.log(err);
});