6

コールバックで提供されるpg.connect内部メソッドとともに、node-postgres のメソッドを約束したいと思います。connection.query

後者はできますが.promisify、最初のものは手動で実装する必要があります (ここで何か不足している場合は説明してください)。

問題は、このコードが正しいかどうか、または改善する必要があるかどうかわかりません。コードは機能しています。Bluebird を意図したとおりに使用しているかどうかを知りたいだけです。

// aliases
var asPromise = Promise.promisify;

// save reference to original method
var connect = pg.connect.bind(pg);

// promisify method
pg.connect = function (data) {
  var deferred = Promise.defer();

  connect(data, function promisify(err, connection, release) {
    if (err) return deferred.reject(err);

    // promisify query factory
    connection.query = asPromise(connection.query, connection);

    // resolve promised connection
    deferred.resolve([connection,release]);
  });

  return deferred.promise;
};
4

4 に答える 4

4

これまでに、これを行うライブラリがいくつかあります。

于 2014-11-05T14:06:34.497 に答える
4

その恐ろしいコールバック コードをすべて捨てて、アプリケーションの初期化のどこかでこれを行います。

var pg = require("pg");
var Promise = require("bluebird");

Object.keys(pg).forEach(function(key) {
    var Class = pg[key];
    if (typeof Class === "function") {
        Promise.promisifyAll(Class.prototype);
        Promise.promisifyAll(Class);
    }
})
Promise.promisifyAll(pg);

後で、最初から promise を使用するように設計されているかのように pg モジュールを使用できます。

// Later
// Don't even need to require bluebird here
var pg = require("pg");
// Note how it's the pg API but with *Async suffix
pg.connectAsync(...).spread(function(connection, release) {
     return connection.queryAsync("...")
         .then(function(result) {
            console.log("rows", result.rows);
         })
         .finally(function() {
            // Creating a superfluous anonymous function cos I am
            // unsure of your JS skill level
            release();
         });
});
于 2014-05-27T06:38:51.637 に答える
0

ペトカ・アントノフのソリューションを少し変更することをお勧めします

var Promise = require('bluebird');
var pg = require('pg');
Object.keys(pg).forEach(function (key) {
  var Cls = null;
  try {
    Cls = pg[key];
    if (typeof Cls === 'function') {
      Promise.promisifyAll(Cls.prototype);
      Promise.promisifyAll(Cls);
    }
  } catch (e) {
    console.log(e);
  }
});
Promise.promisifyAll(pg);

アクセスしようとしたときに再実行できるため、ここではブロック'pg[key]にまとめられていますtry-catchpg[key]errorpg['native']

于 2016-02-25T15:31:31.777 に答える