我正在编写一个 nodejs 应用程序并想使用连接池。
但是,以下应用程序不会终止 - 尽管我希望它在调用 connection.end()
如果我使用一个连接而不是池,应用程序工作得很好。我需要以某种方式终止池吗?
使用的库:https://github.com/felixge/node-mysql
node.js 版本:Ubuntu 上为 0.10.4
var mysql = require('mysql');
var pool = mysql.createPool({
host : 'example.org',
user : 'myuser',
password : 'youbet',
database : 'notrevealingdetails',
insecureAuth: true
});
function getCampaignData(callback)
{
pool.getConnection(function(err, connection) {
if(err) throw err;
connection.query(
'SELECT cam.id, cam.name AS campaign_name, cam.subdomain, usr.email, usr.display_name AS user_displayname ' +
'FROM campaigns AS cam INNER JOIN users AS usr ON usr.id = cam.user_id ' +
'WHERE cam.state=2',
function(err, rows) {
callback(err, rows,connection);
//console.log('called end()');
}); // callback function for connection.query
}); // end pool.GetConnection
}
getCampaignData(function(err, rows, connection) {
if (err) throw err;
connection.end();
console.log("I expect my app to terminate");
});
最佳答案
我遇到了同样的问题,但是查看源代码 https://github.com/felixge/node-mysql/blob/master/lib/Pool.js 我发现该池,至少在其当前实现中,有一个 end() 方法,该方法会在所有连接上调用 end()。
它还接受一个回调函数,在所有连接实际结束后(或每当发生错误时)调用。
pool.end(function (err) {
if (err) console.error("An error occurred: " + err);
else console.log("My app terminated");
});
关于mysql - 应用程序不会以 MySQL 池终止,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/16741749/