logan/Emmelia-Link-Flayer-Rewrite
1
0
Fork 0
Code Issues 6 Pull Requests Packages Projects 2 Releases Wiki Activity

Each query will open and close it's own connection

Browse Source 
logan/Emmelia-Link-Flayer-Rewrite#2
This commit is contained in:
Logan Cusano
2023-03-11 00:03:05 -05:00
parent 6cccc86d90
commit 6b7e6ccae1
1 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
libStorage.js
View File

@@ -16,14 +16,6 @@ const accountsTable = process.env.DB_ACCOUNTS_TABLE;
const transactionsTable = process.env.DB_TRANSACTIONS_TABLE; const transactionsTable = process.env.DB_TRANSACTIONS_TABLE;
const pricingTable = process.env.DB_PRICING_TABLE; const pricingTable = process.env.DB_PRICING_TABLE;
var connection = mysql.createPool({
host: process.env.DB_HOST,
user: process.env.DB_USER,
password: process.env.DB_PASS,
database: process.env.DB_NAME,
connectionLimit: 10
});
// Helper Functions // Helper Functions
// Function to run and handle SQL errors // Function to run and handle SQL errors
function runSQL(sqlQuery, callback = (err, rows) => { function runSQL(sqlQuery, callback = (err, rows) => {
@@ -31,12 +23,19 @@ function runSQL(sqlQuery, callback = (err, rows) => {
throw err; throw err;
}) { }) {
// Start the MySQL Connection // Start the MySQL Connection
var connection = mysql.createConnection({
host: process.env.DB_HOST,
user: process.env.DB_USER,
password: process.env.DB_PASS,
database: process.env.DB_NAME
});
connection.query(sqlQuery, (err, rows) => { connection.query(sqlQuery, (err, rows) => {
if (err) { if (err) {
log.ERROR("SQL Error:", err) log.ERROR("SQL Error:", err)
return callback(err, undefined); return callback(err, undefined);
} }
log.VERBOSE(`SQL result for query '${sqlQuery}':`, rows); log.VERBOSE(`SQL result for query '${sqlQuery}':`, rows);
connection.end();
return callback(undefined, rows); return callback(undefined, rows);
}) })
} }