Skip to content
This repository was archived by the owner on Jul 14, 2020. It is now read-only.

Commit 00d9b5a

Browse files
GHMattiGHMatti
GHMatti
authored and
GHMatti
committed
avoid doubly throwing the error
1 parent aaa825a commit 00d9b5a

File tree

2 files changed

+13
-18
lines changed

2 files changed

+13
-18
lines changed

mysql-async.js

+12-15
Original file line numberDiff line numberDiff line change
@@ -5100,15 +5100,15 @@ global.exports('mysql_execute', (query, parameters, callback) => {
51005100
const sql = prepareQuery(query, parameters);
51015101
mysql.execute({ sql, typeCast }, invokingResource).then((result) => {
51025102
safeInvoke(callback, (result) ? result.affectedRows : 0);
5103-
});
5103+
}).catch(() => {});
51045104
});
51055105

51065106
global.exports('mysql_fetch_all', (query, parameters, callback) => {
51075107
const invokingResource = global.GetInvokingResource();
51085108
const sql = prepareQuery(query, parameters);
51095109
mysql.execute({ sql, typeCast }, invokingResource).then((result) => {
51105110
safeInvoke(callback, result);
5111-
});
5111+
}).catch(() => {});
51125112
});
51135113

51145114
global.exports('mysql_fetch_scalar', (query, parameters, callback) => {
@@ -5124,10 +5124,12 @@ global.exports('mysql_insert', (query, parameters, callback) => {
51245124
const sql = prepareQuery(query, parameters);
51255125
mysql.execute({ sql, typeCast }, invokingResource).then((result) => {
51265126
safeInvoke(callback, (result) ? result.insertId : 0);
5127-
});
5127+
}).catch(() => {});
51285128
});
51295129

51305130
let isReady = false;
5131+
global.exports('is_ready', () => isReady);
5132+
51315133
global.on('onServerResourceStart', (resourcename) => {
51325134
if (resourcename === 'mysql-async') {
51335135
const trace = global.GetConvarInt('mysql_debug', 0);
@@ -5140,16 +5142,13 @@ global.on('onServerResourceStart', (resourcename) => {
51405142
const connectionString = global.GetConvar('mysql_connection_string', 'Empty');
51415143
if (connectionString === 'Empty') {
51425144
logger.error('Empty mysql_connection_string detected.');
5143-
throw new Error('Empty mysql_connection_string detected.');
5144-
}
5145-
config = parseSettings(connectionString);
5145+
} else {
5146+
config = parseSettings(connectionString);
51465147

5147-
mysql = new MySQL(config, logger, profiler);
5148-
global.emit('onMySQLReady'); // avoid ESX bugs
5149-
isReady = true;
5150-
}
5151-
if (isReady) {
5152-
global.emit('MySQLReady'); // avoid ESX bugs
5148+
mysql = new MySQL(config, logger, profiler);
5149+
global.emit('onMySQLReady'); // avoid old ESX bugs
5150+
isReady = true;
5151+
}
51535152
}
51545153
});
51555154

@@ -5222,9 +5221,7 @@ class MySQL {
52225221
if (error) reject(error);
52235222
resolve(result);
52245223
});
5225-
});
5226-
5227-
queryPromise.catch((error) => {
5224+
}).catch((error) => {
52285225
this.logger.error(`[ERROR] [MySQL] [${invokingResource}] An error happens on MySQL for query "${sql.sql}": ${error.message}`);
52295226
});
52305227

src/server/mysql.js

+1-3
Original file line numberDiff line numberDiff line change
@@ -53,9 +53,7 @@ class MySQL {
5353
if (error) reject(error);
5454
resolve(result);
5555
});
56-
});
57-
58-
queryPromise.catch((error) => {
56+
}).catch((error) => {
5957
this.logger.error(`[ERROR] [MySQL] [${invokingResource}] An error happens on MySQL for query "${sql.sql}": ${error.message}`);
6058
});
6159

0 commit comments

Comments
 (0)