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

feat: add schedulerEvents to tools

Browse Source
This commit is contained in:
Nybkox
2025-01-03 15:02:03 +01:00
parent 0ffe2d8811
commit e73356c8da
2 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
packages/tools/src/SqlDumper.ts
View File

@@ -708,6 +708,8 @@ export class SqlDumper implements AlterProcessor {
return 'TRIGGER'; return 'TRIGGER';
case 'matviews': case 'matviews':
return 'MATERIALIZED VIEW'; return 'MATERIALIZED VIEW';
case 'schedulerEvents':
return 'EVENT';
} }
} }
@@ -785,10 +787,7 @@ export class SqlDumper implements AlterProcessor {
} }
callableTemplate(func: CallableObjectInfo) { callableTemplate(func: CallableObjectInfo) {
this.put( this.put('^call %f(&>&n', func);
'^call %f(&>&n',
func,
);
this.putCollection(',&n', func.parameters || [], param => { this.putCollection(',&n', func.parameters || [], param => {
this.putRaw(param.parameterMode == 'IN' ? ':' + param.parameterName : param.parameterName); this.putRaw(param.parameterMode == 'IN' ? ':' + param.parameterName : param.parameterName);

11
packages/tools/src/diffTools.ts
View File

@@ -155,6 +155,7 @@ export function generateDbPairingId(db: DatabaseInfo): DatabaseInfo {
procedures: db.procedures?.map(generateObjectPairingId), procedures: db.procedures?.map(generateObjectPairingId),
functions: db.functions?.map(generateObjectPairingId), functions: db.functions?.map(generateObjectPairingId),
triggers: db.triggers?.map(generateObjectPairingId), triggers: db.triggers?.map(generateObjectPairingId),
schedulerEvents: db.schedulerEvents?.map(generateObjectPairingId),
matviews: db.matviews?.map(generateObjectPairingId), matviews: db.matviews?.map(generateObjectPairingId),
}; };
} }
@@ -715,7 +716,15 @@ export function createAlterDatabasePlan(
): AlterPlan { ): AlterPlan {
const plan = new AlterPlan(wholeOldDb, wholeNewDb, driver.dialect, opts); const plan = new AlterPlan(wholeOldDb, wholeNewDb, driver.dialect, opts);
for (const objectTypeField of ['tables', 'views', 'procedures', 'matviews', 'functions', 'triggers']) { for (const objectTypeField of [
'tables',
'views',
'procedures',
'matviews',
'functions',
'triggers',
'schedulerEvents',
]) {
for (const oldobj of oldDb[objectTypeField] || []) { for (const oldobj of oldDb[objectTypeField] || []) {
const newobj = (newDb[objectTypeField] || []).find(x => x.pairingId == oldobj.pairingId); const newobj = (newDb[objectTypeField] || []).find(x => x.pairingId == oldobj.pairingId);
if (objectTypeField == 'tables') { if (objectTypeField == 'tables') {