Commit a9b0353c authored by Rosanny Sihombing's avatar Rosanny Sihombing
Browse files

Merge branch 'MLAB-566' into 'testing'

using connection pools

See merge request !115
parents 55458af0 4253099f
Pipeline #4843 passed with stage
in 30 seconds
...@@ -4,59 +4,34 @@ var env = process.env.NODE_ENV || 'testing' ...@@ -4,59 +4,34 @@ var env = process.env.NODE_ENV || 'testing'
const config = require('./config')[env] const config = require('./config')[env]
// ==== USER ACOOUNT DB CONNECTION ==== // ==== USER ACOOUNT DB CONNECTION ====
var userConnection = mysql.createConnection({ const userConnection = mysql.createPool({
host: config.database.host, host: config.database.host,
user: config.database.user, user: config.database.user,
password: config.database.password, password: config.database.password,
port: config.database.port, port: config.database.port,
database: config.database.dbUser, database: config.database.dbUser,
multipleStatements: true waitForConnections: true,
}) connectionLimit: 10,
queueLimit: 0
});
userConnection.connect(function(err) {
if (err) throw err
})
userConnection.query('USE '+config.database.dbUser) userConnection.query('USE '+config.database.dbUser)
// ALTERNATIVE approach: close db connection manually after every query
/*
var dbconn = function dbconn(query, values, next) {
var connection = mysql.createConnection({
host: config.database.host,
user: config.database.user,
password: config.database.password,
port: config.database.port,
database: config.database.db
})
connection.connect(function(err) {
if (err) throw err;
})
connection.query(query, values, function(err) {
connection.end(); // close the connection
if (err) {
throw err;
}
// Execute the callback
next.apply(this, arguments);
});
}
*/
// ==== PROJECT DB CONNECTION ==== // ==== PROJECT DB CONNECTION ====
var projectConnection = mysql.createConnection({ const projectConnection = mysql.createPool({
host: config.database.host_project, host: config.database.host_project,
user: config.database.user, user: config.database.user,
password: config.database.password, password: config.database.password,
port: config.database.port, port: config.database.port,
database: config.database.dbProject database: config.database.dbProject,
}) waitForConnections: true,
connectionLimit: 10,
queueLimit: 0
});
projectConnection.connect(function(err) {
if (err) throw err
})
projectConnection.query('USE '+config.database.dbProject) projectConnection.query('USE '+config.database.dbProject)
var connection = { const connection = {
user: userConnection, user: userConnection,
project: projectConnection project: projectConnection
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment