1. 包列表
  2. 类列表
  3. com.mysql.jdbc.ConnectionGroupManager

Java 类com.mysql.jdbc.ConnectionGroupManager 实例源码

项目：the-vigilantes    文件：ConnectionRegressionTest.java    
/**
 * Tests fix for Bug#22730682 - ARRAYINDEXOUTOFBOUNDSEXCEPTION FROM CONNECTIONGROUPMANAGER.REMOVEHOST().
 * 
 * This bug was caused by an incorrect array handling when removing an host from a load balanced connection group, with the option to affect existing
 * connections.
 */
public void testBug22730682() throws Exception {
    Properties connProps = getPropertiesFromTestsuiteUrl();
    String host = connProps.getProperty(NonRegisteringDriver.HOST_PROPERTY_KEY, "localhost");
    String port = connProps.getProperty(NonRegisteringDriver.PORT_PROPERTY_KEY, "3306");

    final String currentHost = host + ":" + port;
    final String dummyHost = "bug22730682:12345";

    final Properties props = new Properties();
    Connection testConn;

    final String lbConnGroup1 = "Bug22730682LB1";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup1);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup1, dummyHost);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    testConn.close();

    final String lbConnGroup2 = "Bug22730682LB2";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup2);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup2, dummyHost, true);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    testConn.close();
}
项目：the-vigilantes    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：OpenVertretung    文件：ConnectionRegressionTest.java    
/**
 * Tests fix for Bug#22730682 - ARRAYINDEXOUTOFBOUNDSEXCEPTION FROM CONNECTIONGROUPMANAGER.REMOVEHOST().
 * 
 * This bug was caused by an incorrect array handling when removing an host from a load balanced connection group, with the option to affect existing
 * connections.
 */
public void testBug22730682() throws Exception {
    Properties connProps = getPropertiesFromTestsuiteUrl();
    String host = connProps.getProperty(NonRegisteringDriver.HOST_PROPERTY_KEY, "localhost");
    String port = connProps.getProperty(NonRegisteringDriver.PORT_PROPERTY_KEY, "3306");

    final String currentHost = host + ":" + port;
    final String dummyHost = "bug22730682:12345";

    final Properties props = new Properties();
    Connection testConn;

    final String lbConnGroup1 = "Bug22730682LB1";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup1);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup1, dummyHost);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    testConn.close();

    final String lbConnGroup2 = "Bug22730682LB2";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup2);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup2, dummyHost, true);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    testConn.close();
}
项目：OpenVertretung    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：lams    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：ProyectoPacientes    文件：ConnectionRegressionTest.java    
/**
 * Tests fix for Bug#22730682 - ARRAYINDEXOUTOFBOUNDSEXCEPTION FROM CONNECTIONGROUPMANAGER.REMOVEHOST().
 * 
 * This bug was caused by an incorrect array handling when removing an host from a load balanced connection group, with the option to affect existing
 * connections.
 */
public void testBug22730682() throws Exception {
    Properties connProps = getPropertiesFromTestsuiteUrl();
    String host = connProps.getProperty(NonRegisteringDriver.HOST_PROPERTY_KEY, "localhost");
    String port = connProps.getProperty(NonRegisteringDriver.PORT_PROPERTY_KEY, "3306");

    final String currentHost = host + ":" + port;
    final String dummyHost = "bug22730682:12345";

    final Properties props = new Properties();
    Connection testConn;

    final String lbConnGroup1 = "Bug22730682LB1";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup1);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup1, dummyHost);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    testConn.close();

    final String lbConnGroup2 = "Bug22730682LB2";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup2);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup2, dummyHost, true);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    testConn.close();
}
项目：ProyectoPacientes    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：BibliotecaPS    文件：ConnectionRegressionTest.java    
/**
 * Tests fix for Bug#22730682 - ARRAYINDEXOUTOFBOUNDSEXCEPTION FROM CONNECTIONGROUPMANAGER.REMOVEHOST().
 * 
 * This bug was caused by an incorrect array handling when removing an host from a load balanced connection group, with the option to affect existing
 * connections.
 */
public void testBug22730682() throws Exception {
    Properties connProps = getPropertiesFromTestsuiteUrl();
    String host = connProps.getProperty(NonRegisteringDriver.HOST_PROPERTY_KEY, "localhost");
    String port = connProps.getProperty(NonRegisteringDriver.PORT_PROPERTY_KEY, "3306");

    final String currentHost = host + ":" + port;
    final String dummyHost = "bug22730682:12345";

    final Properties props = new Properties();
    Connection testConn;

    final String lbConnGroup1 = "Bug22730682LB1";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup1);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup1, dummyHost);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    testConn.close();

    final String lbConnGroup2 = "Bug22730682LB2";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup2);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup2, dummyHost, true);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    testConn.close();
}
项目：BibliotecaPS    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：Geometry-wars    文件：ConnectionRegressionTest.java    
/**
 * Tests fix for Bug#22730682 - ARRAYINDEXOUTOFBOUNDSEXCEPTION FROM CONNECTIONGROUPMANAGER.REMOVEHOST().
 * 
 * This bug was caused by an incorrect array handling when removing an host from a load balanced connection group, with the option to affect existing
 * connections.
 */
public void testBug22730682() throws Exception {
    Properties connProps = getPropertiesFromTestsuiteUrl();
    String host = connProps.getProperty(NonRegisteringDriver.HOST_PROPERTY_KEY, "localhost");
    String port = connProps.getProperty(NonRegisteringDriver.PORT_PROPERTY_KEY, "3306");

    final String currentHost = host + ":" + port;
    final String dummyHost = "bug22730682:12345";

    final Properties props = new Properties();
    Connection testConn;

    final String lbConnGroup1 = "Bug22730682LB1";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup1);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup1, dummyHost);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup1));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup1).contains(currentHost));
    testConn.close();

    final String lbConnGroup2 = "Bug22730682LB2";
    props.setProperty("loadBalanceConnectionGroup", lbConnGroup2);
    testConn = getLoadBalancedConnection(3, dummyHost, props);
    assertEquals(2, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(dummyHost));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    ConnectionGroupManager.removeHost(lbConnGroup2, dummyHost, true);
    assertEquals(1, ConnectionGroupManager.getActiveHostCount(lbConnGroup2));
    assertTrue(ConnectionGroupManager.getActiveHostLists(lbConnGroup2).contains(currentHost));
    testConn.close();
}
项目：Geometry-wars    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：TPKB    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：cloudera-cli-scripts    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：fil_project_mgmt_app_v2    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
    ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e){
        e.printStackTrace();
    }
}
项目：indoor-tracking    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
    ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e){
        e.printStackTrace();
    }
}
项目：SMPT42    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：ForYou    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
    ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e){
        e.printStackTrace();
    }
}
项目：group-five    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：locaviewer    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：locaviewer    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
        ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
项目：manydesigns.cn    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
    ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e){
        e.printStackTrace();
    }
}
项目：Gladiatus    文件：LoadBalanceConnectionGroupManager.java    
public void addHost(String group, String host, boolean forExisting) {
    try {
    ConnectionGroupManager.addHost(group, host, forExisting);
    } catch (Exception e){
        e.printStackTrace();
    }
}
项目：the-vigilantes    文件：LoadBalanceConnectionGroupManager.java    
public int getActiveHostCount(String group) {
    return ConnectionGroupManager.getActiveHostCount(group);
}
项目：the-vigilantes    文件：LoadBalanceConnectionGroupManager.java    
public long getActiveLogicalConnectionCount(String group) {
    return ConnectionGroupManager.getActiveLogicalConnectionCount(group);
}
项目：the-vigilantes    文件：LoadBalanceConnectionGroupManager.java    
public long getActivePhysicalConnectionCount(String group) {
    return ConnectionGroupManager.getActivePhysicalConnectionCount(group);
}
项目：the-vigilantes    文件：LoadBalanceConnectionGroupManager.java    
public String getActiveHostsList(String group) {
    return ConnectionGroupManager.getActiveHostLists(group);
}
项目：the-vigilantes    文件：LoadBalanceConnectionGroupManager.java    
public String getRegisteredConnectionGroups() {
    return ConnectionGroupManager.getRegisteredConnectionGroups();
}
项目：OpenVertretung    文件：LoadBalanceConnectionGroupManager.java    
public int getActiveHostCount(String group) {
    return ConnectionGroupManager.getActiveHostCount(group);
}
项目：OpenVertretung    文件：LoadBalanceConnectionGroupManager.java    
public long getActiveLogicalConnectionCount(String group) {
    return ConnectionGroupManager.getActiveLogicalConnectionCount(group);
}
项目：OpenVertretung    文件：LoadBalanceConnectionGroupManager.java    
public long getActivePhysicalConnectionCount(String group) {
    return ConnectionGroupManager.getActivePhysicalConnectionCount(group);
}
项目：OpenVertretung    文件：LoadBalanceConnectionGroupManager.java    
public String getActiveHostsList(String group) {
    return ConnectionGroupManager.getActiveHostLists(group);
}
项目：OpenVertretung    文件：LoadBalanceConnectionGroupManager.java    
public String getRegisteredConnectionGroups() {
    return ConnectionGroupManager.getRegisteredConnectionGroups();
}
项目：lams    文件：LoadBalanceConnectionGroupManager.java    
public int getActiveHostCount(String group) {
    return ConnectionGroupManager.getActiveHostCount(group);
}
项目：lams    文件：LoadBalanceConnectionGroupManager.java    
public long getActiveLogicalConnectionCount(String group) {
    return ConnectionGroupManager.getActiveLogicalConnectionCount(group);
}
项目：lams    文件：LoadBalanceConnectionGroupManager.java    
public long getActivePhysicalConnectionCount(String group) {
    return ConnectionGroupManager.getActivePhysicalConnectionCount(group);
}
项目：lams    文件：LoadBalanceConnectionGroupManager.java    
public String getActiveHostsList(String group) {
    return ConnectionGroupManager.getActiveHostLists(group);
}
项目：lams    文件：LoadBalanceConnectionGroupManager.java    
public String getRegisteredConnectionGroups() {
    return ConnectionGroupManager.getRegisteredConnectionGroups();
}
项目：ProyectoPacientes    文件：LoadBalanceConnectionGroupManager.java    
public int getActiveHostCount(String group) {
    return ConnectionGroupManager.getActiveHostCount(group);
}
项目：ProyectoPacientes    文件：LoadBalanceConnectionGroupManager.java    
public long getActiveLogicalConnectionCount(String group) {
    return ConnectionGroupManager.getActiveLogicalConnectionCount(group);
}
项目：ProyectoPacientes    文件：LoadBalanceConnectionGroupManager.java    
public long getActivePhysicalConnectionCount(String group) {
    return ConnectionGroupManager.getActivePhysicalConnectionCount(group);
}