dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-27 07:56:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: build enable/disable sql on frontend

Browse Source
This commit is contained in:
Nybkox
2025-01-03 22:57:33 +01:00
parent e73356c8da
commit 1be73d8a4c
5 changed files with 5 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
integration-tests/engines.js
View File

@@ -147,8 +147,6 @@ const mysqlEngine = {
pureName: 'obj1', pureName: 'obj1',
status: 'ENABLED', status: 'ENABLED',
eventType: 'RECURRING', eventType: 'RECURRING',
enableSql: 'ALTER EVENT obj1 ENABLE;',
disableSql: 'ALTER EVENT obj1 DISABLE;',
intervalValue: '1', intervalValue: '1',
intervalField: 'HOUR', intervalField: 'HOUR',
}, },
@@ -161,8 +159,6 @@ const mysqlEngine = {
pureName: 'obj1', pureName: 'obj1',
status: 'ENABLED', status: 'ENABLED',
eventType: 'ONE TIME', eventType: 'ONE TIME',
enableSql: 'ALTER EVENT obj1 ENABLE;',
disableSql: 'ALTER EVENT obj1 DISABLE;',
}, },
}, },
], ],

2
packages/types/dbinfo.d.ts vendored
View File

@@ -167,8 +167,6 @@ export interface SchedulerEventInfo extends SqlObjectInfo {
intervalField: string; intervalField: string;
starts: string; starts: string;
executeAt: string; executeAt: string;
enableSql: string;
disableSql: string;
} }
export interface SchemaInfo { export interface SchemaInfo {

8
packages/web/src/appobj/DatabaseObjectAppObject.svelte
View File

@@ -498,10 +498,10 @@
); );
}); });
} else if (menu.isDisableEvent) { } else if (menu.isDisableEvent) {
const { conid, database, disableSql } = data; const { conid, database, pureName } = data;
const driver = await getDriver(); const driver = await getDriver();
const dmp = driver.createDumper(); const dmp = driver.createDumper();
dmp.put(disableSql); dmp.put('^alter ^event %i ^disable', pureName);
const sql = dmp.s; const sql = dmp.s;
@@ -513,10 +513,10 @@
engine: driver.engine, engine: driver.engine,
}); });
} else if (menu.isEnableEvent) { } else if (menu.isEnableEvent) {
const { conid, database, enableSql } = data; const { conid, database, pureName } = data;
const driver = await getDriver(); const driver = await getDriver();
const dmp = driver.createDumper(); const dmp = driver.createDumper();
dmp.put(enableSql); dmp.put('^alter ^event %i ^enable', pureName);
const sql = dmp.s; const sql = dmp.s;

4
plugins/dbgate-plugin-mysql/src/backend/Analyser.js
View File

@@ -256,8 +256,6 @@ class Analyser extends DatabaseAnalyser {
contentHash: _.isDate(row.LAST_ALTERED) ? row.LAST_ALTERED.toISOString() : row.LAST_ALTERED, contentHash: _.isDate(row.LAST_ALTERED) ? row.LAST_ALTERED.toISOString() : row.LAST_ALTERED,
pureName: row.EVENT_NAME, pureName: row.EVENT_NAME,
createSql: row.CREATE_SQL, createSql: row.CREATE_SQL,
enableSql: row.ENABLE_SQL,
disableSql: row.DISABLE_SQL,
objectId: row.EVENT_NAME, objectId: row.EVENT_NAME,
intervalValue: row.INTERVAL_VALUE, intervalValue: row.INTERVAL_VALUE,
intervalField: row.INTERVAL_FIELD, intervalField: row.INTERVAL_FIELD,
@@ -310,8 +308,6 @@ class Analyser extends DatabaseAnalyser {
contentHash: _.isDate(row.LAST_ALTERED) ? row.LAST_ALTERED.toISOString() : row.LAST_ALTERED, contentHash: _.isDate(row.LAST_ALTERED) ? row.LAST_ALTERED.toISOString() : row.LAST_ALTERED,
pureName: row.EVENT_NAME, pureName: row.EVENT_NAME,
createSql: row.CREATE_SQL, createSql: row.CREATE_SQL,
enableSql: row.ENABLE_SQL,
disableSql: row.DISABLE_SQL,
objectId: row.EVENT_NAME, objectId: row.EVENT_NAME,
intervalValue: row.INTERVAL_VALUE, intervalValue: row.INTERVAL_VALUE,
intervalField: row.INTERVAL_FIELD, intervalField: row.INTERVAL_FIELD,

4
plugins/dbgate-plugin-mysql/src/backend/sql/schedulerEvents.js
View File

@@ -26,9 +26,7 @@ SELECT
END, END,
' DO ', ' DO ',
EVENT_DEFINITION EVENT_DEFINITION
) AS CREATE_SQL, ) AS CREATE_SQL
CONCAT('ALTER EVENT ', EVENT_NAME, ' DISABLE;') AS DISABLE_SQL,
CONCAT('ALTER EVENT ', EVENT_NAME, ' ENABLE;') AS ENABLE_SQL
FROM INFORMATION_SCHEMA.EVENTS FROM INFORMATION_SCHEMA.EVENTS
WHERE EVENT_SCHEMA = '#DATABASE#' AND EVENT_NAME =OBJECT_ID_CONDITION WHERE EVENT_SCHEMA = '#DATABASE#' AND EVENT_NAME =OBJECT_ID_CONDITION
`; `;