public abstract class org.finos.legend.engine.persistence.components.util.MetadataUtilsTest extends java.lang.Object
{
private final org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName;
private final java.time.ZonedDateTime executionZonedDateTime;
protected final org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions;
public void <init>()
{
java.time.ZonedDateTime v, v;
java.time.Instant v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
java.time.Clock v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.time.ZoneOffset v, v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions$Builder v, v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>("main");
v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName> = v;
v = <java.time.ZoneOffset: java.time.ZoneOffset UTC>;
v = staticinvoke <java.time.ZonedDateTime: java.time.ZonedDateTime of(int,int,int,int,int,int,int,java.time.ZoneId)>(2000, 1, 1, 0, 0, 0, 0, v);
v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.time.ZonedDateTime executionZonedDateTime> = v;
v = staticinvoke <org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.time.ZonedDateTime executionZonedDateTime>;
v = virtualinvoke v.<java.time.ZonedDateTime: java.time.Instant toInstant()>();
v = <java.time.ZoneOffset: java.time.ZoneOffset UTC>;
v = staticinvoke <java.time.Clock: java.time.Clock fixed(java.time.Instant,java.time.ZoneId)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions$Builder: org.finos.legend.engine.persistence.components.transformer.TransformOptions$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions$Builder: org.finos.legend.engine.persistence.components.transformer.TransformOptions build()>();
v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions> = v;
return;
}
protected abstract org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset();
protected abstract java.lang.String lowerCaseTableName();
protected java.lang.String upperCaseTableName()
{
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toUpperCase()>();
return v;
}
public void testGetBatchId()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.Object v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue getBatchId(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection selection()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SELECT COALESCE(MAX(\u.\"table_batch_id\"),0)+1 FROM \u as \u WHERE UPPER(\u.\"table_name\") = \'MAIN\'");
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);
return;
}
public void testGetBatchIdWithBatchPattern()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue getBatchId(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder addFields(org.finos.legend.engine.persistence.components.logicalplan.values.Value)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection build()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withBatchIdPattern(java.lang.String)>("{BATCH_ID_PATTERN}");
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
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)>("SELECT {BATCH_ID_PATTERN}", v);
return;
}
public void testGetBatchIdWithUpperCase()
{
java.lang.Object[] v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.Object v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue getBatchId(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection selection()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
v = newarray (org.finos.legend.engine.persistence.components.optimizer.Optimizer)[1];
v = new org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer: void <init>()>();
v[0] = v;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withOptimizers(org.finos.legend.engine.persistence.components.optimizer.Optimizer[])>(v);
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String upperCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SELECT COALESCE(MAX(\u.\"TABLE_BATCH_ID\"),0)+1 FROM \u as \u WHERE UPPER(\u.\"TABLE_NAME\") = \'MAIN\'");
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);
return;
}
public void testGetPrevBatchId()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.values.Value v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.values.Value getPrevBatchId(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder addFields(org.finos.legend.engine.persistence.components.logicalplan.values.Value)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection build()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SELECT (SELECT COALESCE(MAX(\u.\"table_batch_id\"),0)+1 FROM \u as \u WHERE UPPER(\u.\"table_name\") = \'MAIN\')-1");
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);
return;
}
public void testGetPrevBatchIdWithBatchIdPattern()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.values.Value v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.values.Value getPrevBatchId(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder addFields(org.finos.legend.engine.persistence.components.logicalplan.values.Value)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection build()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withBatchIdPattern(java.lang.String)>("{BATCH_ID_PATTERN}");
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
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)>("SELECT {BATCH_ID_PATTERN}-1", v);
return;
}
public void testGetPrevBatchIdWithUpperCase()
{
java.lang.Object[] v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.values.Value v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.values.Value getPrevBatchId(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder addFields(org.finos.legend.engine.persistence.components.logicalplan.values.Value)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection build()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
v = newarray (org.finos.legend.engine.persistence.components.optimizer.Optimizer)[1];
v = new org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer: void <init>()>();
v[0] = v;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withOptimizers(org.finos.legend.engine.persistence.components.optimizer.Optimizer[])>(v);
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String upperCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SELECT (SELECT COALESCE(MAX(\u.\"TABLE_BATCH_ID\"),0)+1 FROM \u as \u WHERE UPPER(\u.\"TABLE_NAME\") = \'MAIN\')-1");
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);
return;
}
public void testInsertMetaStore()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataUtils$MetaTableStatus v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v, v;
java.lang.Object v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp INSTANCE>;
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp INSTANCE>;
v = <org.finos.legend.engine.persistence.components.util.MetadataUtils$MetaTableStatus: org.finos.legend.engine.persistence.components.util.MetadataUtils$MetaTableStatus DONE>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils$MetaTableStatus: java.lang.String toString()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.operations.Insert insertMetaData(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue,org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp,org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp,org.finos.legend.engine.persistence.components.logicalplan.values.Value)>(v, v, v, v);
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("INSERT INTO \u (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\") (SELECT \'main\',(SELECT COALESCE(MAX(\u.\"table_batch_id\"),0)+1 FROM \u as \u WHERE UPPER(\u.\"table_name\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\')");
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);
return;
}
public void testInsertMetaStoreWithUpperCase()
{
java.lang.Object[] v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataUtils$MetaTableStatus v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v, v;
java.lang.Object v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp INSTANCE>;
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp INSTANCE>;
v = <org.finos.legend.engine.persistence.components.util.MetadataUtils$MetaTableStatus: org.finos.legend.engine.persistence.components.util.MetadataUtils$MetaTableStatus DONE>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils$MetaTableStatus: java.lang.String toString()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.operations.Insert insertMetaData(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue,org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp,org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp,org.finos.legend.engine.persistence.components.logicalplan.values.Value)>(v, v, v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
v = newarray (org.finos.legend.engine.persistence.components.optimizer.Optimizer)[1];
v = new org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer: void <init>()>();
v[0] = v;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withOptimizers(org.finos.legend.engine.persistence.components.optimizer.Optimizer[])>(v);
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String upperCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String upperCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("INSERT INTO \u (\"TABLE_NAME\", \"TABLE_BATCH_ID\", \"BATCH_START_TS_UTC\", \"BATCH_END_TS_UTC\", \"BATCH_STATUS\") (SELECT \'main\',(SELECT COALESCE(MAX(\u.\"TABLE_BATCH_ID\"),0)+1 FROM \u as \u WHERE UPPER(\u.\"TABLE_NAME\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\')");
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);
return;
}
public void testGetMaxStagingFilters()
{
java.lang.Object[] v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.Object v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue tableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection getLatestStagingFilters(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
v = newarray (org.finos.legend.engine.persistence.components.optimizer.Optimizer)[1];
v = new org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer: void <init>()>();
v[0] = v;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withOptimizers(org.finos.legend.engine.persistence.components.optimizer.Optimizer[])>(v);
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String upperCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String upperCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SELECT \u.\"BATCH_SOURCE_INFO\" FROM \u as \u WHERE (UPPER(\u.\"TABLE_NAME\") = \'MAIN\') AND (\u.\"TABLE_BATCH_ID\" = (SELECT MAX(\u.\"TABLE_BATCH_ID\") FROM \u as \u WHERE UPPER(\u.\"TABLE_NAME\") = \'MAIN\')) LIMIT 1");
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);
return;
}
public void testInsertMetadataWithAdditionalInfo()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v;
org.finos.legend.engine.persistence.components.logicalplan.values.BulkLoadBatchStatusValue v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
java.lang.String v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
java.util.Optional v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v, v, v;
java.lang.Object v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>("appeng_log_table_name");
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>("my_batch_source_info");
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>("my_additional_metadata");
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp INSTANCE>;
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp INSTANCE>;
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BulkLoadBatchStatusValue: org.finos.legend.engine.persistence.components.logicalplan.values.BulkLoadBatchStatusValue INSTANCE>;
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>("EVENT_ID");
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.operations.Insert insertMetaData(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue,org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp,org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp,org.finos.legend.engine.persistence.components.logicalplan.values.Value,java.util.Optional,java.util.Optional,java.util.Optional,boolean)>(v, v, v, v, v, v, v, 1);
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withBulkLoadBatchStatusPattern(java.lang.String)>("<BATCH_STATUS_PATTERN>");
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("INSERT INTO \u (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\", \"ingest_request_id\", \"batch_source_info\", \"additional_metadata\", \"batch_statistics\") (SELECT \'appeng_log_table_name\',(SELECT COALESCE(MAX(\u.\"table_batch_id\"),0)+1 FROM \u as \u WHERE UPPER(\u.\"table_name\") = \'APPENG_LOG_TABLE_NAME\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'<BATCH_STATUS_PATTERN>\',\'EVENT_ID\',PARSE_JSON(\'my_batch_source_info\'),PARSE_JSON(\'my_additional_metadata\'),PARSE_JSON(\'{BATCH_STATISTICS_PLACEHOLDER}\'))");
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);
return;
}
public void testInsertMetadataWithAdditionalInfoInUpperCase()
{
org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v, v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer v;
org.finos.legend.engine.persistence.components.util.MetadataUtilsTest v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.MetadataDataset v;
org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v;
java.util.Optional v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v, v, v;
java.lang.Object[] v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.logicalplan.values.BulkLoadBatchStatusValue v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
java.lang.String v, v, v, v, v, v;
java.lang.Object v;
v := @this: org.finos.legend.engine.persistence.components.util.MetadataUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.MetadataUtils;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.util.MetadataDataset metadataDataset()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: void <init>(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>("BULK_LOAD_TABLE_NAME");
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>("my_batch_source_info");
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.StringValue: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue of(java.lang.String)>("my_additional_metadata");
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp INSTANCE>;
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp INSTANCE>;
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BulkLoadBatchStatusValue: org.finos.legend.engine.persistence.components.logicalplan.values.BulkLoadBatchStatusValue INSTANCE>;
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>("EVENT_ID");
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.operations.Insert insertMetaData(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue,org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp,org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp,org.finos.legend.engine.persistence.components.logicalplan.values.Value,java.util.Optional,java.util.Optional,java.util.Optional,boolean)>(v, v, v, v, v, v, v, 1);
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withBulkLoadBatchStatusPattern(java.lang.String)>("<BATCH_STATUS_PATTERN>");
v = newarray (org.finos.legend.engine.persistence.components.optimizer.Optimizer)[1];
v = new org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.optimizer.UpperCaseOptimizer: void <init>()>();
v[0] = v;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions withOptimizers(org.finos.legend.engine.persistence.components.optimizer.Optimizer[])>(v);
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String upperCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String upperCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtilsTest: java.lang.String lowerCaseTableName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("INSERT INTO \u (\"TABLE_NAME\", \"TABLE_BATCH_ID\", \"BATCH_START_TS_UTC\", \"BATCH_END_TS_UTC\", \"BATCH_STATUS\", \"INGEST_REQUEST_ID\", \"BATCH_SOURCE_INFO\", \"ADDITIONAL_METADATA\", \"BATCH_STATISTICS\") (SELECT \'BULK_LOAD_TABLE_NAME\',(SELECT COALESCE(MAX(\u.\"TABLE_BATCH_ID\"),0)+1 FROM \u as \u WHERE UPPER(\u.\"TABLE_NAME\") = \'BULK_LOAD_TABLE_NAME\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'<BATCH_STATUS_PATTERN>\',\'EVENT_ID\',PARSE_JSON(\'my_batch_source_info\'),PARSE_JSON(\'my_additional_metadata\'),PARSE_JSON(\'{BATCH_STATISTICS_PLACEHOLDER}\'))");
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);
return;
}
}