public class org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest extends java.lang.Object
{
private final java.time.ZonedDateTime executionZonedDateTime;
private final org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions;
private org.finos.legend.engine.persistence.components.util.LockInfoDataset lockInfoDataset;
public void <init>()
{
org.finos.legend.engine.persistence.components.util.LockInfoDataset v;
java.time.ZonedDateTime v, v;
java.time.Instant v;
org.finos.legend.engine.persistence.components.util.LockInfoDataset$Builder v, v;
org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
java.time.Clock 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.LockInfoUtilsTest;
specialinvoke v.<java.lang.Object: void <init>()>();
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.LockInfoUtilsTest: 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.LockInfoUtilsTest: 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.LockInfoUtilsTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions> = v;
v = staticinvoke <org.finos.legend.engine.persistence.components.util.LockInfoDataset: org.finos.legend.engine.persistence.components.util.LockInfoDataset$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoDataset$Builder: org.finos.legend.engine.persistence.components.util.LockInfoDataset$Builder name(java.lang.String)>("main_table_lock");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoDataset$Builder: org.finos.legend.engine.persistence.components.util.LockInfoDataset build()>();
v.<org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest: org.finos.legend.engine.persistence.components.util.LockInfoDataset lockInfoDataset> = v;
return;
}
public void testInitializeLockInfo()
{
org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v;
org.finos.legend.engine.persistence.components.util.LockInfoDataset v;
org.finos.legend.engine.persistence.components.util.LockInfoUtils 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.LogicalPlan v;
org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
v := @this: org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.LockInfoUtils;
v = v.<org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest: org.finos.legend.engine.persistence.components.util.LockInfoDataset lockInfoDataset>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: void <init>(org.finos.legend.engine.persistence.components.util.LockInfoDataset)>(v);
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp INSTANCE>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: org.finos.legend.engine.persistence.components.logicalplan.operations.Insert initializeLockInfo(org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp)>(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.LockInfoUtilsTest: 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 = 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 main_table_lock (\"insert_ts_utc\") (SELECT \'2000-01-01 00:00:00.000000\' WHERE NOT (EXISTS (SELECT * FROM main_table_lock as main_table_lock)))", v);
return;
}
public void testInitializeLockInfoForMultiIngest()
{
org.finos.legend.engine.persistence.components.util.LockInfoDataset v;
org.finos.legend.engine.persistence.components.util.LockInfoUtils 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.LogicalPlan v;
org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
java.util.List v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
java.util.Optional v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
v := @this: org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.LockInfoUtils;
v = v.<org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest: org.finos.legend.engine.persistence.components.util.LockInfoDataset lockInfoDataset>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: void <init>(org.finos.legend.engine.persistence.components.util.LockInfoDataset)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp INSTANCE>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: java.util.List initializeLockInfoForMultiIngest(java.util.Optional,org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp)>(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.LockInfoUtilsTest: 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 addAllOps(java.lang.Iterable)>(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 = 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 main_table_lock (\"insert_ts_utc\", \"batch_id\") (SELECT \'2000-01-01 00:00:00.000000\',0 WHERE NOT (EXISTS (SELECT * FROM main_table_lock as main_table_lock)))", v);
return;
}
public void testInitializeLockInfoForMultiIngestWithBatchIdValue()
{
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.util.LockInfoUtilsTest 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;
java.lang.Long v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.util.LockInfoDataset v;
org.finos.legend.engine.persistence.components.util.LockInfoUtils v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v, v;
java.util.Optional v;
java.lang.Object v, v;
v := @this: org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.LockInfoUtils;
v = v.<org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest: org.finos.legend.engine.persistence.components.util.LockInfoDataset lockInfoDataset>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: void <init>(org.finos.legend.engine.persistence.components.util.LockInfoDataset)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(50L);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp INSTANCE>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: java.util.List initializeLockInfoForMultiIngest(java.util.Optional,org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp)>(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.LockInfoUtilsTest: 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 addAllOps(java.lang.Iterable)>(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 = 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 main_table_lock (\"insert_ts_utc\", \"batch_id\") (SELECT \'2000-01-01 00:00:00.000000\',50 WHERE NOT (EXISTS (SELECT * FROM main_table_lock as main_table_lock)))", 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)>("UPDATE main_table_lock as main_table_lock SET main_table_lock.\"batch_id\" = 50 WHERE main_table_lock.\"batch_id\" IS NULL", v);
return;
}
public void testUpdateMetaStore()
{
org.finos.legend.engine.persistence.components.logicalplan.operations.Update v;
org.finos.legend.engine.persistence.components.util.LockInfoDataset v;
org.finos.legend.engine.persistence.components.util.LockInfoUtils 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.LogicalPlan v;
org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
v := @this: org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.LockInfoUtils;
v = v.<org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest: org.finos.legend.engine.persistence.components.util.LockInfoDataset lockInfoDataset>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: void <init>(org.finos.legend.engine.persistence.components.util.LockInfoDataset)>(v);
v = <org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp INSTANCE>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: org.finos.legend.engine.persistence.components.logicalplan.operations.Update updateLockInfo(org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp)>(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.LockInfoUtilsTest: 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 = 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)>("UPDATE main_table_lock as main_table_lock SET main_table_lock.\"last_used_ts_utc\" = \'2000-01-01 00:00:00.000000\'", v);
return;
}
public void testUpdateBatchId()
{
org.finos.legend.engine.persistence.components.util.LockInfoDataset v;
org.finos.legend.engine.persistence.components.util.LockInfoUtils v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
java.util.List v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
v := @this: org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.LockInfoUtils;
v = v.<org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest: org.finos.legend.engine.persistence.components.util.LockInfoDataset lockInfoDataset>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: void <init>(org.finos.legend.engine.persistence.components.util.LockInfoDataset)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan updateBatchId(long)>(10L);
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.LockInfoUtilsTest: 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 = 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)>("UPDATE main_table_lock as main_table_lock SET main_table_lock.\"batch_id\" = 10", v);
return;
}
public void testGetLogicalPlanForNextBatchIdValue()
{
org.finos.legend.engine.persistence.components.util.LockInfoDataset v;
org.finos.legend.engine.persistence.components.util.LockInfoUtils v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
java.util.List v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
v := @this: org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest;
v = new org.finos.legend.engine.persistence.components.util.LockInfoUtils;
v = v.<org.finos.legend.engine.persistence.components.util.LockInfoUtilsTest: org.finos.legend.engine.persistence.components.util.LockInfoDataset lockInfoDataset>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: void <init>(org.finos.legend.engine.persistence.components.util.LockInfoDataset)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.LockInfoUtils: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan getLogicalPlanForNextBatchIdValue()>();
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.LockInfoUtilsTest: 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 = 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 MAX(main_table_lock.\"batch_id\")+1 FROM main_table_lock as main_table_lock", v);
return;
}
}