如何promisify你自己的JavaScript API使用另一个promisified API与蓝鸟？

Question

我正在为此苦苦挣扎。我想在节点中的数据库驱动模块上构建一个抽象层。

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

然后我自己的js文件中我想换行查询，像这样：我已经通过执行以下操作promisified驱动模块

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

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

我怎样才能promisify（使用蓝鸟），所以我的查询函数也是promisified并返回一个承诺或可以吗？

更新：

我想也可以promisified我的包装方法，使用户能够做这样的事情：

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

我敢肯定，这是行不通的代码，只需试图传达这个想法。此外，此示例仅显示一个查询，并且不显示提交方法，该方法也是包装的一部分。有人能告诉我一个例子，使用承诺做一个以上的查询的整个交易，然后如果没有错误，则提交'提交'？

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