fabio286/antares
1
1
Fork 0
mirror of https://github.com/Fabio286/antares.git synced 2025-03-10 08:20:06 +01:00
Code Issues Releases Wiki Activity

fix: some issues related to previous commit

Browse Source
This commit is contained in:
Fabio Di Stasio 2024-02-12 18:30:07 +01:00
parent 876d5ea481
commit 259d051a21
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/libs/clients/MySQLClient.ts
View File

@ -260,11 +260,11 @@ export class MySQLClient extends BaseClient {
return connection; return connection;
} }
private async getConnection (args: antares.QueryParams, retry?: boolean): Promise<mysql.Pool | mysql.PoolConnection | mysql.Connection> { async getConnection (args?: antares.QueryParams, retry?: boolean): Promise<mysql.Pool | mysql.PoolConnection | mysql.Connection> {
let connection; let connection;
try { try {
if (!args.autocommit && args.tabUid) { // autocommit OFF if (args && !args.autocommit && args.tabUid) { // autocommit OFF
if (this._connectionsToCommit.has(args.tabUid)) if (this._connectionsToCommit.has(args.tabUid))
connection = this._connectionsToCommit.get(args.tabUid); connection = this._connectionsToCommit.get(args.tabUid);
else { else {
@ -276,12 +276,12 @@ export class MySQLClient extends BaseClient {
else// autocommit ON else// autocommit ON
connection = this.isPool ? await (this._connection as mysql.Pool).getConnection() : this._connection; connection = this.isPool ? await (this._connection as mysql.Pool).getConnection() : this._connection;
if (args.tabUid && this.isPool) { if (args && args.tabUid && this.isPool) {
// eslint-disable-next-line @typescript-eslint/no-explicit-any // eslint-disable-next-line @typescript-eslint/no-explicit-any
this._runningConnections.set(args.tabUid, (connection as any).connection.connectionId); this._runningConnections.set(args.tabUid, (connection as any).connection.connectionId);
} }
if (args.schema) if (args && args.schema)
await connection.query(`USE \`${args.schema}\``); await connection.query(`USE \`${args.schema}\``);
return connection; return connection;