如何promisify 你自己的javascript api，它使用另一个promisified api 和Bluebird？

Question

我有点挣扎。我想在节点中的数据库驱动程序模块上构建一个抽象层。我已经通过执行以下操作来承诺驱动程序模块：

var sql = Promise.promisifyAll(require('sql-driver'));

然后在我自己的 js 文件中，我想像这样包装查询：

function query(queryString, transaction) {
   sql.connectAsync(config).then(function() {

      var req = new sql.Request(transaction);
      req.queryAsync(queryString).then(function(resultSet)) {
          console.log(resultSet);
      });
   });
}

我怎样才能承诺（使用 bluebird），以便我的查询函数也被承诺并返回承诺或 thenable？

更新：

我希望我的包装方法也被承诺，以便用户可以执行以下操作：

var myDbWrapper = require('my-db-wapper');
function getData() {
    myDbWrapper.startTransaction()
    .then(function(transaction) {
        return myDbWrapper.query('select 1 as number', transaction);
     })
    .then(function(resultSet) {
        console.log(resultSet);
     }).
    .catch(function(e) {
        console.error(e);
    });
}

我确定这不是工作代码，只是试图传达这个想法。另外，这个例子只显示了一个查询，没有显示 commit 方法，它也是包装器的一部分。有人可以给我看一个例子吗？使用承诺来完成一个具有多个查询的整个事务，然后如果没有错误则“提交”？

更新 2：

idbehold 下面的示例不允许我做这种事情，假设我们此时不关心交易，只是一个简单的查询：

myDbWrapper.query(queryString, undefined)
.then(function(recordSet) {
   console.log(recordSet);
})
.catch(function(err) {
   console.error(err);
});

我怎样才能让我的查询方法以这种方式工作？

更新 3：

我找到了答案。见下文。

Answer 1

只要返回那个承诺：

function query(queryString, transaction) {
   return sql.connectAsync(config).then(function() {
      var req = new sql.Request(transaction);
      return req.queryAsync(queryString);
   }).then(function(resultSet)) {        // You don't actually
      console.log(resultSet);            // need this this part
      return resultSet;                  // unless you need to log
   });
}

Answer 2

好的，我想通了，它就在我面前。这是我对 Promises 缺乏了解。大多数关于返回承诺的回答都是正确的，但我不应该返回我正在使用的承诺，我需要像这样创建一个新的承诺：

function query (queryString, transaction) {
   return new Promise(function(resolve, reject) {
        var req = new sql.Request(transaction);
        req.queryAsync(queryString).then(function(resultSet) {
            resolve(resultSet);
        })
        .catch(function(err) {
            reject(err);
        });
    });
}

编辑，不创建新的承诺：

function query (queryString, transaction) {
  var req = new sql.Request(transaction);
  return req.queryAsync(queryString);
}