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);
     })
 }