public class org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName extends org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionManagement
{
public void <init>()
{
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionManagement: void <init>()>();
return;
}
public void setup() throws java.lang.Exception
{
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionManagement: void setup()>();
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager getInstance()>();
v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager connectionStateManager> = v;
v = v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager connectionStateManager>;
staticinvoke <org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager: void setInstanceForTesting(org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager)>(v);
return;
}
public void testPoolNameIncludesCredentialType()
{
org.finos.legend.engine.shared.core.identity.Identity v, v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v;
java.util.List v;
org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName v;
java.lang.String v, v;
boolean v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName;
v = new org.finos.legend.engine.shared.core.identity.Identity;
specialinvoke v.<org.finos.legend.engine.shared.core.identity.Identity: void <init>(java.lang.String)>("pool1");
v = new org.finos.legend.engine.shared.core.identity.Identity;
specialinvoke v.<org.finos.legend.engine.shared.core.identity.Identity: void <init>(java.lang.String)>("pool2");
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>("DROP TABLE IF EXISTS T1;");
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification buildLocalDataSourceSpecification(java.util.List)>(v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager connectionStateManager>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceSpecification: org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey getConnectionKey()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager: java.lang.String poolNameFor(org.finos.legend.engine.shared.core.identity.Identity,org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean matches(java.lang.String)>("DBPool_LocalH2_port:\\d{5}_sqlCS:3263863932_type:TestDB_pool1_org\\.finos\\.legend\\.engine\\.shared\\.core\\.identity\\.credential\\.AnonymousCredential");
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestPoolName: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager connectionStateManager>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceSpecification: org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey getConnectionKey()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager: java.lang.String poolNameFor(org.finos.legend.engine.shared.core.identity.Identity,org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey)>(v, v);
v = virtualinvoke v.<java.lang.String: boolean matches(java.lang.String)>("DBPool_LocalH2_port:\\d{5}_sqlCS:3263863932_type:TestDB_pool2_org\\.finos\\.legend\\.engine\\.shared\\.core\\.identity\\.credential\\.AnonymousCredential");
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
return;
}
}