public class org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult extends org.finos.legend.engine.plan.execution.result.StreamingResult implements org.finos.legend.engine.plan.dependencies.store.relational.IRelationalResult, org.finos.legend.engine.plan.execution.stores.StoreExecutable
{
private static final org.slf4j.Logger LOGGER;
private static final org.eclipse.collections.api.list.ImmutableList TEMPORAL_DATE_ALIASES;
public final java.util.List sqlColumns;
private final java.util.List temporaryTables;
private final java.util.List resultColumns;
private java.util.List columnListForSerializer;
private final java.sql.Connection connection;
private final java.sql.Statement statement;
public java.sql.ResultSet resultSet;
public java.sql.ResultSetMetaData resultSetMetaData;
public java.lang.String executedSQl;
public int columnCount;
private final java.lang.String databaseType;
private final java.lang.String databaseTimeZone;
public io.opentracing.Span topSpan;
private final org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData resultDBColumnsMetaData;
private final org.finos.legend.engine.shared.core.api.request.RequestContext requestContext;
public org.eclipse.collections.api.list.MutableList setTransformers;
public org.finos.legend.engine.plan.execution.result.builder.Builder builder;
private java.util.Calendar calendar;
public void <init>(org.eclipse.collections.api.list.MutableList, org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode, java.util.List, java.lang.String, java.lang.String, java.sql.Connection, org.finos.legend.engine.shared.core.identity.Identity, java.util.List, io.opentracing.Span)
{
org.finos.legend.engine.shared.core.identity.Identity v;
java.sql.Connection v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode v;
org.eclipse.collections.api.list.MutableList v;
java.util.List v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
io.opentracing.Span v;
org.finos.legend.engine.shared.core.api.request.RequestContext v;
java.lang.String v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: org.eclipse.collections.api.list.MutableList;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.sql.Connection;
v := @parameter: org.finos.legend.engine.shared.core.identity.Identity;
v := @parameter: java.util.List;
v := @parameter: io.opentracing.Span;
v = new org.finos.legend.engine.shared.core.api.request.RequestContext;
specialinvoke v.<org.finos.legend.engine.shared.core.api.request.RequestContext: void <init>()>();
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: void <init>(org.eclipse.collections.api.list.MutableList,org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode,java.util.List,java.lang.String,java.lang.String,java.sql.Connection,org.finos.legend.engine.shared.core.identity.Identity,java.util.List,io.opentracing.Span,org.finos.legend.engine.shared.core.api.request.RequestContext)>(v, v, v, v, v, v, v, v, v, v);
return;
}
public void <init>(org.eclipse.collections.api.list.MutableList, org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode, java.util.List, java.lang.String, java.lang.String, java.sql.Connection, org.finos.legend.engine.shared.core.identity.Identity, java.util.List, io.opentracing.Span, org.finos.legend.engine.shared.core.api.request.RequestContext)
{
org.finos.legend.engine.shared.core.identity.Identity v;
java.sql.Connection v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode v;
org.eclipse.collections.api.list.MutableList v;
java.util.List v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
io.opentracing.Span v;
org.finos.legend.engine.shared.core.api.request.RequestContext v;
java.lang.String v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: org.eclipse.collections.api.list.MutableList;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.sql.Connection;
v := @parameter: org.finos.legend.engine.shared.core.identity.Identity;
v := @parameter: java.util.List;
v := @parameter: io.opentracing.Span;
v := @parameter: org.finos.legend.engine.shared.core.api.request.RequestContext;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: void <init>(org.eclipse.collections.api.list.MutableList,org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode,java.util.List,java.lang.String,java.lang.String,java.sql.Connection,org.finos.legend.engine.shared.core.identity.Identity,java.util.List,io.opentracing.Span,org.finos.legend.engine.shared.core.api.request.RequestContext,boolean)>(v, v, v, v, v, v, v, v, v, v, 1);
return;
}
public void <init>(org.eclipse.collections.api.list.MutableList, org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode, java.util.List, java.lang.String, java.lang.String, java.sql.Connection, org.finos.legend.engine.shared.core.identity.Identity, java.util.List, io.opentracing.Span, org.finos.legend.engine.shared.core.api.request.RequestContext, boolean)
{
org.finos.legend.engine.shared.core.operational.logs.LoggingEventType v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseType v;
java.sql.ResultSet v, v;
io.opentracing.Span v;
java.lang.Throwable v;
long v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.RuntimeException v;
java.sql.Statement v, v, v;
org.finos.legend.engine.shared.core.identity.Identity v;
java.sql.Connection v;
org.eclipse.collections.api.list.MutableList v, v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData v;
boolean v, v, v, v;
org.finos.legend.engine.plan.execution.stores.StoreExecutableManager v;
org.finos.legend.engine.shared.core.operational.logs.LogInfo v, v;
java.util.List v, v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection v;
org.finos.legend.engine.shared.core.api.request.RequestContext v;
java.sql.ResultSetMetaData v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode v;
org.eclipse.collections.api.factory.list.MutableListFactory v, v;
int v, v, v, v;
double v;
org.slf4j.Logger v, v, v;
java.lang.Object v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: org.eclipse.collections.api.list.MutableList;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.sql.Connection;
v := @parameter: org.finos.legend.engine.shared.core.identity.Identity;
v := @parameter: java.util.List;
v := @parameter: io.opentracing.Span;
v := @parameter: org.finos.legend.engine.shared.core.api.request.RequestContext;
v := @parameter: boolean;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.StreamingResult: void <init>(java.util.List)>(v);
v = <org.eclipse.collections.impl.factory.Lists: org.eclipse.collections.api.factory.list.MutableListFactory mutable>;
v = interfaceinvoke v.<org.eclipse.collections.api.factory.list.MutableListFactory: org.eclipse.collections.api.list.MutableList empty()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers> = v;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String databaseType> = v;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String databaseTimeZone> = v;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List temporaryTables> = v;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: io.opentracing.Span topSpan> = v;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.shared.core.api.request.RequestContext requestContext> = v;
label:
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Connection connection> = v;
v = interfaceinvoke v.<java.sql.Connection: java.sql.Statement createStatement()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement> = v;
v = <org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseType: org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseType MemSQL>;
v = virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseType: java.lang.String name()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement>;
interfaceinvoke v.<java.sql.Statement: void setFetchSize(int)>(100);
label:
if v == null goto label;
v = <org.finos.legend.engine.plan.execution.stores.StoreExecutableManager: org.finos.legend.engine.plan.execution.stores.StoreExecutableManager INSTANCE>;
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.StoreExecutableManager: void addExecutable(org.finos.legend.engine.shared.core.api.request.RequestContext,org.finos.legend.engine.plan.execution.stores.StoreExecutable)>(v, v);
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: java.lang.Object getLast()>();
v = v.<org.finos.legend.engine.plan.execution.stores.relational.activity.RelationalExecutionActivity: java.lang.String comment>;
if v == null goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.activity.RelationalExecutionActivity: java.lang.String comment>;
v = virtualinvoke v.<java.lang.String: java.lang.String concat(java.lang.String)>("\n");
v = v.<org.finos.legend.engine.plan.execution.stores.relational.activity.RelationalExecutionActivity: java.lang.String sql>;
v = virtualinvoke v.<java.lang.String: java.lang.String concat(java.lang.String)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.activity.RelationalExecutionActivity: java.lang.String sql>;
label:
v = v;
if v == 0 goto label;
v = v;
goto label;
label:
v = virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode: java.lang.String sqlQuery()>();
label:
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
v = new org.finos.legend.engine.shared.core.operational.logs.LogInfo;
v = virtualinvoke v.<org.finos.legend.engine.shared.core.identity.Identity: java.lang.String getName()>();
v = <org.finos.legend.engine.shared.core.operational.logs.LoggingEventType: org.finos.legend.engine.shared.core.operational.logs.LoggingEventType EXECUTION_RELATIONAL_START>;
specialinvoke v.<org.finos.legend.engine.shared.core.operational.logs.LogInfo: void <init>(java.lang.String,org.finos.legend.engine.shared.core.operational.logs.ILoggingEventType,java.lang.String)>(v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.shared.core.operational.logs.LogInfo: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement>;
v = interfaceinvoke v.<java.sql.Statement: java.sql.ResultSet executeQuery(java.lang.String)>(v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet> = v;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String executedSQl> = v;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
v = new org.finos.legend.engine.shared.core.operational.logs.LogInfo;
v = virtualinvoke v.<org.finos.legend.engine.shared.core.identity.Identity: java.lang.String getName()>();
v = <org.finos.legend.engine.shared.core.operational.logs.LoggingEventType: org.finos.legend.engine.shared.core.operational.logs.LoggingEventType EXECUTION_RELATIONAL_STOP>;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
specialinvoke v.<org.finos.legend.engine.shared.core.operational.logs.LogInfo: void <init>(java.lang.String,org.finos.legend.engine.shared.core.operational.logs.ILoggingEventType,double)>(v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.shared.core.operational.logs.LogInfo: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: java.sql.ResultSetMetaData getMetaData()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData> = v;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData>;
v = interfaceinvoke v.<java.sql.ResultSetMetaData: int getColumnCount()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: int columnCount> = v;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List resultColumns> = v;
v = new org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List resultColumns>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData>;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData: void <init>(java.util.List,java.sql.ResultSetMetaData)>(v, v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData resultDBColumnsMetaData> = v;
v = <org.eclipse.collections.impl.factory.Lists: org.eclipse.collections.api.factory.list.MutableListFactory mutable>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: int columnCount>;
v = interfaceinvoke v.<org.eclipse.collections.api.factory.list.MutableListFactory: org.eclipse.collections.api.list.MutableList ofInitialCapacity(int)>(v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List sqlColumns> = v;
v = 1;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: int columnCount>;
if v > v goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List sqlColumns>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData>;
v = interfaceinvoke v.<java.sql.ResultSetMetaData: java.lang.String getColumnLabel(int)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List sqlColumns>;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List columnListForSerializer> = v;
v = v.<org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalExecutionNode: org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection connection>;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: void buildTransformersAndBuilder(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode,org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("error initialising RelationalResult", v);
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: void close()>();
v = v instanceof java.lang.Error;
if v == 0 goto label;
throw v;
label:
v = v instanceof java.lang.RuntimeException;
if v == 0 goto label;
throw v;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult, org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalInstantiationExecutionNode)
{
java.sql.Connection v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalInstantiationExecutionNode v;
org.eclipse.collections.api.list.MutableList v;
java.sql.ResultSet v;
org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData v;
boolean v, v;
org.finos.legend.engine.plan.execution.stores.StoreExecutableManager v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.SQLExecutionNode v;
java.util.List v, v, v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection v;
io.opentracing.Span v;
org.finos.legend.engine.shared.core.api.request.RequestContext v, v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult v;
java.sql.ResultSetMetaData v, v;
java.lang.Throwable v;
org.eclipse.collections.api.factory.list.MutableListFactory v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
int v;
java.lang.String v, v, v;
org.slf4j.Logger v;
java.lang.RuntimeException v;
java.sql.Statement v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.RelationalInstantiationExecutionNode;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.util.List activities>;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.StreamingResult: void <init>(java.util.List)>(v);
v = <org.eclipse.collections.impl.factory.Lists: org.eclipse.collections.api.factory.list.MutableListFactory mutable>;
v = interfaceinvoke v.<org.eclipse.collections.api.factory.list.MutableListFactory: org.eclipse.collections.api.list.MutableList empty()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.lang.String getDatabaseType()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String databaseType> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.lang.String getDatabaseTimeZone()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String databaseTimeZone> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.util.List getTemporaryTables()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List temporaryTables> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: io.opentracing.Span getTopSpan()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: io.opentracing.Span topSpan> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: org.finos.legend.engine.shared.core.api.request.RequestContext getRequestContext()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.shared.core.api.request.RequestContext requestContext> = v;
label:
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.sql.Connection getConnection()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Connection connection> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.sql.Statement getStatement()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.sql.ResultSet getResultSet()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.lang.String getExecutedSql()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String executedSQl> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.sql.ResultSetMetaData getResultSetMetaData()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: int getColumnCount()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: int columnCount> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.util.List getColumnNames()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List sqlColumns> = v;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List sqlColumns>;
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List columnListForSerializer> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: java.util.List getSqlResultColumns()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List resultColumns> = v;
v = new org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List resultColumns>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData>;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData: void <init>(java.util.List,java.sql.ResultSetMetaData)>(v, v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData resultDBColumnsMetaData> = v;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLExecutionResult: org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.SQLExecutionNode getSQLExecutionNode()>();
v = v.<org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.SQLExecutionNode: org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection connection>;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: void buildTransformersAndBuilder(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode,org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection)>(v, v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.shared.core.api.request.RequestContext requestContext>;
if v == null goto label;
v = <org.finos.legend.engine.plan.execution.stores.StoreExecutableManager: org.finos.legend.engine.plan.execution.stores.StoreExecutableManager INSTANCE>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.shared.core.api.request.RequestContext requestContext>;
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.StoreExecutableManager: void addExecutable(org.finos.legend.engine.shared.core.api.request.RequestContext,org.finos.legend.engine.plan.execution.stores.StoreExecutable)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("error initialising RelationalResult", v);
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: void close()>();
v = v instanceof java.lang.Error;
if v == 0 goto label;
throw v;
label:
v = v instanceof java.lang.RuntimeException;
if v == 0 goto label;
throw v;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void buildTransformersAndBuilder(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode, org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection) throws java.sql.SQLException
{
org.eclipse.collections.api.block.predicate.Predicate v;
java.lang.Integer v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode v;
org.finos.legend.engine.plan.execution.stores.relational.result.DatabaseIdentifiersCaseSensitiveVisitor v;
org.eclipse.collections.api.block.function.Function v, v, v, v, v, v, v;
org.finos.legend.engine.plan.execution.result.builder._class.PartialClassBuilder v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.lang.String v, v, v, v, v;
org.finos.legend.engine.plan.execution.result.builder.datatype.DataTypeBuilder v;
org.finos.legend.engine.plan.execution.result.transformer.TransformerInput v, v;
org.eclipse.collections.api.list.MutableList v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.result.TDSColumn v;
org.finos.legend.engine.plan.execution.stores.relational.result.builder.relation.RelationBuilder v;
org.finos.legend.engine.plan.execution.result.builder.Builder v;
boolean v, v, v, v, v, v;
java.util.List v, v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection v;
java.sql.ResultSetMetaData v, v;
org.eclipse.collections.api.factory.list.MutableListFactory v, v;
int v, v, v, v, v, v, v, v;
java.util.Iterator v;
org.finos.legend.engine.plan.execution.result.builder._class.ClassBuilder v;
org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers v, v, v, v;
java.lang.Object v, v, v;
org.finos.legend.engine.plan.execution.result.builder.tds.TDSBuilder v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection;
v = new org.finos.legend.engine.plan.execution.stores.relational.result.DatabaseIdentifiersCaseSensitiveVisitor;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.DatabaseIdentifiersCaseSensitiveVisitor: void <init>()>();
v = virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.connection.ConnectionVisitor)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = staticinvoke <org.finos.legend.engine.plan.execution.nodes.helpers.ExecutionNodeTDSResultHelper: boolean isResultTDS(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
if v == 0 goto label;
v = <org.eclipse.collections.impl.factory.Lists: org.eclipse.collections.api.factory.list.MutableListFactory mutable>;
v = interfaceinvoke v.<org.eclipse.collections.api.factory.list.MutableListFactory: org.eclipse.collections.api.list.MutableList empty()>();
v = 1;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: int columnCount>;
if v > v goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData>;
v = interfaceinvoke v.<java.sql.ResultSetMetaData: java.lang.String getColumnLabel(int)>(v);
v = staticinvoke <org.finos.legend.engine.plan.execution.nodes.helpers.ExecutionNodeTDSResultHelper: org.finos.legend.engine.protocol.pure.v.model.executionPlan.result.TDSColumn getTDSColumn(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode,java.lang.String,boolean)>(v, v, v);
v = new org.finos.legend.engine.plan.execution.result.transformer.TransformerInput;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = v.<org.finos.legend.engine.protocol.pure.v.model.executionPlan.result.TDSColumn: java.lang.String type>;
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$lambda_buildTransformersAndBuilder_d5f36f75_1__167: org.eclipse.collections.api.block.function.Function bootstrap$(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult,org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode,boolean)>(v, v, v);
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$lambda_buildTransformersAndBuilder_d5f36f75_2__168: org.eclipse.collections.api.block.function.Function bootstrap$(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult,org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode,boolean)>(v, v, v);
specialinvoke v.<org.finos.legend.engine.plan.execution.result.transformer.TransformerInput: void <init>(java.lang.Object,java.lang.String,org.eclipse.collections.api.block.function.Function,org.eclipse.collections.api.block.function.Function)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers>;
v = new org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: void <init>(java.util.List)>(v);
interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: boolean add(java.lang.Object)>(v);
v = new org.finos.legend.engine.plan.execution.result.builder.tds.TDSBuilder;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List sqlColumns>;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.builder.tds.TDSBuilder: void <init>(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode,java.util.List,boolean)>(v, v, v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder> = v;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder>;
v = v.<org.finos.legend.engine.plan.execution.result.builder.tds.TDSBuilder: java.util.List columns>;
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$lambda_buildTransformersAndBuilder_9c893561_1__166: org.eclipse.collections.api.block.function.Function bootstrap$()>();
v = staticinvoke <org.eclipse.collections.impl.utility.ListIterate: org.eclipse.collections.api.list.MutableList collect(java.util.List,org.eclipse.collections.api.block.function.Function)>(v, v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List columnListForSerializer> = v;
goto label;
label:
v = staticinvoke <org.finos.legend.engine.plan.execution.nodes.helpers.ExecutionNodeClassResultHelper: boolean isClassResult(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.plan.execution.nodes.helpers.ExecutionNodeClassResultHelper: org.eclipse.collections.api.list.MutableList getClassMappingInfoFromClassResult(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.eclipse.collections.impl.factory.Lists: org.eclipse.collections.api.factory.list.MutableListFactory mutable>;
v = interfaceinvoke v.<org.eclipse.collections.api.factory.list.MutableListFactory: org.eclipse.collections.api.list.MutableList empty()>();
v = 1;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: int columnCount>;
if v > v goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData>;
v = interfaceinvoke v.<java.sql.ResultSetMetaData: java.lang.String getColumnLabel(int)>(v);
v = v.<org.finos.legend.engine.plan.execution.result.builder._class.ClassMappingInfo: java.util.List properties>;
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$lambda_buildTransformersAndBuilder_4aa90cd6_1__163: org.eclipse.collections.api.block.predicate.Predicate bootstrap$(boolean,java.lang.String)>(v, v);
v = staticinvoke <org.eclipse.collections.impl.utility.ListIterate: org.eclipse.collections.api.list.MutableList select(java.util.List,org.eclipse.collections.api.block.predicate.Predicate)>(v, v);
v = interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: java.lang.Object getFirst()>();
v = new org.finos.legend.engine.plan.execution.result.transformer.TransformerInput;
if v == null goto label;
v = v.<org.finos.legend.engine.plan.execution.result.builder._class.PropertyInfo: java.lang.String property>;
goto label;
label:
v = v;
label:
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String resolveType(org.finos.legend.engine.plan.execution.result.builder._class.PropertyInfo,java.lang.String)>(v, v);
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$lambda_buildTransformersAndBuilder_2451f4c4_1__164: org.eclipse.collections.api.block.function.Function bootstrap$(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode,org.finos.legend.engine.plan.execution.result.builder._class.ClassMappingInfo)>(v, v);
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$lambda_buildTransformersAndBuilder_2451f4c4_2__165: org.eclipse.collections.api.block.function.Function bootstrap$(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode,org.finos.legend.engine.plan.execution.result.builder._class.ClassMappingInfo)>(v, v);
specialinvoke v.<org.finos.legend.engine.plan.execution.result.transformer.TransformerInput: void <init>(java.lang.Object,java.lang.String,org.eclipse.collections.api.block.function.Function,org.eclipse.collections.api.block.function.Function)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers>;
v = new org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: void <init>(java.util.List)>(v);
interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.finos.legend.engine.plan.execution.nodes.helpers.ExecutionNodePartialClassResultHelper: boolean isPartialClassResult(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
if v == 0 goto label;
v = new org.finos.legend.engine.plan.execution.result.builder._class.PartialClassBuilder;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.builder._class.PartialClassBuilder: void <init>(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder> = v;
goto label;
label:
v = new org.finos.legend.engine.plan.execution.result.builder._class.ClassBuilder;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.builder._class.ClassBuilder: void <init>(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder> = v;
goto label;
label:
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.ExecutionNodeRelationalResultHelper: boolean isRelationResult(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
if v == 0 goto label;
v = new org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: void <init>()>();
v = 1;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: int columnCount>;
if v > v goto label;
v = v.<org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: org.eclipse.collections.api.list.MutableList transformers>;
v = <org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: org.eclipse.collections.api.block.function.Function TEMPORARY_DATATYPE_TRANSFORMER>;
interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers>;
interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: boolean add(java.lang.Object)>(v);
v = new org.finos.legend.engine.plan.execution.stores.relational.result.builder.relation.RelationBuilder;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.builder.relation.RelationBuilder: void <init>(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder> = v;
goto label;
label:
v = new org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: void <init>()>();
v = 1;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: int columnCount>;
if v > v goto label;
v = v.<org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: org.eclipse.collections.api.list.MutableList transformers>;
v = <org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: org.eclipse.collections.api.block.function.Function TEMPORARY_DATATYPE_TRANSFORMER>;
interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers>;
interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: boolean add(java.lang.Object)>(v);
v = new org.finos.legend.engine.plan.execution.result.builder.datatype.DataTypeBuilder;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.builder.datatype.DataTypeBuilder: void <init>(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)>(v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder> = v;
label:
return;
}
public java.lang.Object accept(org.finos.legend.engine.plan.execution.result.ResultVisitor)
{
org.finos.legend.engine.plan.execution.result.ResultVisitor v;
java.lang.Object v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: org.finos.legend.engine.plan.execution.result.ResultVisitor;
v = interfaceinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResultVisitor: java.lang.Object visit(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
return v;
}
private static java.lang.String resolveType(org.finos.legend.engine.plan.execution.result.builder._class.PropertyInfo, java.lang.String)
{
org.eclipse.collections.api.list.ImmutableList v;
java.lang.String v, v;
org.finos.legend.engine.plan.execution.result.builder._class.PropertyInfo v;
boolean v;
v := @parameter: org.finos.legend.engine.plan.execution.result.builder._class.PropertyInfo;
v := @parameter: java.lang.String;
if v != null goto label;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.ImmutableList TEMPORAL_DATE_ALIASES>;
v = interfaceinvoke v.<org.eclipse.collections.api.list.ImmutableList: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = "Date";
goto label;
label:
v = null;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.result.builder._class.PropertyInfo: java.lang.String type>;
label:
return v;
}
public java.lang.String getRelationalDatabaseTimeZone()
{
java.lang.String v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String databaseTimeZone>;
return v;
}
public void close()
{
java.sql.Connection v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.sql.ResultSet v, v;
org.slf4j.Logger v, v, v;
org.finos.legend.engine.plan.execution.stores.StoreExecutableManager v;
java.lang.Exception v, v, v;
java.util.function.Consumer v;
java.util.List v, v;
java.sql.Statement v, v, v;
org.finos.legend.engine.shared.core.api.request.RequestContext v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List temporaryTables>;
if v == null goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement>;
if v == null goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List temporaryTables>;
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$lambda_close_0__169: java.util.function.Consumer bootstrap$(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.shared.core.api.request.RequestContext requestContext>;
if v == null goto label;
v = <org.finos.legend.engine.plan.execution.stores.StoreExecutableManager: org.finos.legend.engine.plan.execution.stores.StoreExecutableManager INSTANCE>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.shared.core.api.request.RequestContext requestContext>;
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.StoreExecutableManager: void removeExecutable(org.finos.legend.engine.shared.core.api.request.RequestContext,org.finos.legend.engine.plan.execution.stores.StoreExecutable)>(v, v);
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
if v == null goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
interfaceinvoke v.<java.sql.ResultSet: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("error closing result set", v);
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement>;
if v == null goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement>;
interfaceinvoke v.<java.sql.Statement: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("error closing statement", v);
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Connection connection>;
if v == null goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Connection connection>;
interfaceinvoke v.<java.sql.Connection: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("error closing connection", v);
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public java.util.List getTdsColumns()
{
java.util.List v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.lang.RuntimeException v;
org.finos.legend.engine.plan.execution.result.builder.Builder v, v;
boolean v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder>;
v = v instanceof org.finos.legend.engine.plan.execution.result.builder.tds.TDSBuilder;
if v == 0 goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder>;
v = v.<org.finos.legend.engine.plan.execution.result.builder.tds.TDSBuilder: java.util.List columns>;
return v;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Current result is not a tds result");
throw v;
}
public java.util.List getSQLResultColumns()
{
java.util.List v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List resultColumns>;
return v;
}
public java.util.List getColumnListForSerializer()
{
java.util.List v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.List columnListForSerializer>;
return v;
}
public org.eclipse.collections.api.list.MutableList getTransformers() throws java.sql.SQLException
{
org.eclipse.collections.api.list.MutableList v, v, v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.sql.ResultSet v;
int v, v;
java.lang.Object v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers>;
v = interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: int size()>();
if v != 1 goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers>;
v = interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: java.lang.Object get(int)>(0);
v = v.<org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: org.eclipse.collections.api.list.MutableList transformers>;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.MutableList setTransformers>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: int getInt(java.lang.String)>("u_type");
v = interfaceinvoke v.<org.eclipse.collections.api.list.MutableList: java.lang.Object get(int)>(v);
v = v.<org.finos.legend.engine.plan.execution.result.transformer.SetImplTransformers: org.eclipse.collections.api.list.MutableList transformers>;
label:
return v;
}
public java.lang.Object getValue(int) throws java.sql.SQLException
{
java.sql.Timestamp v;
java.util.Calendar v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.sql.ResultSet v, v, v;
int v;
java.lang.Object v;
org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData v, v;
boolean v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: int;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData resultDBColumnsMetaData>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData: boolean isTimestampColumn(int)>(v);
if v == 0 goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.Calendar getCalendar()>();
v = interfaceinvoke v.<java.sql.ResultSet: java.sql.Timestamp getTimestamp(int,java.util.Calendar)>(v, v);
v = v;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData resultDBColumnsMetaData>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.SQLResultDBColumnsMetaData: boolean isDateColumn(int)>(v);
if v == 0 goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: java.sql.Date getDate(int)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: java.lang.Object getObject(int)>(v);
label:
return v;
}
public java.lang.Object getTransformedValue(int) throws java.sql.SQLException
{
byte[] v;
long v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.sql.ResultSet v, v, v, v, v, v, v, v, v, v, v, v;
int v, v;
java.lang.String v, v;
boolean v, v, v, v;
double v;
java.util.GregorianCalendar v;
java.util.TimeZone v, v;
java.sql.Timestamp v;
java.sql.Date v;
java.lang.Object v;
java.sql.ResultSetMetaData v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: int;
v = null;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSetMetaData resultSetMetaData>;
v = interfaceinvoke v.<java.sql.ResultSetMetaData: int getColumnType(int)>(v);
lookupswitch(v)
{
case -16: goto label;
case -15: goto label;
case -9: goto label;
case -7: goto label;
case -6: goto label;
case -5: goto label;
case -4: goto label;
case -3: goto label;
case -2: goto label;
case -1: goto label;
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
case 8: goto label;
case 12: goto label;
case 16: goto label;
case 91: goto label;
case 93: goto label;
case 1111: goto label;
default: goto label;
};
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: java.sql.Date getDate(int)>(v);
if v == null goto label;
v = staticinvoke <org.finos.legend.engine.plan.dependencies.domain.date.PureDate: org.finos.legend.engine.plan.dependencies.domain.date.PureDate fromSQLDate(java.sql.Date)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String getRelationalDatabaseTimeZone()>();
if v != null goto label;
v = new java.util.GregorianCalendar;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>("GMT");
specialinvoke v.<java.util.GregorianCalendar: void <init>(java.util.TimeZone)>(v);
goto label;
label:
v = new java.util.GregorianCalendar;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String getRelationalDatabaseTimeZone()>();
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>(v);
specialinvoke v.<java.util.GregorianCalendar: void <init>(java.util.TimeZone)>(v);
label:
v = interfaceinvoke v.<java.sql.ResultSet: java.sql.Timestamp getTimestamp(int,java.util.Calendar)>(v, v);
if v == null goto label;
v = staticinvoke <org.finos.legend.engine.plan.dependencies.domain.date.PureDate: org.finos.legend.engine.plan.dependencies.domain.date.PureDate fromSQLTimestamp(java.sql.Timestamp)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: long getLong(int)>(v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: boolean wasNull()>();
if v != 0 goto label;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: double getDouble(int)>(v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: boolean wasNull()>();
if v != 0 goto label;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: java.math.BigDecimal getBigDecimal(int)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: java.lang.String getString(int)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: boolean getBoolean(int)>(v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: boolean wasNull()>();
if v != 0 goto label;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: byte[] getBytes(int)>(v);
if v == null goto label;
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.BinaryUtils: java.lang.String encodeHex(byte[])>(v);
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: java.lang.Object getObject(int)>(v);
label:
return v;
}
public java.sql.ResultSet getResultSet()
{
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.sql.ResultSet v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.ResultSet resultSet>;
return v;
}
public org.finos.legend.engine.plan.execution.result.builder.Builder getResultBuilder()
{
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
org.finos.legend.engine.plan.execution.result.builder.Builder v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.plan.execution.result.builder.Builder builder>;
return v;
}
public org.finos.legend.engine.plan.execution.result.Result realizeInMemory()
{
java.sql.SQLException v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
int v;
java.lang.String v, v;
org.finos.legend.engine.plan.execution.result.ErrorResult v;
org.finos.legend.engine.plan.execution.stores.relational.result.RealizedRelationalResult v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.result.RealizedRelationalResult;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RealizedRelationalResult: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.finos.legend.engine.plan.execution.result.ErrorResult;
v = virtualinvoke v.<java.sql.SQLException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Error realizing the relational result in memory : \u0001");
v = (int) -1;
specialinvoke v.<org.finos.legend.engine.plan.execution.result.ErrorResult: void <init>(int,java.lang.String)>(v, v);
return v;
catch java.sql.SQLException from label to label with label;
}
public org.finos.legend.engine.plan.execution.result.serialization.Serializer getSerializer(org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat)
{
org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat v;
java.lang.RuntimeException v;
org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSSerializer v;
org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToCSVSerializer v;
int[] v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
int v, v;
org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToJsonDefaultSerializer v;
java.lang.String v, v;
org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSToObjectSerializer v;
org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToCSVSerializerWithTransformersApplied v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v := @parameter: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$2: int[] $SwitchMap$org$finos$legend$engine$plan$execution$result$serialization$SerializationFormat>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
default: goto label;
};
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSSerializer;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSSerializer: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
return v;
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSToObjectSerializer;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToPureTDSToObjectSerializer: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
return v;
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToCSVSerializer;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToCSVSerializer: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult,boolean)>(v, 1);
return v;
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToCSVSerializerWithTransformersApplied;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToCSVSerializerWithTransformersApplied: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult,boolean)>(v, 1);
return v;
label:
v = new org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToJsonDefaultSerializer;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.serialization.RelationalResultToJsonDefaultSerializer: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
return v;
label:
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: void close()>();
v = new java.lang.RuntimeException;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u format not currently supported with RelationalResult");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
}
public java.util.stream.Stream toStream()
{
com.fasterxml.jackson.databind.ObjectMapper v;
org.eclipse.collections.api.factory.map.MutableMapFactory v;
java.lang.Runnable v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$1 v;
java.util.stream.Stream v;
org.eclipse.collections.api.map.MutableMap v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.util.stream.BaseStream v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = staticinvoke <org.finos.legend.engine.plan.execution.result.serialization.ExecutionResultObjectMapperFactory: com.fasterxml.jackson.databind.ObjectMapper getNewObjectMapper()>();
v = <org.eclipse.collections.api.factory.Maps: org.eclipse.collections.api.factory.map.MutableMapFactory mutable>;
v = interfaceinvoke v.<org.eclipse.collections.api.factory.map.MutableMapFactory: org.eclipse.collections.api.map.MutableMap empty()>();
v = new org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$1;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$1: void <init>(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult,long,int,java.util.Map,com.fasterxml.jackson.databind.ObjectMapper)>(v, 9223372036854775807L, 0, v, v);
v = staticinvoke <java.util.stream.StreamSupport: java.util.stream.Stream stream(java.util.Spliterator,boolean)>(v, 0);
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult$close__170: java.lang.Runnable bootstrap$(org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.BaseStream onClose(java.lang.Runnable)>(v);
return v;
}
private java.util.Calendar getCalendar()
{
java.util.GregorianCalendar v;
java.util.TimeZone v;
java.util.Calendar v, v, v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.lang.String v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.lang.String getRelationalDatabaseTimeZone()>();
if v == null goto label;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>(v);
goto label;
label:
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>("GMT");
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.Calendar calendar>;
if v != null goto label;
v = new java.util.GregorianCalendar;
specialinvoke v.<java.util.GregorianCalendar: void <init>(java.util.TimeZone)>(v);
v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.Calendar calendar> = v;
goto label;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.Calendar calendar>;
virtualinvoke v.<java.util.Calendar: void clear()>();
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.Calendar calendar>;
virtualinvoke v.<java.util.Calendar: void setTimeZone(java.util.TimeZone)>(v);
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.util.Calendar calendar>;
return v;
}
public void cancel()
{
org.finos.legend.engine.shared.core.operational.logs.LoggingEventType v, v;
org.finos.legend.engine.shared.core.identity.Identity v, v;
org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult v;
java.lang.String v, v, v, v, v, v, v, v, v;
boolean v;
org.slf4j.Logger v, v;
java.lang.Exception v;
org.finos.legend.engine.shared.core.operational.logs.LogInfo v, v;
java.sql.Statement v, v;
org.finos.legend.engine.shared.core.api.request.RequestContext v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult;
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement>;
v = interfaceinvoke v.<java.sql.Statement: boolean isClosed()>();
if v != 0 goto label;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: java.sql.Statement statement>;
interfaceinvoke v.<java.sql.Statement: void cancel()>();
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
v = new org.finos.legend.engine.shared.core.operational.logs.LogInfo;
v = staticinvoke <org.finos.legend.engine.shared.core.identity.Identity: org.finos.legend.engine.shared.core.identity.Identity getAnonymousIdentity()>();
v = virtualinvoke v.<org.finos.legend.engine.shared.core.identity.Identity: java.lang.String getName()>();
v = <org.finos.legend.engine.shared.core.operational.logs.LoggingEventType: org.finos.legend.engine.shared.core.operational.logs.LoggingEventType EXECUTABLE_CANCELLATION>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.shared.core.api.request.RequestContext requestContext>;
v = staticinvoke <org.finos.legend.engine.shared.core.api.request.RequestContext: java.lang.String getSessionID(org.finos.legend.engine.shared.core.api.request.RequestContext)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("Successful cancellation of  RelationalResult \u0001");
specialinvoke v.<org.finos.legend.engine.shared.core.operational.logs.LogInfo: void <init>(java.lang.String,org.finos.legend.engine.shared.core.operational.logs.ILoggingEventType,java.lang.String)>(v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.shared.core.operational.logs.LogInfo: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER>;
v = new org.finos.legend.engine.shared.core.operational.logs.LogInfo;
v = staticinvoke <org.finos.legend.engine.shared.core.identity.Identity: org.finos.legend.engine.shared.core.identity.Identity getAnonymousIdentity()>();
v = virtualinvoke v.<org.finos.legend.engine.shared.core.identity.Identity: java.lang.String getName()>();
v = <org.finos.legend.engine.shared.core.operational.logs.LoggingEventType: org.finos.legend.engine.shared.core.operational.logs.LoggingEventType EXECUTABLE_CANCELLATION_ERROR>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.finos.legend.engine.shared.core.api.request.RequestContext requestContext>;
v = staticinvoke <org.finos.legend.engine.shared.core.api.request.RequestContext: java.lang.String getSessionID(org.finos.legend.engine.shared.core.api.request.RequestContext)>(v);
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("Unable to cancel  RelationalResult  for session \u \u0001");
specialinvoke v.<org.finos.legend.engine.shared.core.operational.logs.LogInfo: void <init>(java.lang.String,org.finos.legend.engine.shared.core.operational.logs.ILoggingEventType,java.lang.String)>(v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.shared.core.operational.logs.LogInfo: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
org.eclipse.collections.api.factory.list.ImmutableListFactory v;
org.eclipse.collections.api.list.ImmutableList v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/finos/legend/engine/plan/execution/stores/relational/result/RelationalResult;");
<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.slf4j.Logger LOGGER> = v;
v = <org.eclipse.collections.impl.factory.Lists: org.eclipse.collections.api.factory.list.ImmutableListFactory immutable>;
v = interfaceinvoke v.<org.eclipse.collections.api.factory.list.ImmutableListFactory: org.eclipse.collections.api.list.ImmutableList of(java.lang.Object,java.lang.Object)>("k_businessDate", "k_processingDate");
<org.finos.legend.engine.plan.execution.stores.relational.result.RelationalResult: org.eclipse.collections.api.list.ImmutableList TEMPORAL_DATE_ALIASES> = v;
return;
}
}