public class org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest extends org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases { public void () { org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; specialinvoke v.()>(); return; } public void verifyUnitemporalDeltaNoDeleteIndNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { java.lang.String v, v, v, v; org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v, v; java.lang.Object v, v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging\" as stage WHERE ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (sink.\"digest\" <> stage.\"digest\")))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging\" as stage WHERE NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")))))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); virtualinvoke v.(v, "SELECT COUNT(*) as \"incomingRecordCount\" FROM \"mydb\".\"staging\" as stage", "SELECT COUNT(*) as \"rowsUpdated\" FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1", "SELECT 0 as \"rowsDeleted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) as \"rowsInserted\"", "SELECT 0 as \"rowsTerminated\""); return; } public void verifyUnitemporalDeltaNoDeleteIndNoDedupAllVersionsWithoutPerform(java.util.List, java.util.List) { java.util.Map v; boolean v, v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v, v, v, v, v, v, v, v; int v; java.lang.String v, v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: java.util.List; v := @parameter: java.util.List; v = ; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(0); v = virtualinvoke v.("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging\" as stage WHERE ((stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')) AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (sink.\"digest\" <> stage.\"digest\")))", v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(0); v = virtualinvoke v.("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging\" as stage WHERE ((stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')) AND (NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\"))))))", v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(1); v = virtualinvoke v.("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging\" as stage WHERE ((stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')) AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (sink.\"digest\" <> stage.\"digest\")))", v); v = interfaceinvoke v.(1); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(1); v = virtualinvoke v.("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging\" as stage WHERE ((stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')) AND (NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\"))))))", v); v = interfaceinvoke v.(1); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (2, v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(0); v = interfaceinvoke v.(0); v = virtualinvoke v.("SELECT COUNT(*) as \"incomingRecordCount\" FROM \"mydb\".\"staging\" as stage WHERE (stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')", v); virtualinvoke v.(v, v, "SELECT COUNT(*) as \"rowsUpdated\" FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1", "SELECT 0 as \"rowsDeleted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) as \"rowsInserted\"", "SELECT 0 as \"rowsTerminated\""); return; } public void verifyUnitemporalDeltaWithDeleteIndFilterDupsNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { java.util.Map v; java.lang.String v, v, v, v; boolean v; org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v; java.lang.Object v, v, v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND ((sink.\"digest\" <> stage.\"digest\") OR (stage.\"delete_indicator\" IN (\'yes\',\'1\',\'true\')))))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE (NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\"))))) AND (stage.\"delete_indicator\" NOT IN (\'yes\',\'1\',\'true\')))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"delete_indicator\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"delete_indicator\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\", stage.\"digest\", stage.\"delete_indicator\")", v); v = interfaceinvoke v.(); staticinvoke (v); virtualinvoke v.(v, "SELECT COUNT(*) as \"incomingRecordCount\" FROM \"mydb\".\"staging\" as stage", "SELECT COUNT(*) as \"rowsUpdated\" FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) AND (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE ((sink.\"id\" = sink.\"id\") AND (sink.\"name\" = sink.\"name\")) AND (sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))))", "SELECT 0 as \"rowsDeleted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) AND (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE ((sink.\"id\" = sink.\"id\") AND (sink.\"name\" = sink.\"name\")) AND (sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))))) as \"rowsInserted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1)-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) AND (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE ((sink.\"id\" = sink.\"id\") AND (sink.\"name\" = sink.\"name\")) AND (sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))))) as \"rowsTerminated\""); return; } public void verifyUnitemporalDeltaWithDeleteIndNoDedupAllVersion(java.util.List, java.util.List) { java.util.Map v, v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v; int v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: java.util.List; v := @parameter: java.util.List; v = ; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(0); v = virtualinvoke v.("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE ((stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')) AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND ((sink.\"digest\" <> stage.\"digest\") OR (stage.\"delete_indicator\" IN (\'yes\',\'1\',\'true\')))))", v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(0); v = virtualinvoke v.("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE ((stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')) AND (NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\"))))) AND (stage.\"delete_indicator\" NOT IN (\'yes\',\'1\',\'true\')))", v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(1); v = virtualinvoke v.("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE ((stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')) AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND ((sink.\"digest\" <> stage.\"digest\") OR (stage.\"delete_indicator\" IN (\'yes\',\'1\',\'true\')))))", v); v = interfaceinvoke v.(1); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(1); v = virtualinvoke v.("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE ((stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')) AND (NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\"))))) AND (stage.\"delete_indicator\" NOT IN (\'yes\',\'1\',\'true\')))", v); v = interfaceinvoke v.(1); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(); staticinvoke (2, v); v = ; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"delete_indicator\", \"data_split\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"delete_indicator\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"biz_date\" ASC) as \"data_split\" FROM \"mydb\".\"staging\" as stage)", v); v = ; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = interfaceinvoke v.(0); v = interfaceinvoke v.(0); v = virtualinvoke v.("SELECT COUNT(*) as \"incomingRecordCount\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE (stage.\"data_split\" >= \'{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}\') AND (stage.\"data_split\" <= \'{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}\')", v); virtualinvoke v.(v, v, "SELECT COUNT(*) as \"rowsUpdated\" FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) AND (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE ((sink.\"id\" = sink.\"id\") AND (sink.\"name\" = sink.\"name\")) AND (sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))))", "SELECT 0 as \"rowsDeleted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) AND (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE ((sink.\"id\" = sink.\"id\") AND (sink.\"name\" = sink.\"name\")) AND (sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))))) as \"rowsInserted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1)-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) AND (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE ((sink.\"id\" = sink.\"id\") AND (sink.\"name\" = sink.\"name\")) AND (sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))))) as \"rowsTerminated\""); return; } public void verifyUnitemporalDeltaWithUpperCaseOptimizer(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { java.lang.String v, v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = ; v = interfaceinvoke v.(2); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"MYDB\".\"MAIN\" as sink SET sink.\"BATCH_ID_OUT\" = (SELECT COALESCE(MAX(BATCH_METADATA.\"TABLE_BATCH_ID\"),0)+1 FROM BATCH_METADATA as BATCH_METADATA WHERE UPPER(BATCH_METADATA.\"TABLE_NAME\") = \'MAIN\')-1 WHERE (sink.\"BATCH_ID_OUT\" = 999999999) AND (EXISTS (SELECT * FROM \"MYDB\".\"STAGING\" as stage WHERE ((sink.\"ID\" = stage.\"ID\") AND (sink.\"NAME\" = stage.\"NAME\")) AND (sink.\"DIGEST\" <> stage.\"DIGEST\")))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"MYDB\".\"MAIN\" (\"ID\", \"NAME\", \"AMOUNT\", \"BIZ_DATE\", \"DIGEST\", \"BATCH_ID_IN\", \"BATCH_ID_OUT\") (SELECT stage.\"ID\",stage.\"NAME\",stage.\"AMOUNT\",stage.\"BIZ_DATE\",stage.\"DIGEST\",(SELECT COALESCE(MAX(BATCH_METADATA.\"TABLE_BATCH_ID\"),0)+1 FROM BATCH_METADATA as BATCH_METADATA WHERE UPPER(BATCH_METADATA.\"TABLE_NAME\") = \'MAIN\'),999999999 FROM \"MYDB\".\"STAGING\" as stage WHERE NOT (EXISTS (SELECT * FROM \"MYDB\".\"MAIN\" as sink WHERE (sink.\"BATCH_ID_OUT\" = 999999999) AND (sink.\"DIGEST\" = stage.\"DIGEST\") AND ((sink.\"ID\" = stage.\"ID\") AND (sink.\"NAME\" = stage.\"NAME\")))))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); return; } public void verifyUnitemporalDeltaWithCleanStagingData(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { java.util.List v; org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; java.lang.Object v; java.lang.String v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); return; } public void verifyUnitemporalDeltaWithNoVersionAndStagingFilter(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v; java.lang.Object v, v, v, v, v; java.lang.String v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging\" as stage WHERE (((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (sink.\"digest\" <> stage.\"digest\")) AND (stage.\"batch_id_in\" > 5)))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging\" as stage WHERE (NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\"))))) AND (stage.\"batch_id_in\" > 5))", v); v = virtualinvoke v.("{\"staging_filters\":{\"batch_id_in\":{\"GT\":5}}}"); v = interfaceinvoke v.(0); staticinvoke (v, v); return; } public void verifyUnitemporalDeltaWithNoVersionAndFilteredDataset(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v; java.lang.Object v, v, v, v, v; java.lang.String v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging\" as stage WHERE (((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (sink.\"digest\" <> stage.\"digest\")) AND (stage.\"batch_id_in\" > 5)))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging\" as stage WHERE (NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\"))))) AND (stage.\"batch_id_in\" > 5))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); return; } public void verifyUnitemporalDeltaWithFilterDupsMaxVersionWithStagingFilter(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { java.util.Map v, v; java.lang.String v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = ; v = interfaceinvoke v.(2); staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"version\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",stage.\"legend_persistence_count\" as \"legend_persistence_count\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",stage.\"legend_persistence_count\" as \"legend_persistence_count\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"version\" DESC) as \"legend_persistence_rank\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage WHERE stage.\"batch_id_in\" > 5 GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\", stage.\"digest\", stage.\"version\") as stage) as stage WHERE stage.\"legend_persistence_rank\" = 1)", v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (stage.\"version\" > sink.\"version\")))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"version\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (stage.\"version\" <= sink.\"version\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")))))", v); v = virtualinvoke v.("{\"staging_filters\":{\"batch_id_in\":{\"GT\":5}}}"); v = interfaceinvoke v.(0); staticinvoke (v, v); return; } public void verifyUnitemporalDeltaWithFilterDupsMaxVersionWithFilteredDataset(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { java.util.Map v, v; java.lang.String v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = ; v = interfaceinvoke v.(2); staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"version\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",stage.\"legend_persistence_count\" as \"legend_persistence_count\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",stage.\"legend_persistence_count\" as \"legend_persistence_count\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"version\" DESC) as \"legend_persistence_rank\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage WHERE stage.\"batch_id_in\" > 5 GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\", stage.\"digest\", stage.\"version\") as stage) as stage WHERE stage.\"legend_persistence_rank\" = 1)", v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (stage.\"version\" > sink.\"version\")))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"version\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (stage.\"version\" <= sink.\"version\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")))))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); return; } public void verifyUnitemporalDeltaWithNoDedupMaxVersionWithoutPerformAndStagingFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v; java.lang.Object v, v, v, v, v; java.lang.String v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging\" as stage WHERE (((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (stage.\"version\" > sink.\"version\")) AND (stage.\"batch_id_in\" > 5)))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"version\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging\" as stage WHERE (NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (stage.\"version\" <= sink.\"version\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\"))))) AND (stage.\"batch_id_in\" > 5))", v); v = virtualinvoke v.("{\"staging_filters\":{\"batch_id_in\":{\"GT\":5}}}"); v = interfaceinvoke v.(0); staticinvoke (v, v); virtualinvoke v.(v, "SELECT COUNT(*) as \"incomingRecordCount\" FROM \"mydb\".\"staging\" as stage WHERE stage.\"batch_id_in\" > 5", "SELECT COUNT(*) as \"rowsUpdated\" FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1", "SELECT 0 as \"rowsDeleted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) as \"rowsInserted\"", "SELECT 0 as \"rowsTerminated\""); return; } public void verifyUnitemporalDeltaWithFailOnDupsMaxVersioningWithoutPerform(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { java.util.Map v, v; java.lang.String v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = ; v = interfaceinvoke v.(2); staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"version\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\", stage.\"digest\", stage.\"version\")", v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (EXISTS (SELECT * FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (stage.\"version\" > sink.\"version\")))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"version\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"version\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (stage.\"version\" <= sink.\"version\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")))))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); return; } public void verifyUnitemporalDeltaWithNoDedupMaxVersioningAndUpperCaseWithoutStagingFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { java.util.Map v, v; java.lang.String v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = ; v = interfaceinvoke v.(2); staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" (\"ID\", \"NAME\", \"AMOUNT\", \"BIZ_DATE\", \"DIGEST\", \"VERSION\") (SELECT stage.\"ID\",stage.\"NAME\",stage.\"AMOUNT\",stage.\"BIZ_DATE\",stage.\"DIGEST\",stage.\"VERSION\" FROM (SELECT stage.\"ID\",stage.\"NAME\",stage.\"AMOUNT\",stage.\"BIZ_DATE\",stage.\"DIGEST\",stage.\"VERSION\",DENSE_RANK() OVER (PARTITION BY stage.\"ID\",stage.\"NAME\" ORDER BY stage.\"VERSION\" DESC) as \"LEGEND_PERSISTENCE_RANK\" FROM \"MYDB\".\"STAGING\" as stage) as stage WHERE stage.\"LEGEND_PERSISTENCE_RANK\" = 1)", v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"MYDB\".\"MAIN\" as sink SET sink.\"BATCH_ID_OUT\" = (SELECT COALESCE(MAX(BATCH_METADATA.\"TABLE_BATCH_ID\"),0)+1 FROM BATCH_METADATA as BATCH_METADATA WHERE UPPER(BATCH_METADATA.\"TABLE_NAME\") = \'MAIN\')-1 WHERE (sink.\"BATCH_ID_OUT\" = 999999999) AND (EXISTS (SELECT * FROM \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" as stage WHERE ((sink.\"ID\" = stage.\"ID\") AND (sink.\"NAME\" = stage.\"NAME\")) AND (stage.\"VERSION\" >= sink.\"VERSION\")))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"MYDB\".\"MAIN\" (\"ID\", \"NAME\", \"AMOUNT\", \"BIZ_DATE\", \"DIGEST\", \"VERSION\", \"BATCH_ID_IN\", \"BATCH_ID_OUT\") (SELECT stage.\"ID\",stage.\"NAME\",stage.\"AMOUNT\",stage.\"BIZ_DATE\",stage.\"DIGEST\",stage.\"VERSION\",(SELECT COALESCE(MAX(BATCH_METADATA.\"TABLE_BATCH_ID\"),0)+1 FROM BATCH_METADATA as BATCH_METADATA WHERE UPPER(BATCH_METADATA.\"TABLE_NAME\") = \'MAIN\'),999999999 FROM \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" as stage WHERE NOT (EXISTS (SELECT * FROM \"MYDB\".\"MAIN\" as sink WHERE (sink.\"BATCH_ID_OUT\" = 999999999) AND (stage.\"VERSION\" < sink.\"VERSION\") AND ((sink.\"ID\" = stage.\"ID\") AND (sink.\"NAME\" = stage.\"NAME\")))))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); return; } public void verifyUnitemporalDeltaNoDeleteIndWithOptimizationFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v; java.lang.Object v, v, v, v, v; java.lang.String v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND ((sink.\"id\" >= \'{ID_LOWER_BOUND}\') AND (sink.\"id\" <= \'{ID_UPPER_BOUND}\')) AND (EXISTS (SELECT * FROM \"mydb\".\"staging\" as stage WHERE ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (sink.\"digest\" <> stage.\"digest\")))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging\" as stage WHERE NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND ((sink.\"id\" >= \'{ID_LOWER_BOUND}\') AND (sink.\"id\" <= \'{ID_UPPER_BOUND}\')))))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); virtualinvoke v.(v, "SELECT COUNT(*) as \"incomingRecordCount\" FROM \"mydb\".\"staging\" as stage", "SELECT COUNT(*) as \"rowsUpdated\" FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1", "SELECT 0 as \"rowsDeleted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) as \"rowsInserted\"", "SELECT 0 as \"rowsTerminated\""); return; } public void verifyUnitemporalDeltaNoDeleteIndWithOptimizationFiltersIncludesNullValues(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult) { org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; java.util.List v, v, v; java.lang.Object v, v, v, v, v; java.lang.String v, v, v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(0); staticinvoke (v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(1); staticinvoke (v, v); v = interfaceinvoke v.(0); staticinvoke ("UPDATE \"mydb\".\"main\" as sink SET sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1 WHERE (sink.\"batch_id_out\" = 999999999) AND (((sink.\"id\" >= \'{ID_LOWER_BOUND}\') AND (sink.\"id\" <= \'{ID_UPPER_BOUND}\')) OR (sink.\"id\" IS NULL)) AND (EXISTS (SELECT * FROM \"mydb\".\"staging\" as stage WHERE ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (sink.\"digest\" <> stage.\"digest\")))", v); v = interfaceinvoke v.(1); staticinvoke ("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"batch_id_in\", \"batch_id_out\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),999999999 FROM \"mydb\".\"staging\" as stage WHERE NOT (EXISTS (SELECT * FROM \"mydb\".\"main\" as sink WHERE (sink.\"batch_id_out\" = 999999999) AND (sink.\"digest\" = stage.\"digest\") AND ((sink.\"id\" = stage.\"id\") AND (sink.\"name\" = stage.\"name\")) AND (((sink.\"id\" >= \'{ID_LOWER_BOUND}\') AND (sink.\"id\" <= \'{ID_UPPER_BOUND}\')) OR (sink.\"id\" IS NULL)))))", v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); staticinvoke (v, v); virtualinvoke v.(v, "SELECT COUNT(*) as \"incomingRecordCount\" FROM \"mydb\".\"staging\" as stage", "SELECT COUNT(*) as \"rowsUpdated\" FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1", "SELECT 0 as \"rowsDeleted\"", "SELECT (SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_in\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'))-(SELECT COUNT(*) FROM \"mydb\".\"main\" as sink WHERE sink.\"batch_id_out\" = (SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\')-1) as \"rowsInserted\"", "SELECT 0 as \"rowsTerminated\""); return; } public org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink() { org.finos.legend.engine.persistence.components.relational.RelationalSink v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v = staticinvoke (); return v; } protected java.lang.String getExpectedMetadataTableIngestQuery() { java.lang.String v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v = ; return v; } protected java.lang.String getExpectedMetadataTableIngestQueryWithIngestRequestId() { org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; return "INSERT INTO batch_metadata (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\", \"ingest_request_id\", \"batch_statistics\") (SELECT \'main\',(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\',\'123456789\',PARSE_JSON(\'{BATCH_STATISTICS_PLACEHOLDER}\'))"; } protected java.lang.String getExpectedMetadataTableIngestQueryWithUpperCase() { java.lang.String v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v = ; return v; } protected java.lang.String getExpectedMetadataTableIngestQueryWithBatchSuccessValue() { java.lang.String v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v = ; return v; } protected java.lang.String getExpectedMetadataTableIngestQueryWithAdditionalMetadata() { java.lang.String v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v = ; return v; } protected java.lang.String getExpectedMetadataTableIngestQueryWithAdditionalMetadataWithUpperCase() { java.lang.String v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v = ; return v; } protected java.lang.String getExpectedMetadataTableCreateQuery() { java.lang.String v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v = ; return v; } protected java.lang.String getExpectedMetadataTableCreateQueryWithUpperCase() { java.lang.String v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v = ; return v; } protected java.lang.String getExpectedMetadataTableIngestQueryWithStagingFilters(java.lang.String) { java.lang.Object[] v; java.lang.String v, v, v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: java.lang.String; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("PARSE_JSON(\'%s\'))", v); v = dynamicinvoke "makeConcatWithConstants" (v) ("INSERT INTO batch_metadata (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\", \"batch_source_info\") (SELECT \'main\',(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\',\u0001"); return v; } protected java.lang.String getExpectedMetadataTableIngestQueryWithStagingFiltersAndAdditionalMetadata(java.lang.String) { java.lang.Object[] v; java.lang.String v, v, v; org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest v; v := @this: org.finos.legend.engine.persistence.components.ingestmode.unitemporal.UnitemporalDeltaBatchIdBasedTest; v := @parameter: java.lang.String; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("PARSE_JSON(\'%s\'),", v); v = dynamicinvoke "makeConcatWithConstants" (v) ("INSERT INTO batch_metadata (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\", \"batch_source_info\", \"additional_metadata\") (SELECT \'main\',(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\',\u0001PARSE_JSON(\'{\"watermark\":\"my_watermark_value\"}\'))"); return v; } }