Move database stuff to natives
This commit is contained in:
Vortrex
@@ -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;
|
|
||||||
}
|
|
||||||
|
|
||||||
// ===========================================================================
|
|
||||||
Reference in New Issue
Block a user