węzeł MongoDB kierowca 2,0 * z Bluebird 2,9 * promisification

Question

więc istnieje kilka innych zapytań wokół tej kwestii, takich jak: How can I promisify the MongoDB native Javascript driver using bluebird?

Jednak nie wydaje się, aby rozwiązać najnowszą wersję sterownika, który wydaje mieć problemy podczas próby promisify. Obecnie można uzyskać MongoClient pracuje wykonując:

Promise.promisifyAll(mongodb.MongoClient); // Using .Prototype here fails to promisify

Jednak bez względu na to, co staram się Collections nie wydają się działać przy użyciu połączenia *async, może je wywołać, ale nigdy nie zostanie rozwiązany lub odrzucone więc po prostu zwisają w otchłani.

Historycznie w poprzednich wersjach byłeś po prostu Promise.promisifyAll(mongodb) i skończyłeś, ale nie jestem pewien, jak poprawnie obsłużyć to w nowym sterowniku.

Oto przykładowe dane wyjściowe kolekcji, która została utworzona za pomocą mongo direct promisification connectAsync, a następnie pobranie kolekcji z zwróconej bazy danych. Raz spróbować zrobić coś w sprawie zbierania po prostu zawiesza się i obiecuje dont powrócić z nim:

{ s: { pkFactory: { [Function: ObjectID] index: 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: [Object], delayAsync: [Object], everyAsync: [Object], cancelAsync: [Object], afterAsync: [Object], onceAsync: [Object], fillAsync: [Object] }, db: { domain: [Object], _events: {}, _maxListeners: undefined, s: [Object], serverConfig: [Getter], bufferMaxEntries: [Getter], databaseName: [Getter], options: [Getter], native_parser: [Getter], slaveOk: [Getter], writeConcern: [Getter] }, topology: { domain: [Object], _events: [Object], _maxListeners: undefined, connectTimeoutMS: 500, s: [Object], bson: [Getter], isMasterDoc: [Getter], poolSize: [Getter], autoReconnect: [Getter], host: [Getter], port: [Getter], emitOpen: false, socketTimeoutMS: 0 }, dbName: 'some-db-name', options: {}, namespace: 'some-namespace', readPreference: null, raw: undefined, slaveOk: false, serializeFunctions: undefined, internalHint: null, collectionHint: null, name: 'some-collection-name' } }

Answer 1

Można promisify go bezpośrednio po wymagających, jak zilustrowano na bluebird API docs, tak:

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

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

Korzystanie Bluebird 02.09.14 i MongoDB sterownik 2.0.22, mam to (uproszczony) wyniki:

// .... 
    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], 
     // .... 

i zapytaliśmy successfu lly tak:

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

Używanie obiektu MongoClient działa tak samo:

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); 
}); 

Answer 2

Usprawnione i bardziej realistyczna wersja:

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

MongoDB.MongoClient.connectAsync('mongodb://localhost:27017/test') 
    .then(function(db) { // Expose db to query logic 
    // need to return a promise to let outer catch handle it 
    return db.collection("orders").find({}).toArrayAsync() 
     .then(function (orders) { 
     console.log(orders); 
     }) 
     // Ensure that db is closed at the end no matter what... 
     .finally(db.close.bind(db)); 
     // No need for another catch here, the outer one will handle it 
    }) 
    .catch(console.log.bind(console)); 

Obietnica gniazdowania odbywa w celu ujawnienia db do Reszta logiki. To samo można zrobić bez zagnieżdżania przez przekazanie lub deklarowanie "db" globalnie. Wypróbowałem to wszystko i ten jest najbardziej elegancki.

Answer 3

Domyślnie sterownik mongodb zawsze zwraca obietnicę, jeśli nie określisz wywołania zwrotnego. Ale możesz polecić, by zwrócił obietnice, korzystając z biblioteki preferowanych obietnic.

Oto prosty sposób korzystać Bluebird obietnic podczas korzystania node-mongodb-native 2.0 sterownik:

var Promise = require("bluebird"); 
var MongoClient = require("mongodb").MongoClient; // Doesn't require promisification 

/*...*/ 
function saveData(data) { 
    MongoClient 
    .connect(MONGO_CONNECTION_STRING, { 
     promiseLibrary: Promise // Here you instruct to use bluebird 
    }) 
    .then(function(db) { 
     return db 
     .collection('myCollection') 
     .insert(data) 
     .finally(db.close.bind(db)) 
    }) 
    .catch(function(err) { 
     console.error("ERROR", err); 
    }); 
} 

Answer 4

można odczytać źródło MongoDB Native Kierowca:

MongoClient.connect = function(url, options, callback) { 
    var args = Array.prototype.slice.call(arguments, 1); 
    callback = typeof args[args.length - 1] == 'function' ? args.pop() : null; 
    options = args.length ? args.shift() : null; 
    options = options || {}; 

    // Get the promiseLibrary 
    var promiseLibrary = options.promiseLibrary; 

    // No promise library selected fall back 
    if(!promiseLibrary) { 
    promiseLibrary = typeof global.Promise == 'function' ? 
     global.Promise : require('es6-promise').Promise; 
    } 

    // Return a promise 
    if(typeof callback != 'function') { 
    return new promiseLibrary(function(resolve, reject) { 
     connect(url, options, function(err, db) { 
     if(err) return reject(err); 
     resolve(db); 
     }); 
    }); 
    } 

    // Fallback to callback based connect 
    connect(url, options, callback); 
} 

promiseLibrary można setted Bluebird