From 860977a444cb8fc464b4f15df8b7c4881f3d5fa4 Mon Sep 17 00:00:00 2001
From: Vortrex <3858226+VortrexFTW@users.noreply.github.com>
Date: Sun, 9 Jan 2022 05:25:22 -0600
Subject: [PATCH] Move database stuff to natives

---
 scripts/server/database.js | 225 -------------------------------------
 1 file changed, 225 deletions(-)

diff --git a/scripts/server/database.js b/scripts/server/database.js
index 28ab48ac..00bfeac8 100644
--- a/scripts/server/database.js
+++ b/scripts/server/database.js
@@ -21,228 +21,3 @@ function initDatabaseScript() {
 
 // ===========================================================================
 
-function connectToDatabase() {
-	if(databaseConfig.usePersistentConnection) {
-		if(persistentDatabaseConnection == null) {
-			logToConsole(LOG_DEBUG, "[VRR.Database] Initializing database connection ...");
-			persistentDatabaseConnection = module.mysql.connect(databaseConfig.host, databaseConfig.user, databaseConfig.pass, databaseConfig.name, databaseConfig.port);
-			if(persistentDatabaseConnection.error) {
-				console.warn("[VRR.Database] Database connection error: " + toString(persistentDatabaseConnection.error));
-				persistentDatabaseConnection = null;
-				return false;
-			}
-
-			logToConsole(LOG_DEBUG, "[VRR.Database] Database connection successful!");
-			return persistentDatabaseConnection;
-		} else {
-			logToConsole(LOG_DEBUG, "[VRR.Database] Using existing database connection.");
-			return persistentDatabaseConnection;
-		}
-	} else {
-		let databaseConnection = module.mysql.connect(databaseConfig.host, databaseConfig.user, databaseConfig.pass, databaseConfig.name, databaseConfig.port);
-		if(databaseConnection.error) {
-			console.warn("[VRR.Database] Database connection error: " + toString(persistentDatabaseConnection.error));
-			return false;
-		} else {
-			return databaseConnection;
-		}
-	}
-}
-
-// ===========================================================================
-
-function disconnectFromDatabase(dbConnection) {
-	if(!databaseConfig.usePersistentConnection) {
-		try {
-			dbConnection.close();
-			logToConsole(LOG_DEBUG, `[VRR.Database] Database connection closed successfully`);
-		} catch(error) {
-			logToConsole(LOG_ERROR, `[VRR.Database] Database connection could not be closed! (Error: ${error})`);
-		}
-	}
-	return true;
-}
-
-// ===========================================================================
-
-function queryDatabase(dbConnection, queryString) {
-	logToConsole(LOG_DEBUG, `[VRR.Database] Query string: ${queryString}`);
-	return dbConnection.query(queryString);
-}
-
-// ===========================================================================
-
-function escapeDatabaseString(dbConnection, unsafeString = "") {
-	if(!dbConnection) {
-		dbConnection = connectToDatabase();
-	}
-
-	if(typeof unsafeString == "string") {
-		return dbConnection.escapeString(unsafeString);
-	}
-	return unsafeString;
-}
-
-// ===========================================================================
-
-function getDatabaseInsertId(dbConnection) {
-	return dbConnection.insertId;
-}
-
-// ===========================================================================
-
-function getQueryNumRows(dbQuery) {
-	return dbQuery.numRows;
-}
-
-// ===========================================================================
-
-function getDatabaseError(dbConnection) {
-	return dbConnection.error;
-}
-
-// ===========================================================================
-
-function freeDatabaseQuery(dbQuery) {
-	if(dbQuery != null) {
-		dbQuery.free();
-	}
-	return;
-}
-
-// ===========================================================================
-
-function fetchQueryAssoc(dbQuery) {
-	return dbQuery.fetchAssoc();
-}
-
-// ===========================================================================
-
-function quickDatabaseQuery(queryString) {
-	let dbConnection = connectToDatabase();
-	let insertId = 0;
-	if(dbConnection) {
-		//logToConsole(LOG_DEBUG, `[VRR.Database] Query string: ${queryString}`);
-		let dbQuery = queryDatabase(dbConnection, queryString);
-		if(getDatabaseInsertId(dbConnection)) {
-			insertId = getDatabaseInsertId(dbConnection);
-			logToConsole(LOG_DEBUG, `[VRR.Database] Query returned insert id ${insertId}`);
-		}
-
-		if(dbQuery) {
-			try {
-				freeDatabaseQuery(dbQuery);
-				logToConsole(LOG_DEBUG, `[VRR.Database] Query result free'd successfully`);
-			} catch(error) {
-				logToConsole(LOG_ERROR, `[VRR.Database] Query result could not be free'd! (Error: ${error})`);
-			}
-		}
-
-		disconnectFromDatabase(dbConnection);
-
-		if(insertId != 0) {
-			return insertId;
-		}
-
-		return true;
-	}
-	return false;
-}
-
-// ===========================================================================
-
-function executeDatabaseQueryCommand(command, params, client) {
-	if(areParamsEmpty(params)) {
-		messagePlayerSyntax(client, getCommandSyntaxText(command));
-		return false;
-	}
-
-	if(!targetClient) {
-		messagePlayerError(client, "That player was not found!");
-		return false;
-	}
-
-	if(targetCode == "") {
-		messagePlayerError(client, "You didn't enter any code!");
-		return false;
-	}
-
-	let success = quickDatabaseQuery(params);
-
-	if(!success) {
-		messagePlayerAlert(client, `Database query failed to execute: {ALTCOLOUR}${query}`);
-	} else if(typeof success != "boolean") {
-		messagePlayeSuccess(client, `Database query successful: {ALTCOLOUR}${query}`);
-		messagePlayerInfo(client, `Returns: ${success}`);
-	} else {
-		messagePlayerSuccess(client, `Database query successful: {ALTCOLOUR}${query}`);
-	}
-	return true;
-}
-
-// ===========================================================================
-
-function setConstantsAsGlobalVariablesInDatabase() {
-	let dbConnection = connectToDatabase();
-	let entries = Object.entries(global);
-	for(let i in entries) {
-		logToConsole(LOG_DEBUG, `[VRR.Database] Checking entry ${i} (${entries[i]})`);
-		if(toString(i).slice(0, 3).indexOf("VRR_") != -1) {
-			logToConsole(LOG_DEBUG, `[VRR.Database] Adding ${i} (${entries[i]}) to database global variables`);
-		}
-	}
-}
-
-// ===========================================================================
-
-function loadDatabaseConfiguration() {
-	let databaseConfigFile = loadTextFile("config/database.json");
-	return JSON.parse(databaseConfigFile);
-}
-
-// ===========================================================================
-
-function createDatabaseInsertQuery(tableName, data) {
-	let fields = [];
-	let values = [];
-
-	for(let i in data) {
-		if(data[i][1] != "undefined" && data[i][1] != NaN && data[i][0] != 'NaN') {
-			if(data[i][1] != "undefined" && data[i][1] != NaN && data[i][1] != 'NaN') {
-				fields.push(data[i][0]);
-
-				if(typeof data[i][1] == "string") {
-					values.push(`'${data[i][1]}'`);
-				} else {
-					values.push(data[i][1]);
-				}
-			}
-		}
-	}
-
-	let queryString = `INSERT INTO ${tableName} (${fields.join(", ")}) VALUES (${values.join(", ")})`;
-	return queryString;
-}
-
-// ===========================================================================
-
-function createDatabaseUpdateQuery(tableName, data, whereClause) {
-	let values = [];
-
-	for(let i in data) {
-		if(data[i][0] != "undefined" && data[i][0] != NaN && data[i][0] != 'NaN') {
-			if(data[i][1] != "undefined" && data[i][1] != NaN && data[i][1] != 'NaN') {
-				if(typeof data[i][1] == "string") {
-					values.push(`${data[i][0]}='${data[i][1]}'`);
-				} else {
-					values.push(`${data[i][0]}=${data[i][1]}`);
-				}
-			}
-		}
-	}
-
-	let queryString = `UPDATE ${tableName} SET ${values.join(", ")} WHERE ${whereClause}`;
-	return queryString;
-}
-
-// ===========================================================================
\ No newline at end of file