Class ConnectionGroup

java.lang.Object
com.mysql.jdbc.ConnectionGroup

public class ConnectionGroup extends Object
  • Constructor Details

    • ConnectionGroup

      ConnectionGroup(String groupName)
  • Method Details

    • registerConnectionProxy

      public long registerConnectionProxy(LoadBalancedConnectionProxy proxy, List<String> localHostList)
    • getGroupName

      public String getGroupName()
    • getInitialHosts

      public Collection<String> getInitialHosts()
    • getActiveHostCount

      public int getActiveHostCount()
    • getClosedHosts

      public Collection<String> getClosedHosts()
    • getTotalLogicalConnectionCount

      public long getTotalLogicalConnectionCount()
    • getActiveLogicalConnectionCount

      public long getActiveLogicalConnectionCount()
    • getActivePhysicalConnectionCount

      public long getActivePhysicalConnectionCount()
    • getTotalPhysicalConnectionCount

      public long getTotalPhysicalConnectionCount()
    • getTotalTransactionCount

      public long getTotalTransactionCount()
    • closeConnectionProxy

      public void closeConnectionProxy(LoadBalancedConnectionProxy proxy)
    • removeHost

      public void removeHost(String hostPortPair) throws SQLException
      Remove the given host (host:port pair) from this Connection Group.
      Parameters:
      hostPortPair - The host:port pair to remove.
      Throws:
      SQLException
    • removeHost

      public void removeHost(String hostPortPair, boolean removeExisting) throws SQLException
      Remove the given host (host:port pair) from this Connection Group.
      Parameters:
      hostPortPair - The host:port pair to remove.
      removeExisting - Whether affects existing load-balanced connections or only new ones.
      Throws:
      SQLException
    • removeHost

      public void removeHost(String hostPortPair, boolean removeExisting, boolean waitForGracefulFailover) throws SQLException
      Remove the given host (host:port pair) from this Connection Group and, consequently, from all the load-balanced connections it holds.
      Parameters:
      hostPortPair - The host:port pair to remove.
      removeExisting - Whether affects existing load-balanced connections or only new ones.
      waitForGracefulFailover - If true instructs the load-balanced connections to fail-over the underlying active connection before removing this host, otherwise remove immediately.
      Throws:
      SQLException
    • addHost

      public void addHost(String hostPortPair)
      Add the given host (host:port pair) to this Connection Group.
      Parameters:
      hostPortPair - The host:port pair to add.
      Throws:
      SQLException
    • addHost

      public void addHost(String hostPortPair, boolean forExisting)
      Add the given host (host:port pair) to this Connection Group and, consequently, to all the load-balanced connections it holds.
      Parameters:
      hostPortPair - The host:port pair to add.
      forExisting - Whether affects existing load-balanced connections or only new ones.