public class org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager extends org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionManagement { public org.junit.rules.ExpectedException exceptionRule; public void () { org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; org.junit.rules.ExpectedException v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; specialinvoke v.()>(); v = staticinvoke (); v. = v; return; } public void setup() throws java.lang.Exception { org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.FakeClock v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; specialinvoke v.(); v = v.; v = staticinvoke (v); v. = v; return; } public void testDefaultEvictionDuration() { org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; java.time.Duration v; long v, v; java.lang.String v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = ; staticinvoke (v); v = staticinvoke (); v = staticinvoke (10L); v = virtualinvoke v.(); staticinvoke (v, v); return; } public void testNonDefaultEvictionDuration() { long v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; java.lang.String v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = ; staticinvoke (v, "4567"); v = staticinvoke (); staticinvoke (4567L, v); return; } public void testDataSourceConnectionsRequest() { org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v; java.lang.String[] v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; int v; java.util.List v, v, v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = newarray (java.lang.String)[1]; v[0] = "DROP TABLE IF EXISTS T1"; v = staticinvoke (v); v = virtualinvoke v.(v); v = newarray (java.lang.String)[1]; v[0] = "DROP TABLE IF EXISTS T2"; v = staticinvoke (v); v = virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(0, "user1", v); v = virtualinvoke v.(); virtualinvoke v.(0, "user2", v); v = virtualinvoke v.(); virtualinvoke v.(0, "user3", v); virtualinvoke v.("user1", v); virtualinvoke v.("user2", v); virtualinvoke v.("user3", v); virtualinvoke v.("user1", v); v = v.; v = virtualinvoke v.(); staticinvoke (3L, v); v = virtualinvoke v.(); virtualinvoke v.(1, "user1", v); v = virtualinvoke v.(); virtualinvoke v.(1, "user2", v); v = virtualinvoke v.(); virtualinvoke v.(1, "user3", v); return; } public void testMetricCreationForNewConnectionPoolUsingHouseKeeperRun() { org.finos.legend.engine.shared.core.identity.Identity v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v; java.time.Duration v, v; io.prometheus.client.CollectorRegistry v; java.util.List v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.FakeClock v; java.lang.Double v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v, v; java.lang.String[] v, v, v, v, v, v, v; long v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceWithStatistics v, v; java.lang.String v; double v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = ; v = newarray (java.lang.String)[1]; v[0] = "DROP TABLE IF EXISTS T1"; v = staticinvoke (v); v = virtualinvoke v.(v); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask; v = staticinvoke (5L); v = virtualinvoke v.(); specialinvoke v.(long)>(v); virtualinvoke v.(v, v); v = v.; v = staticinvoke (11L); virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("total_connections", v, v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("idle_connections", v, v); v = virtualinvoke v.(); staticinvoke (0.0, v, 0.0); return; } public void testMetricUpdateForActiveConnectionPoolUsingHouseKeeperRun() { java.time.Duration v, v, v; io.prometheus.client.CollectorRegistry v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.FakeClock v, v; java.lang.Double v, v, v, v, v, v, v, v, v, v; long v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; java.lang.String v, v; org.finos.legend.engine.shared.core.identity.Identity v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey 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.ConnectionStateManager v, v, v, v, v, v, v, v, v; java.lang.String[] v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceWithStatistics v, v, v, v, v, v, v, v; double v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = ; v = newarray (java.lang.String)[1]; v[0] = "DROP TABLE IF EXISTS T1"; v = staticinvoke (v); v = virtualinvoke v.(v); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask; v = staticinvoke (5L); v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); virtualinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = v.; v = staticinvoke (11L); virtualinvoke v.(v); virtualinvoke v.(); virtualinvoke v.(v, v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); staticinvoke (v, v); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("total_connections", v, v); staticinvoke (v, v); v = v.; v = staticinvoke (11L); virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); v = virtualinvoke v.(); staticinvoke (v, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("total_connections", v, v); v = virtualinvoke v.(); staticinvoke (v, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("idle_connections", v, v); v = virtualinvoke v.(); staticinvoke (v, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (3.0, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (3.0, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (0.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); v = virtualinvoke v.(); staticinvoke (3.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("total_connections", v, v); v = virtualinvoke v.(); staticinvoke (3.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("idle_connections", v, v); v = virtualinvoke v.(); staticinvoke (0.0, v, 0.0); return; } public void testMetricDeletionForEvictedConnectionPoolsFromHouseKeeperRun() { org.finos.legend.engine.shared.core.identity.Identity v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v; java.time.Duration v, v, v; io.prometheus.client.CollectorRegistry v; java.util.List v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.FakeClock v, v; java.lang.Double v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v, v, v, v, v; java.lang.String[] v, v, v, v, v, v, v, v, v, v, v; long v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceWithStatistics v, v, v, v, v; java.lang.String v, v, v; double v, v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = ; v = newarray (java.lang.String)[1]; v[0] = "DROP TABLE IF EXISTS T2"; v = staticinvoke (v); v = virtualinvoke v.(v); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user2"); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask; v = staticinvoke (5L); v = virtualinvoke v.(); specialinvoke v.(long)>(v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = v.; v = staticinvoke (11L); virtualinvoke v.(v); virtualinvoke v.(); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("total_connections", v, v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("idle_connections", v, v); v = virtualinvoke v.(); staticinvoke (0.0, v, 0.0); v = v.; v = virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (0.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = v.; v = staticinvoke (11L); virtualinvoke v.(v); virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = v.; v = virtualinvoke v.(v); staticinvoke (v, null); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); staticinvoke (null, v); return; } public void testMetricsUpdateWithIdleConnectionInActivePool() throws java.sql.SQLException { org.finos.legend.engine.shared.core.identity.Identity v; java.sql.Connection v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v; java.time.Duration v, v; io.prometheus.client.CollectorRegistry v; java.util.List v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.FakeClock v; java.lang.Double v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v, v, v; java.lang.String[] v, v, v, v, v, v, v, v, v; long v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceWithStatistics v, v, v; java.lang.String v, v; double v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = ; v = newarray (java.lang.String)[1]; v[0] = "DROP TABLE IF EXISTS T1"; v = staticinvoke (v); v = virtualinvoke v.(v); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask; v = staticinvoke (5L); v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); virtualinvoke v.(v, v); v = virtualinvoke v.(v, v); interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (2.0, v, 0.0); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); staticinvoke (null, v); v = v.; v = staticinvoke (11L); virtualinvoke v.(v); virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("active_connections", v, v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("total_connections", v, v); v = virtualinvoke v.(); staticinvoke (2.0, v, 0.0); v = newarray (java.lang.String)[1]; v[0] = "poolName"; v = newarray (java.lang.String)[1]; v[0] = v; v = virtualinvoke v.("idle_connections", v, v); v = virtualinvoke v.(); staticinvoke (1.0, v, 0.0); return; } public void testDataSourceRegistrationSequentialCalls() { org.finos.legend.engine.shared.core.identity.Identity v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, v, v, v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v, v; java.util.List v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v, v, v, v, v; java.lang.String[] v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user2"); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = v.; v = virtualinvoke v.(); staticinvoke (0L, v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); staticinvoke (1L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = newarray (java.lang.String)[1]; v[0] = v; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); staticinvoke (1L, v); v = staticinvoke (); v = virtualinvoke v.(v); virtualinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v); v = v.; v = virtualinvoke v.(); staticinvoke (2L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = newarray (java.lang.String)[2]; v[0] = v; v[1] = v; virtualinvoke v.(v); return; } public void testDataSourceEviction() throws java.sql.SQLException { org.finos.legend.engine.shared.core.identity.Identity v, v, v; java.sql.Connection v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v, v; java.time.Duration v, v, v, v; java.util.List v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.FakeClock v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v, v, v, v, v, v, v; java.lang.String[] v, v, v; long v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; int v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user2"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user3"); v = newarray (java.lang.String)[1]; v[0] = "DROP TABLE IF EXISTS T1"; v = staticinvoke (v); v = virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask; v = staticinvoke (5L); v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = virtualinvoke v.(v, v); v = virtualinvoke v.(v, v); interfaceinvoke v.(); interfaceinvoke v.(); v = v.; v = staticinvoke (4L); virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (2L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = newarray (java.lang.String)[2]; v[0] = v; v[1] = v; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); staticinvoke (2L, v); v = v.; v = staticinvoke (5L); virtualinvoke v.(v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = v.; v = virtualinvoke v.(); staticinvoke (3L, v); v = v.; v = staticinvoke (2L); virtualinvoke v.(v); virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = v.; v = virtualinvoke v.(); staticinvoke (1L, v); v = newarray (java.lang.String)[1]; v[0] = v; virtualinvoke v.(v); return; } public void testDataSourceEvictionWithUnclosedConnection() throws java.sql.SQLException { java.time.Duration v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.FakeClock v, v, v; long v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.shared.core.identity.Identity v, v, v; java.sql.Connection v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v, v; java.util.List v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v, v, v, v, v, v, v, v; java.lang.String[] v, v, v, v, v; int v, v, v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user2"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user3"); v = newarray (java.lang.String)[1]; v[0] = "DROP TABLE IF EXISTS T1"; v = staticinvoke (v); v = virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask; v = staticinvoke (5L); v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = virtualinvoke v.(v, v); v = virtualinvoke v.(v, v); interfaceinvoke v.(); v = v.; v = staticinvoke (4L); virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (2L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = newarray (java.lang.String)[2]; v[0] = v; v[1] = v; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); staticinvoke (2L, v); v = v.; v = staticinvoke (5L); virtualinvoke v.(v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); staticinvoke (v); v = v.; v = virtualinvoke v.(); staticinvoke (3L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = v.; v = staticinvoke (2L); virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (2L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = newarray (java.lang.String)[1]; v[0] = v; virtualinvoke v.(v); v = newarray (java.lang.String)[1]; v[0] = v; virtualinvoke v.(v); interfaceinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (1L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = newarray (java.lang.String)[1]; v[0] = v; virtualinvoke v.(v); return; } public void testDataSourceEvictionForDatasourceWithConnectionErrors() throws java.sql.SQLException { org.finos.legend.engine.shared.core.identity.Identity v; java.sql.Connection v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v, v; long v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceWithStatistics v; java.time.Duration v, v, v; int v, v, v; java.lang.String v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceStatistics v; java.util.List v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.FakeClock v, v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = staticinvoke ("DROP TABLE IF EXISTS T1"); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager$ConnectionStateHousekeepingTask; v = staticinvoke (5L); v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = virtualinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = virtualinvoke v.(); virtualinvoke v.(); interfaceinvoke v.(); v = v.; v = staticinvoke (4L); virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (1L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(1, v, v); v = v.; v = staticinvoke (2L); virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); return; } public void testDataSourceManualEvictionOnExceptionsDuringDatasourceBuild() { org.finos.legend.engine.plan.execution.stores.relational.connection.authentication.strategy.TestDatabaseAuthenticationStrategy v; org.finos.legend.engine.shared.core.identity.Identity 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; java.lang.Exception 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.TestConnectionStateManager v; int v, v; java.lang.String v, v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification; v = staticinvoke (); v = new org.finos.legend.engine.plan.execution.stores.relational.connection.authentication.strategy.TestDatabaseAuthenticationStrategy; specialinvoke v.()>(); specialinvoke v.(java.util.List,org.finos.legend.engine.plan.execution.stores.relational.connection.driver.DatabaseManager,org.finos.legend.engine.plan.execution.stores.relational.connection.authentication.AuthenticationStrategy)>(v, null, v); v = v.; v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); label: virtualinvoke v.(v, v); staticinvoke ("Exception not thrown while building datasource"); label: goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); label: return; catch java.lang.Exception from label to label with label; } public void canGetAggregatedStats() { org.finos.legend.engine.shared.core.identity.Identity v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v; long v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v; java.util.ArrayList v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; boolean v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManagerPOJO$PoolDynamic v, v, v, v; java.util.Set v; java.util.List v; java.lang.Object v, v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManagerPOJO v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user2"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user3"); v = staticinvoke (); v = virtualinvoke v.(v); virtualinvoke v.(v, v); virtualinvoke v.(v, v); virtualinvoke v.(v, v); v = new java.util.ArrayList; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); staticinvoke (v); v = interfaceinvoke v.(0); v = v.; v = v.; staticinvoke (3L, v); v = interfaceinvoke v.(0); v = v.; v = v.; staticinvoke (0L, v); v = interfaceinvoke v.(0); v = v.; v = v.; staticinvoke (3L, v); v = interfaceinvoke v.(0); v = v.; v = v.; staticinvoke (0L, v); return; } public void testShutdown() throws java.io.IOException { org.finos.legend.engine.shared.core.identity.Identity v, v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v, 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.TestConnectionStateManager v; int v; java.lang.String v, v, v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user1"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user2"); v = new org.finos.legend.engine.shared.core.identity.Identity; specialinvoke v.(java.lang.String)>("user3"); v = staticinvoke (); v = virtualinvoke v.(v); virtualinvoke v.(v, v); virtualinvoke v.(v, v); virtualinvoke v.(v, v); v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0, v, v); return; } public void testPoolIdentityIsValid() { org.finos.legend.engine.shared.core.identity.Identity v; org.finos.legend.engine.plan.execution.stores.relational.connection.ConnectionKey v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.ConnectionStateManager v, v, v, v, v; long v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.specifications.LocalH2DataSourceSpecification v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceWithStatistics v, v; int v, v; java.lang.Boolean v, v, v, v; java.lang.String v; org.finos.legend.engine.shared.core.identity.Credential[] v; org.junit.rules.ExpectedException v, v; boolean v, v; org.mockito.stubbing.OngoingStubbing v, v; org.finos.legend.engine.plan.execution.stores.relational.connection.ds.DataSourceStatistics v, v; java.util.List v; java.lang.Object v; v := @this: org.finos.legend.engine.plan.execution.stores.relational.connection.ds.state.TestConnectionStateManager; v = staticinvoke (class "Lorg/finos/legend/engine/shared/core/identity/Credential;"); v = new org.finos.legend.engine.shared.core.identity.Identity; v = newarray (org.finos.legend.engine.shared.core.identity.Credential)[1]; v[0] = v; specialinvoke v.(java.lang.String,org.finos.legend.engine.shared.core.identity.Credential[])>("mock", v); v = interfaceinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); v = staticinvoke (1); interfaceinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); staticinvoke (v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); staticinvoke (1L, v); v = v.; v = virtualinvoke v.(v); virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); staticinvoke (1L, v); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v); v = v.; virtualinvoke v.(class "Ljava/lang/RuntimeException;"); v = v.; virtualinvoke v.("Invalid Identity found, cannot build connection pool for mock"); v = interfaceinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); v = staticinvoke (0); interfaceinvoke v.(v); virtualinvoke v.(v, v); return; } }