public class org.finos.legend.engine.persistence.components.ingestmode.NoOpTest extends org.finos.legend.engine.persistence.components.testcases.ingestmode.NoOpTestCases
{
public void <init>()
{
org.finos.legend.engine.persistence.components.ingestmode.NoOpTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.NoOpTest;
specialinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.NoOpTestCases: void <init>()>();
return;
}
public void verifyNoOp(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)
{
org.finos.legend.engine.persistence.components.ingestmode.NoOpTest v;
int v;
java.lang.String v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
java.util.List v, v, v, v, v;
java.lang.Object v, v, v, v, v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.NoOpTest;
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 = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableCreateQuery>;
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 expectedLockInfoTableCreateQuery>;
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 = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.NoOpTest: 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 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);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.NoOpTest: void verifyStats(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, null, null, null, null, null);
return;
}
protected java.lang.String getExpectedMetadataTableIngestQuery()
{
org.finos.legend.engine.persistence.components.ingestmode.NoOpTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.NoOpTest;
return "INSERT INTO batch_metadata (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\", \"ingest_request_id\") (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\')";
}
public void verifyNoOpUpperCase(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)
{
org.finos.legend.engine.persistence.components.ingestmode.NoOpTest v;
int v;
java.lang.String v, v, v, v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
java.util.List v, v, v, v, v;
java.lang.Object v, v, v, v, v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.NoOpTest;
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 = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableCreateQueryWithUpperCase>;
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 expectedLockInfoTableUpperCaseCreateQuery>;
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 = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
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)>("INSERT INTO BATCH_METADATA (\"TABLE_NAME\", \"TABLE_BATCH_ID\", \"BATCH_START_TS_UTC\", \"BATCH_END_TS_UTC\", \"BATCH_STATUS\", \"INGEST_REQUEST_ID\") (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\')", v);
v = <org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String lockInitializedUpperCaseQuery>;
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 lockAcquiredUpperCaseQuery>;
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);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.NoOpTest: void verifyStats(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, null, null, null, null, null);
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.NoOpTest v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.NoOpTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
return v;
}
}