public class org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest extends org.finos.legend.engine.persistence.components.testcases.ingestmode.nontemporal.NontemporalSnapshotTestCases
{
java.lang.String cleanUpMainTableSql;
java.lang.String cleanupMainTableSqlUpperCase;
java.lang.String rowsDeleted;
java.lang.String rowsUpdated;
java.lang.String rowsInserted;
java.lang.String rowsTerminated;
public void <init>()
{
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
specialinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.nontemporal.NontemporalSnapshotTestCases: void <init>()>();
v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String cleanUpMainTableSql> = "DELETE FROM \"mydb\".\"main\" as sink";
v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String cleanupMainTableSqlUpperCase> = "DELETE FROM \"MYDB\".\"MAIN\" as sink";
v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String rowsDeleted> = "SELECT COUNT(*) as \"rowsDeleted\" FROM \"mydb\".\"main\" as sink";
v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String rowsUpdated> = "SELECT 0 as \"rowsUpdated\"";
v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String rowsInserted> = "SELECT COUNT(*) as \"rowsInserted\" FROM \"mydb\".\"main\" as sink";
v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String rowsTerminated> = "SELECT 0 as \"rowsTerminated\"";
return;
}
public void verifyNontemporalSnapshotNoAuditingNoDedupNoVersioning(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)
{
java.util.Map v;
java.lang.String v, v, v, v, v;
boolean v, v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
java.util.List v, v, v, v, v, v;
java.lang.Object v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List preActionsSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List ingestSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List metadataIngestSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List initializeLockSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List acquireLockSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List deduplicationAndVersioningSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.Map deduplicationAndVersioningErrorChecksSql()>();
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedLockInfoTableCreateQuery>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String cleanUpMainTableSql>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"batch_id\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\') FROM \"mydb\".\"staging\" as stage)", v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String lockInitializedQuery>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String lockAcquiredQuery>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String getExpectedMetadataTableIngestQuery()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
specialinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: void verifyStats(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult,java.lang.String)>(v, "staging");
return;
}
public void verifyNontemporalSnapshotWithAuditingFilterDupsNoVersioning(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)
{
java.util.Map v;
java.lang.String v, v, v, v, v, v, v;
boolean v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
java.util.List v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List preActionsSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List ingestSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List metadataIngestSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List deduplicationAndVersioningSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.Map deduplicationAndVersioningErrorChecksSql()>();
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTableWithAuditPkCreateQuery>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String getExpectedMetadataTableCreateQuery()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTableWithCount>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String cleanUpMainTableSql>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"batch_update_time\", \"batch_id\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",\'2000-01-01 00:00:00.000000\',(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\') FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage)", v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String getExpectedMetadataTableIngestQuery()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedTempStagingCleanupQuery>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingWithFilterDuplicates>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
specialinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: void verifyStats(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult,java.lang.String)>(v, "staging");
return;
}
public void verifyNontemporalSnapshotWithAuditingFailOnDupMaxVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)
{
java.util.Map v;
java.util.List v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List preActionsSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List ingestSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List metadataIngestSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List deduplicationAndVersioningSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.Map deduplicationAndVersioningErrorChecksSql()>();
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTableWithAuditPkCreateQuery>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String getExpectedMetadataTableCreateQuery()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTableWithCount>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String cleanUpMainTableSql>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"biz_date\", \"batch_update_time\", \"batch_id\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",\'2000-01-01 00:00:00.000000\',(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\') FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage)", v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String getExpectedMetadataTableIngestQuery()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedTempStagingCleanupQuery>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingWithMaxVersionAndFilterDuplicates>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String maxDupsErrorCheckSql>;
v = <org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType: org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType MAX_DUPLICATES>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType: org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType MAX_DATA_ERRORS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT MAX(\"legend_persistence_distinct_rows\") as \"MAX_DATA_ERRORS\" FROM (SELECT COUNT(DISTINCT(\"amount\")) as \"legend_persistence_distinct_rows\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage GROUP BY \"id\", \"name\", \"biz_date\") as stage", v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dupRowsSql>;
v = <org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType: org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType DUPLICATE_ROWS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType: org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType DATA_ERROR_ROWS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT \"id\",\"name\",\"biz_date\",COUNT(DISTINCT(\"amount\")) as \"legend_persistence_error_count\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage GROUP BY \"id\", \"name\", \"biz_date\" HAVING \"legend_persistence_error_count\" > 1 LIMIT 20", v);
specialinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: void verifyStats(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult,java.lang.String)>(v, "staging");
return;
}
public void verifyNontemporalSnapshotWithUpperCaseOptimizer(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)
{
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
java.util.List v, v;
java.lang.Object v, v, v;
java.lang.String v, v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List preActionsSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List ingestSql()>();
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTableCreateQueryWithUpperCase>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String cleanupMainTableSqlUpperCase>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("INSERT INTO \"MYDB\".\"MAIN\" (\"ID\", \"NAME\", \"AMOUNT\", \"BIZ_DATE\", \"BATCH_ID\") (SELECT stage.\"ID\",stage.\"NAME\",stage.\"AMOUNT\",stage.\"BIZ_DATE\",(SELECT COALESCE(MAX(BATCH_METADATA.\"TABLE_BATCH_ID\"),0)+1 FROM BATCH_METADATA as BATCH_METADATA WHERE UPPER(BATCH_METADATA.\"TABLE_NAME\") = \'MAIN\') FROM \"MYDB\".\"STAGING\" as stage)", v);
return;
}
public void verifyNontemporalSnapshotWithLessColumnsInStaging(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)
{
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
java.util.List v, v;
java.lang.Object v, v, v;
java.lang.String v, v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List preActionsSql()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List ingestSql()>();
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTableCreateQuery>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String cleanUpMainTableSql>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("INSERT INTO \"mydb\".\"main\" (\"id\", \"name\", \"amount\", \"batch_id\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\') FROM \"mydb\".\"staging\" as stage)", v);
return;
}
public void verifyNontemporalSnapshotWithCleanStagingData(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.String v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
java.util.ArrayList v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.List postActionsSql()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedStagingCleanupQuery>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: void assertIfListsAreSameIgnoringOrder(java.util.List,java.util.List)>(v, v);
return;
}
public void verifyNontemporalSnapshotWithDropStagingData(org.finos.legend.engine.persistence.components.relational.SqlPlan)
{
java.util.List v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
java.lang.String v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
java.util.ArrayList v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.SqlPlan;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedDropTableQuery>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: void assertIfListsAreSameIgnoringOrder(java.util.List,java.util.List)>(v, v);
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.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
return v;
}
protected java.lang.String getExpectedMetadataTableIngestQuery()
{
java.lang.String v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQuery>;
return v;
}
protected java.lang.String getExpectedMetadataTableIngestQueryWithUpperCase()
{
java.lang.String v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQueryWithUpperCase>;
return v;
}
protected java.lang.String getExpectedMetadataTableCreateQuery()
{
java.lang.String v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableCreateQuery>;
return v;
}
protected java.lang.String getExpectedMetadataTableCreateQueryWithUpperCase()
{
java.lang.String v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableCreateQueryWithUpperCase>;
return v;
}
private void verifyStats(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult, java.lang.String)
{
java.lang.Object[] v;
org.finos.legend.engine.persistence.components.common.StatisticName v, v, v, v, v;
java.util.Map v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
java.lang.Object v, v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult;
v := @parameter: java.lang.String;
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String rowsDeleted>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.Map preIngestStatisticsSql()>();
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName ROWS_DELETED>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("SELECT COUNT(*) as \"incomingRecordCount\" FROM \"mydb\".\"%s\" as stage", v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.Map postIngestStatisticsSql()>();
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName INCOMING_RECORD_COUNT>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String rowsUpdated>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.Map postIngestStatisticsSql()>();
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName ROWS_UPDATED>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String rowsInserted>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.Map postIngestStatisticsSql()>();
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName ROWS_INSERTED>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.nontemporal.NontemporalSnapshotTest: java.lang.String rowsTerminated>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.GeneratorResult: java.util.Map postIngestStatisticsSql()>();
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName ROWS_TERMINATED>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
}