From 6b7e6ccae1c7123e2d2905f39b721fc6717100be Mon Sep 17 00:00:00 2001
From: Logan Cusano <Logan@simplestepsolutions.com>
Date: Sat, 11 Mar 2023 00:03:05 -0500
Subject: [PATCH] Each query will open and close it's own connection

logan/Emmelia-Link-Flayer-Rewrite#2
---
 libStorage.js | 15 +++++++--------
 1 file changed, 7 insertions(+), 8 deletions(-)

diff --git a/libStorage.js b/libStorage.js
index 3ee75f0..a11c01c 100644
--- a/libStorage.js
+++ b/libStorage.js
@@ -16,14 +16,6 @@ const accountsTable = process.env.DB_ACCOUNTS_TABLE;
 const transactionsTable = process.env.DB_TRANSACTIONS_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
 // Function to run and handle SQL errors
 function runSQL(sqlQuery, callback = (err, rows) => {
@@ -31,12 +23,19 @@ function runSQL(sqlQuery, callback = (err, rows) => {
     throw err;
 }) {
      // 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) => {
         if (err) {
             log.ERROR("SQL Error:", err)
             return callback(err, undefined);
         } 
         log.VERBOSE(`SQL result for query '${sqlQuery}':`, rows);        
+        connection.end();
         return callback(undefined, rows);
     })
 }