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’}}
解决方法
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);
});
