fabio286/antares
1
1
Fork 0
mirror of https://github.com/Fabio286/antares.git synced 2025-06-05 21:59:22 +02:00
Code Issues Releases Wiki Activity

refactor: ipc handlers ts refactor

Browse Source
This commit is contained in:
Fabio Di Stasio
2022-04-15 14:56:13 +02:00
parent 5e2ad8c377
commit 6adc93e1cd
20 changed files with 219 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -720,7 +720,13 @@ export class MySQLClient extends AntaresCore {
}
async getDatabaseCollation (params: { database: string }) {
return await this.raw(`SELECT \`DEFAULT_COLLATION_NAME\` FROM \`information_schema\`.\`SCHEMATA\` WHERE \`SCHEMA_NAME\`='${params.database}'`);
let collation: string;
const { rows: collaitons } = await this.raw<antares.QueryResult<{DEFAULT_COLLATION_NAME: string}>>(`SELECT \`DEFAULT_COLLATION_NAME\` FROM \`information_schema\`.\`SCHEMATA\` WHERE \`SCHEMA_NAME\`='${params.database}'`);
if (collaitons.length)
collation = collaitons[0].DEFAULT_COLLATION_NAME;
return collation;
}
async createTable (params: antares.CreateTableParams) {
@ -1496,10 +1502,10 @@ export class MySQLClient extends AntaresCore {
const orderByRaw = orderByArray.length ? `ORDER BY ${orderByArray.join(', ')} ` : '';
// LIMIT
const limitRaw = this._query.limit.length ? `LIMIT ${this._query.limit.join(', ')} ` : '';
const limitRaw = this._query.limit ? `LIMIT ${this._query.limit} ` : '';
// OFFSET
const offsetRaw = this._query.offset.length ? `OFFSET ${this._query.offset.join(', ')} ` : '';
const offsetRaw = this._query.offset ? `OFFSET ${this._query.offset} ` : '';
return `${selectRaw}${updateRaw ? 'UPDATE' : ''}${insertRaw ? 'INSERT ' : ''}${this._query.delete ? 'DELETE ' : ''}${fromRaw}${updateRaw}${whereRaw}${groupByRaw}${orderByRaw}${limitRaw}${offsetRaw}${insertRaw}`;
}