diff --git a/packages/tools/src/SqlDumper.ts b/packages/tools/src/SqlDumper.ts index 3ec1572ae..04314dfc2 100644 --- a/packages/tools/src/SqlDumper.ts +++ b/packages/tools/src/SqlDumper.ts @@ -708,6 +708,8 @@ export class SqlDumper implements AlterProcessor { return 'TRIGGER'; case 'matviews': return 'MATERIALIZED VIEW'; + case 'schedulerEvents': + return 'EVENT'; } } @@ -785,10 +787,7 @@ export class SqlDumper implements AlterProcessor { } callableTemplate(func: CallableObjectInfo) { - this.put( - '^call %f(&>&n', - func, - ); + this.put('^call %f(&>&n', func); this.putCollection(',&n', func.parameters || [], param => { this.putRaw(param.parameterMode == 'IN' ? ':' + param.parameterName : param.parameterName); diff --git a/packages/tools/src/diffTools.ts b/packages/tools/src/diffTools.ts index 22cf09e7d..1bb7ee7d5 100644 --- a/packages/tools/src/diffTools.ts +++ b/packages/tools/src/diffTools.ts @@ -155,6 +155,7 @@ export function generateDbPairingId(db: DatabaseInfo): DatabaseInfo { procedures: db.procedures?.map(generateObjectPairingId), functions: db.functions?.map(generateObjectPairingId), triggers: db.triggers?.map(generateObjectPairingId), + schedulerEvents: db.schedulerEvents?.map(generateObjectPairingId), matviews: db.matviews?.map(generateObjectPairingId), }; } @@ -715,7 +716,15 @@ export function createAlterDatabasePlan( ): AlterPlan { 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] || []) { const newobj = (newDb[objectTypeField] || []).find(x => x.pairingId == oldobj.pairingId); if (objectTypeField == 'tables') {