public class org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext extends java.lang.Object
{
private final org.eclipse.collections.api.map.MutableMap blockConnectionMap;
private void <init>(org.eclipse.collections.api.map.MutableMap)
{
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext v;
org.eclipse.collections.api.map.MutableMap v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v := @parameter: org.eclipse.collections.api.map.MutableMap;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: org.eclipse.collections.api.map.MutableMap blockConnectionMap> = v;
return;
}
public void <init>()
{
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext v;
org.eclipse.collections.api.factory.map.MutableMapFactory v;
org.eclipse.collections.api.map.MutableMap v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v = <org.eclipse.collections.impl.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()>();
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: void <init>(org.eclipse.collections.api.map.MutableMap)>(v);
return;
}
public org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection getBlockConnection(org.finos.legend.engine.plan.execution.stores.relational.plugin.RelationalStoreExecutionState, org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection, org.finos.legend.engine.shared.core.identity.Identity)
{
org.finos.legend.engine.shared.core.identity.Identity v;
java.sql.Connection v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionState v, v;
org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector v, v, v;
org.eclipse.collections.api.block.function.Function v;
org.eclipse.collections.api.map.MutableMap v;
boolean v;
org.finos.legend.engine.plan.execution.stores.relational.RelationalExecutor v, v, v;
org.finos.legend.engine.plan.execution.stores.relational.plugin.RelationalStoreExecutionState v;
org.finos.legend.engine.plan.execution.stores.StoreExecutionState$RuntimeContext v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection v;
java.lang.Object v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v := @parameter: org.finos.legend.engine.plan.execution.stores.relational.plugin.RelationalStoreExecutionState;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection;
v := @parameter: org.finos.legend.engine.shared.core.identity.Identity;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: org.eclipse.collections.api.map.MutableMap blockConnectionMap>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.plugin.RelationalStoreExecutionState: org.finos.legend.engine.plan.execution.stores.relational.RelationalExecutor getRelationalExecutor()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.RelationalExecutor: org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector getConnectionManager()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector: org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey generateKeyFromDatabaseConnection(org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection)>(v);
v = interfaceinvoke v.<org.eclipse.collections.api.map.MutableMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.plugin.RelationalStoreExecutionState: org.finos.legend.engine.plan.execution.stores.relational.RelationalExecutor getRelationalExecutor()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.RelationalExecutor: org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector getConnectionManager()>();
v = new org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.plugin.RelationalStoreExecutionState: org.finos.legend.engine.plan.execution.stores.relational.RelationalExecutor getRelationalExecutor()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.RelationalExecutor: org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector getConnectionManager()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.plugin.RelationalStoreExecutionState: org.finos.legend.engine.plan.execution.stores.StoreExecutionState$RuntimeContext getRuntimeContext()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector: java.sql.Connection getDatabaseConnection(org.finos.legend.engine.shared.core.identity.Identity,org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection,org.finos.legend.engine.plan.execution.stores.StoreExecutionState$RuntimeContext)>(v, v, v);
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection: void <init>(java.sql.Connection)>(v);
v = specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection setBlockConnection(org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector,org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection,org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection)>(v, v, v);
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionState blockConnectionState>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionState: boolean isConnectionAvailable()>();
if v != 0 goto label;
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext$lambda_getBlockConnection_522ae73d_1__69: org.eclipse.collections.api.block.function.Function bootstrap$(org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection)>(v);
staticinvoke <org.finos.legend.engine.shared.core.operational.Assert: void fail(org.eclipse.collections.api.block.function.Function)>(v);
label:
v = v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionState blockConnectionState>;
virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionState: void hasOpenResultSet()>();
return v;
}
public void unlockAllBlockConnections()
{
java.util.function.Consumer v;
org.eclipse.collections.api.map.MutableMap v;
java.util.Collection v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: org.eclipse.collections.api.map.MutableMap blockConnectionMap>;
v = interfaceinvoke v.<org.eclipse.collections.api.map.MutableMap: java.util.Collection values()>();
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext$lambda_unlockAllBlockConnections_0__70: java.util.function.Consumer bootstrap$()>();
interfaceinvoke v.<java.util.Collection: void forEach(java.util.function.Consumer)>(v);
return;
}
public void closeAllBlockConnections()
{
java.util.function.Consumer v;
org.eclipse.collections.api.map.MutableMap v;
java.util.Collection v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: org.eclipse.collections.api.map.MutableMap blockConnectionMap>;
v = interfaceinvoke v.<org.eclipse.collections.api.map.MutableMap: java.util.Collection values()>();
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext$close__71: java.util.function.Consumer bootstrap$()>();
interfaceinvoke v.<java.util.Collection: void forEach(java.util.function.Consumer)>(v);
return;
}
public void closeAllBlockConnectionsAsync()
{
java.util.function.Consumer v;
org.eclipse.collections.api.map.MutableMap v;
java.util.Collection v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: org.eclipse.collections.api.map.MutableMap blockConnectionMap>;
v = interfaceinvoke v.<org.eclipse.collections.api.map.MutableMap: java.util.Collection values()>();
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext$lambda_closeAllBlockConnectionsAsync_1__72: java.util.function.Consumer bootstrap$()>();
interfaceinvoke v.<java.util.Collection: void forEach(java.util.function.Consumer)>(v);
return;
}
private org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection setBlockConnection(org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector, org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection, org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection)
{
org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection v;
org.eclipse.collections.api.map.MutableMap v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v := @parameter: org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection;
v := @parameter: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnection;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.manager.ConnectionManagerSelector: org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey generateKeyFromDatabaseConnection(org.finos.legend.engine.protocol.pure.v.model.packageableElement.store.relational.connection.DatabaseConnection)>(v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: org.eclipse.collections.api.map.MutableMap blockConnectionMap>;
interfaceinvoke v.<org.eclipse.collections.api.map.MutableMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext copy()
{
org.eclipse.collections.api.map.MutableMap v, v;
org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext v, v;
org.eclipse.collections.api.factory.map.MutableMapFactory v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v = new org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext;
v = <org.eclipse.collections.impl.factory.Maps: org.eclipse.collections.api.factory.map.MutableMapFactory mutable>;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: org.eclipse.collections.api.map.MutableMap blockConnectionMap>;
v = interfaceinvoke v.<org.eclipse.collections.api.factory.map.MutableMapFactory: org.eclipse.collections.api.map.MutableMap ofMap(java.util.Map)>(v);
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.blockConnection.BlockConnectionContext: void <init>(org.eclipse.collections.api.map.MutableMap)>(v);
return v;
}
}