sql - 将繁琐的连接作为参数传递
问题描述
我正在尝试使用利用 Tedious 库构建的一套简单的函数来访问 Microsoft SQL Server。这是我的“工具”文件:
'use strict';
const tedious = require('tedious');
const q = require('q');
var Connection = tedious.Connection;
var Request = tedious.Request;
module.exports = {
connectSQL : function(config) {
var connection = new Connection(config);
connection.on('connect', function(err) {
if (err) {
console.log('FAIL ON CONNECT');
console.log(err);
} else {
try {
/* ----- */
return connection;
} catch (err) {
console.log(err);
return;
}
}
});
connection.on('error', function(err) {
if (err) {
console.log('FAIL ON ERROR');
console.log(err);
} else {
console.log("Error called with no err object.");
}
});
},
executeSQL: function(connection, requestString) {
var results = [];
var request = new Request( requestString , function(err, data) {
if (err) {
console.log(err);
} else {
console.log( data );
}
});
request.on('row', function(row) {
//console.log(row);
results.push( row );
});
request.on('requestCompleted', function(){
console.log('Finished');
return results;
});
connection.execSql(request);
}
}
我在我的服务器文件中按如下方式调用这些函数。
const sqlTools = require('./sqlTools.js');
var connection = sqlTools.connectSQL(config);
sqlTools.executeSQL(connection, "select * from dbo.test");
但是,我收到错误“TypeError: Cannot read property 'execSql' of undefined”,即使我在调用函数 sqlTools.executeSQL 之前让程序休眠 10 秒(显然不理想)。
我可以通过在 sqlTools.connectSQL 函数(在“/* ----- */”处)调用请求来使其工作,但我想重新使用繁琐的连接来进行多次调用。有什么建议么?谢谢!
~~~~~~~编辑~~~~~~~~~~
在 akinjide 的帮助下,我能够实现回调,允许我对我的 SQL 数据库进行一次调用。但是,我正在努力履行后续电话的承诺。我改变了我的“工具”文件:
'use strict';
const tedious = require('tedious');
const q = require('q');
var Connection = tedious.Connection;
var Request = tedious.Request;
module.exports = {
connectSQL: function(config) {
var deferred = q.defer();
var connection = new Connection(config);
connection.on('connect', function(err) {
if (err) {
deferred.reject( err );
} else {
deferred.resolve( connection );
}
});
connection.on('error', function(err) {
deferred.reject(err);
});
return deferred.promise;
},
executeSQL: function(connection, requestString, callback) {
var results = [];
const request = new Request(requestString, function(err) {
callback(err);
});
request.on('row', function(row) {
results.push(row);
});
request.on('requestCompleted', function() {
console.log('request completed!');
callback(null, results);
});
connection.execSql(request);
}
}
我这样称呼这段代码......
var promise = sqlTools.connectSQL(config);
promise.then(function (connection) {
sqlTools.executeSQL(connection, "select * from dbo.test", function(err, results) {
if (err) {
console.log(err);
}
console.log(results);
});
}).catch(function (err) {
console.log(err);
}).then(function (connection) {
sqlTools.executeSQL(connection, "select * from dbo.test2", function(err, results) {
if (err) {
console.log(err);
}
console.log(results);
});
}).catch(function(err) {
console.log(err);
});
这将正确返回第一次调用的结果,但不幸的是,第二次调用返回此错误“TypeError:无法读取未定义的属性'execSql'”,因为它第二次无法识别连接。有什么建议么?
解决方案
更好的方法是将 node.js 回调样式函数作为参数传递给connectSQL
.
return
关键字在异步程序中不起作用。
'use strict';
const tedious = require('tedious');
const Connection = tedious.Connection;
const Request = tedious.Request;
module.exports = {
connectSQL: function(config, callback) {
const connection = new Connection(config);
connection.on('connect', function(err) {
if (err) {
callback(err);
} else {
callback(null, connection);
}
});
connection.on('error', function (err) {
callback(err);
});
},
executeSQL: function(connection, requestString, callback) {
let results = [];
const request = new Request(requestString, function(err) {
callback(err);
});
request.on('row', function(row) {
results.push(row);
});
request.on('requestCompleted', function(){
console.log('Finished');
callback(null, results);
});
connection.execSql(request);
}
}
然后你可以要求,使用sqlTools.connectSQL
传递两个参数config
和function(err, connection) {}
const sqlTools = require('./sqlTools');
sqlTools.connectSQL(config, function(err, connection) {
if (err) {
console.log('FAIL ON CONNECT');
console.log(err);
}
sqlTools.executeSQL(connection, "select * from dbo.test", function (err, results) {
if (err) {
console.log(err);
}
console.log(results);
});
});
推荐阅读
- mongodb - 如何使用官方 mongo-go-driver 从 mongo 文档中过滤字段
- ansible - VMWARE_GUEST:从模板创建 VM:创建虚拟机失败:无法访问虚拟机配置
- php - 为什么我在 laravel 中得到“不应静态调用非静态方法 App\Models\Category::products()”
- ios - iPhone 7 中没有出现导航栏
- javascript - 改变url动态JS
- javascript - 当我导入 jquery 库时,Chrome 抛出 ajaxSetup 不是一个函数?
- api - 起源 youtube api 无法在“DOMWindow”上执行“postMessage”:
- algorithm - 在 O(nlogm) 时间内计算两个未排序数组的并集和交集
- c++ - malloc() 可能导致内存泄漏
- c++ - 如何克服 Boost Spirit AST 混乱