Chỉ để giúp một số người trong tương lai, điều này đã hiệu quả với tôi:
Tôi đã tạo tệp trình kết nối mysql có chứa nhóm:
// Load module
var mysql = require('mysql');
// Initialize pool
var pool = mysql.createPool({
connectionLimit : 10,
host : '127.0.0.1',
user : 'root',
password : 'root',
database : 'db_name',
debug : false
});
module.exports = pool;
Sau đó, bạn có thể chỉ cần đưa trình kết nối vào một tệp khác, hãy gọi nó là managementDB.js:
var pool = require('./mysqlConnector');
Và tạo một phương thức có thể gọi được như thế này:
exports.executeQuery=function(query,callback){
pool.getConnection(function(err,connection){
if (err) {
connection.release();
throw err;
}
connection.query(query,function(err,rows){
connection.release();
if(!err) {
callback(null, {rows: rows});
}
});
connection.on('error', function(err) {
throw err;
return;
});
});
}