hamyack/GTA4RP
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add support for non-persistent db conn

Browse Source
This commit is contained in:
Vortrex
2021-08-24 19:53:46 -05:00
parent 82a4f8285c
commit a9f22880e7
1 changed files with 22 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
scripts/server/database.js
View File

@@ -22,20 +22,30 @@ function initDatabaseScript() {
// =========================================================================== // ===========================================================================
function connectToDatabase() { function connectToDatabase() {
if(persistentDatabaseConnection == null) { if(databaseConfig.usePersistentConnection) {
logToConsole(LOG_DEBUG, "[VRR.Database] Initializing database connection ..."); if(persistentDatabaseConnection == null) {
persistentDatabaseConnection = module.mysql.connect(databaseConfig.host, databaseConfig.user, databaseConfig.pass, databaseConfig.name, databaseConfig.port); logToConsole(LOG_DEBUG, "[VRR.Database] Initializing database connection ...");
if(persistentDatabaseConnection.error) { persistentDatabaseConnection = module.mysql.connect(databaseConfig.host, databaseConfig.user, databaseConfig.pass, databaseConfig.name, databaseConfig.port);
console.warn("[VRR.Database] Database connection error: " + toString(persistentDatabaseConnection.error)); if(persistentDatabaseConnection.error) {
persistentDatabaseConnection = null; console.warn("[VRR.Database] Database connection error: " + toString(persistentDatabaseConnection.error));
return false; persistentDatabaseConnection = null;
} return false;
}
logToConsole(LOG_DEBUG, "[VRR.Database] Database connection successful!"); logToConsole(LOG_DEBUG, "[VRR.Database] Database connection successful!");
return persistentDatabaseConnection; return persistentDatabaseConnection;
} else {
logToConsole(LOG_DEBUG, "[VRR.Database] Using existing database connection.");
return persistentDatabaseConnection;
}
} else { } else {
logToConsole(LOG_DEBUG, "[VRR.Database] Using existing database connection."); let databaseConnection = module.mysql.connect(databaseConfig.host, databaseConfig.user, databaseConfig.pass, databaseConfig.name, databaseConfig.port);
return persistentDatabaseConnection; if(databaseConnection.error) {
console.warn("[VRR.Database] Database connection error: " + toString(persistentDatabaseConnection.error));
return false;
} else {
return databaseConnection;
}
} }
} }