repo-mirrors/dlsync
1
0
Fork 0
mirror of https://github.com/Snowflake-Labs/dlsync.git synced 2025-12-18 00:51:27 +00:00
Code Actions Packages Releases Activity

Updated parser to warn migration if no valid migration was found

Browse Source
This commit is contained in:
Ytbarek Hailu
2025-08-13 16:19:05 -07:00
parent 14b8b7087c
commit 0cc89cbe50
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
example_scripts/main/example_db/MAIN_SCHEMA/ALERTS/DISCOUNTS_ALERT.SQL
View File

@@ -1,6 +1,9 @@
---version: 0, author: DlSync
CREATE OR REPLACE ALERT ${EXAMPLE_DB}.${MAIN_SCHEMA}.DISCOUNTS_ALERT
SCHEDULE = '1 minute'
SCHEDULE = '600 minute'
IF( EXISTS(
SELECT DISCOUNT_RATE FROM ${EXAMPLE_DB}.${MAIN_SCHEMA}.DISCOUNTS WHERE DISCOUNT_RATE>0.1))
THEN
INSERT INTO DISCOUNT_RATE_EXCEEDED_HISTORY VALUES (current_timestamp());
INSERT INTO DISCOUNT_RATE_EXCEEDED_HISTORY VALUES (current_timestamp());
---rollback: DROP ALERT IF EXISTS ${EXAMPLE_DB}.${MAIN_SCHEMA}.DISCOUNTS_ALERT;
---verify: SHOW ALERTS LIKE 'DISCOUNTS_ALERT' IN SCHEMA ${EXAMPLE_DB}.${MAIN_SCHEMA};

3
src/main/java/com/snowflake/dlsync/parser/SqlTokenizer.java
View File

@@ -79,6 +79,9 @@ public class SqlTokenizer {
Set<Script> scripts = new HashSet<>();
if(objectType.isMigration()) {
List<Migration> migrations = SqlTokenizer.parseMigrationScripts(content);
if(migrations.isEmpty()) {
log.warn("Object type: {} is migration, but there are no migrations found in the file: {}", objectType, filePath);
}
for(Migration migration: migrations) {
MigrationScript script = ScriptFactory.getMigrationScript(database, schema, objectType, objectName, migration);
// Script script = new Script(database, schema, objectType, objectName, migration.getContent(), migration.getVersion(), migration.getAuthor(), migration.getRollback());