Made database.js wrapper use connection pool

Using a connection pool instead of a single @$*%^_!# connection increased the throughput tremendously and fixed the problem with the server crashing due to server disconnects, reducing downtime. Why was the latter issue even unfixed?

1 files changed, 17 insertions, 8 deletions

diff --git a/database.js b/database.js
index 30396fe..d8e2d92 100644
--- a/database.js
+++ b/database.js
@@ -2,15 +2,21 @@ const mysql = require("mysql2");
 
 class Database
 {
-	constructor(credentials)
+	constructor(credentials, connectionLimit=8)
 	{
-		this.connection = mysql.createConnection(credentials);
+		this.pool = mysql.createPool({
+			connectionLimit: connectionLimit,
+			host: credentials.host,
+			user: credentials.user,
+			password: credentials.password,
+			database: credentials.database
+		});
 	}
 	query(query, values)
 	{
 		return new Promise((resolve, reject) =>
 		{
-			this.connection.query(query, values, (err, res, fields) =>
+			this.pool.query(query, values, (err, res, fields) =>
 			{
 				if (err) reject(err);
 				resolve(res);
@@ -21,10 +27,13 @@ class Database
 	{
 		return new Promise((resolve, reject) =>
 		{
-			this.connection.execute(query, values, (err, res, fields) =>
-			{
+			this.pool.getConnection((err, connection) => {
 				if (err) reject(err);
-				resolve(res);
+				connection.execute(query, values, (err, res, fields) => {
+					connection.release();
+					if (err) reject(err);
+					resolve(res);
+				})
 			});
 		});
 
@@ -33,7 +42,7 @@ class Database
 	{
 		return new Promise((resolve, reject) =>
 		{
-			this.connection.query(query, (err, res, fields) =>
+			this.pool.query(query, (err, res, fields) =>
 			{
 				if (err)
 					reject(err)
@@ -45,7 +54,7 @@ class Database
 	{
 		return new Promise((resolve, reject) =>
 		{
-			this.connection.end(err =>
+			this.pool.end(err =>
 			{
 				if (err) reject(err);
 				resolve();