我想使用带有bluebird promises的MongoDB 原生 JS 驱动程序。我如何在这个库上使用？Promise.promisifyAll()
问问题
18444 次
5 回答
23
2.0 分支文档包含更好的承诺指南https://github.com/petkaantonov/bluebird/blob/master/API.md#promisification
它实际上有更简单的 mongodb 示例：
var Promise = require("bluebird");
var MongoDB = require("mongodb");
Promise.promisifyAll(MongoDB);
于 2014-05-21T09:13:14.680 回答
18
使用 时Promise.promisifyAll()，如果您的目标对象必须被实例化，它有助于识别目标原型。对于 MongoDB JS 驱动程序，标准模式是：
Db使用MongoClient静态方法或Db构造函数获取对象- 调用
Db#collection()以获取Collection对象。
因此，从https://stackoverflow.com/a/21733446/741970借用，您可以：
var Promise = require('bluebird');
var mongodb = require('mongodb');
var MongoClient = mongodb.MongoClient;
var Collection = mongodb.Collection;
Promise.promisifyAll(Collection.prototype);
Promise.promisifyAll(MongoClient);
现在你可以：
var client = MongoClient.connectAsync('mongodb://localhost:27017/test')
.then(function(db) {
return db.collection("myCollection").findOneAsync({ id: 'someId' })
})
.then(function(item) {
// Use `item`
})
.catch(function(err) {
// An error occurred
});
这会让你走得很远，除了它还有助于确保Cursor返回的对象Collection#find()也被承诺。在 MongoDB JS 驱动程序中，返回的游标Collection#find()不是从原型构建的。因此，您可以包装该方法并每次都承诺游标。如果您不使用游标，或者不想产生开销，这不是必需的。这是一种方法：
Collection.prototype._find = Collection.prototype.find;
Collection.prototype.find = function() {
var cursor = this._find.apply(this, arguments);
cursor.toArrayAsync = Promise.promisify(cursor.toArray, cursor);
cursor.countAsync = Promise.promisify(cursor.count, cursor);
return cursor;
}
于 2014-05-20T23:58:18.613 回答
10
我知道这已经被回答了好几次，但我想添加更多关于这个主题的信息。根据 Bluebird 自己的文档，您应该使用“使用”来清理连接并防止内存泄漏。 Bluebird 中的资源管理
我到处寻找如何正确地做到这一点，信息稀缺，所以我想我会分享我在反复试验后发现的东西。我在下面使用的数据（餐厅）来自 MongoDB 示例数据。你可以在这里得到：MongoDB 导入数据
// Using dotenv for environment / connection information
require('dotenv').load();
var Promise = require('bluebird'),
mongodb = Promise.promisifyAll(require('mongodb'))
using = Promise.using;
function getConnectionAsync(){
// process.env.MongoDbUrl stored in my .env file using the require above
return mongodb.MongoClient.connectAsync(process.env.MongoDbUrl)
// .disposer is what handles cleaning up the connection
.disposer(function(connection){
connection.close();
});
}
// The two methods below retrieve the same data and output the same data
// but the difference is the first one does as much as it can asynchronously
// while the 2nd one uses the blocking versions of each
// NOTE: using limitAsync seems to go away to never-never land and never come back!
// Everything is done asynchronously here with promises
using(
getConnectionAsync(),
function(connection) {
// Because we used promisifyAll(), most (if not all) of the
// methods in what was promisified now have an Async sibling
// collection : collectionAsync
// find : findAsync
// etc.
return connection.collectionAsync('restaurants')
.then(function(collection){
return collection.findAsync()
})
.then(function(data){
return data.limit(10).toArrayAsync();
});
}
// Before this ".then" is called, the using statement will now call the
// .dispose() that was set up in the getConnectionAsync method
).then(
function(data){
console.log("end data", data);
}
);
// Here, only the connection is asynchronous - the rest are blocking processes
using(
getConnectionAsync(),
function(connection) {
// Here because I'm not using any of the Async functions, these should
// all be blocking requests unlike the promisified versions above
return connection.collection('restaurants').find().limit(10).toArray();
}
).then(
function(data){
console.log("end data", data);
}
);
我希望这可以帮助其他想通过蓝鸟书做事的人。
于 2015-10-30T21:34:38.580 回答
7
1.4.9 版mongodb现在应该很容易被承诺为：
Promise.promisifyAll(mongo.Cursor.prototype);
有关更多详细信息，请参阅https://github.com/mongodb/node-mongodb-native/pull/1201。
于 2014-08-26T12:52:04.737 回答
0
我们已经在生产中使用以下驱动程序一段时间了。它本质上是原生 node.js 驱动程序的承诺包装器。它还添加了一些额外的辅助函数。
poseidon-mongo- https://github.com/playlyfe/poseidon-mongo
于 2016-07-28T06:03:51.220 回答