2020-08-16 23:28:41 -07:00
|
|
|
const mysql = require("mysql2");
|
2020-04-22 11:51:36 -07:00
|
|
|
|
2020-09-19 04:39:08 -07:00
|
|
|
let globalDbs = new Map();
|
2020-04-22 15:53:59 -07:00
|
|
|
|
2020-09-02 03:49:58 -07:00
|
|
|
async function connectToDb({
|
2020-09-18 05:50:17 -07:00
|
|
|
host = "impress.openneo.net",
|
2020-09-02 03:49:58 -07:00
|
|
|
user = process.env["IMPRESS_MYSQL_USER"],
|
|
|
|
password = process.env["IMPRESS_MYSQL_PASSWORD"],
|
2020-09-18 05:50:17 -07:00
|
|
|
database = "openneo_impress",
|
2020-09-02 03:49:58 -07:00
|
|
|
} = {}) {
|
2020-09-19 04:39:08 -07:00
|
|
|
if (globalDbs.has(host)) {
|
|
|
|
return globalDbs.get(host);
|
2020-04-22 15:53:59 -07:00
|
|
|
}
|
|
|
|
|
2020-09-19 04:39:08 -07:00
|
|
|
const db = mysql
|
2020-08-16 23:28:41 -07:00
|
|
|
.createConnection({
|
2020-09-18 05:50:17 -07:00
|
|
|
host,
|
2020-09-02 03:49:58 -07:00
|
|
|
user,
|
|
|
|
password,
|
2020-09-18 05:50:17 -07:00
|
|
|
database,
|
2020-09-06 15:49:08 -07:00
|
|
|
multipleStatements: true,
|
2020-08-16 23:28:41 -07:00
|
|
|
})
|
|
|
|
// We upgrade to promises here, instead of using the mysql2/promise import,
|
|
|
|
// for compatibility with Honeycomb's automatic tracing.
|
|
|
|
.promise();
|
2020-04-22 11:51:36 -07:00
|
|
|
|
2020-09-19 04:39:08 -07:00
|
|
|
globalDbs.set(host, db);
|
|
|
|
|
|
|
|
return db;
|
2020-04-22 11:51:36 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
module.exports = connectToDb;
|