ms sql资源管理使用bluebird promises

Question

我正在使用mssql模块使用节点连接到sql server数据库.Bluebird的功能类似于c#中的资源管理.它有一个'使用'方法,以避免使用try/catch/finall来处理资源.他们有pg和mysql的例子,但他们没有mssql的例子,它没有像pg和mysql那样创建连接.以下是如何使用它的示例:

using(getConnection(),
  fs.readFileAsync("file.sql", "utf8"), function(connection, fileContents) {
  return connection.query(fileContents);
}).then(function() {
  console.log("query successful and connection closed");
});

但是为了能够使用此方法,您需要创建一个描述如何关闭连接的连接方法.这是pg的一个例子:

function getSqlConnection(connectionString) {
   var close;
   return pg.connectAsync(connectionString).spread(function(client, done) {
      close = done;
      return client;
   }).disposer(function(client) {
      if (close) close(client);
   });
}

我使用mssql模块的问题是connect方法不返回像pg甚至mysql模块这样的连接对象.有谁能用mssql做到这一点？

更新1:

以下是我制作交易处理器的方法:

function getTransaction(connection) {
   return new Promise(function(resolve, reject) {
       var tx = sql.Transaction(connection);
       tx.beginAsync().then(function(err) {
           if(err) {
             tx = null;
             return reject(err);
           }
           return resolve(tx);
       });
   }).disposer(function(tx, promise) {
       if(promise.isFulfilled()) {
          return tx.commitAsync();
       }
       else {
          return tx.rollbackAsync();
       }
   });
}

它似乎有效,但不确定这是否有效.现在我需要弄清楚如何捕获查询错误.

这就是我在做交易的方式:

using(getConnection(), function(connection) {
   return using(getTransaction(connection), function(tx) {
          return query(queryString, tx).then(function() {
               console.log('first query in transaction completed.');
               console.log('starting second query in transaction.');
               return query(anotherQueryString, tx);
          });
   });
});

如果我将一个catch标记到外部'using',那么是否会捕获整个事务中的所有错误？

Answer 1

好问题,mssql有非常棘手的API(构造函数采取回调!)所以这是文档的好补充.

var Promise = require("bluebird");
var sql = Promise.promisifyAll(require("mssql"));
global.using = Promise.using;

function getConnection(config) {
    var connection;
    return new Promise(function(resolve, reject) 
        connection = new sql.Connection(config, function(err) {
            if (err) {
                connection = null;
                return reject(err);
            }
            resolve(connection);
        });
    }).disposer(function() {
      if (connection) connection.close();
   });
}

var config = {
    user: '...',
    password: '...',
    server: 'localhost',
    database: '...',
};

using(getConnection(config), function(connection) {
    var request = new sql.Request(connection);
    return request.queryAsync("select 1 as number").then(function(recordSet) {
        console.log("got record set", recordSet);
        return request.queryAsync("select 10 as number");
    });
}).then(function(recordSet) {
    console.log("got record set", recordSet);
})

要使用该事务,请尝试实现getTransaction,如:

function getTransaction(connection) {
  var tx = new sql.Transaction(connection);
  return tx.beginAsync().thenReturn(tx).disposer(function(tx, promise) {
    return promise.isFulfilled() ? tx.commitAsync() : tx.rollbackAsync();
  });
}

使用它像:

using(getConnection(), function(connection) {
  return using(getTransaction(connection), function(tx) {
    var request = new sql.Request(tx);
    return request.queryAsync("INSERT 1...").then(function() {
      return request.queryAsync("INSERT 2...");
    }).then(function() {
      return request.queryAsync("INSERT 3...");
    });
  });
});

错误处理:

using(getConnection(), function(connection) {
  return using(getTransaction(connection), function(tx) {
    var request = new sql.Request(tx);
    return request.queryAsync("INSERT...");
  });
}).catch(sql.TransactionError, function(e) {
  console.log("transaction failed", e);
}).catch(sql.ConnectionError, function(e) {
  console.log("connection failed", e);
}).catch(sql.RequestError, function(e) {
  console.log("invalid query", e);
});