com.mysql.cj.jdbc

Class ConnectionGroup

java.lang.Object

com.mysql.cj.jdbc.ConnectionGroup

public class ConnectionGroup
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private long	activeConnections
private int	activeHosts
private java.util.Set<java.lang.String>	closedHosts
private long	closedProxyTotalPhysicalConnections
private long	closedProxyTotalTransactions
private java.util.HashMap<java.lang.Long,LoadBalancedConnectionProxy>	connectionProxies
private long	connections
private java.lang.String	groupName
private java.util.Set<java.lang.String>	hostList
private boolean	isInitialized

Constructor Summary

Constructors

Constructor and Description
ConnectionGroup(java.lang.String groupName)

Method Summary

Modifier and Type	Method and Description
void	addHost(java.lang.String hostPortPair) Add the given host (host:port pair) to this Connection Group.
void	addHost(java.lang.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.
void	closeConnectionProxy(LoadBalancedConnectionProxy proxy)
int	getActiveHostCount()
long	getActiveLogicalConnectionCount()
long	getActivePhysicalConnectionCount()
java.util.Collection<java.lang.String>	getClosedHosts()
java.lang.String	getGroupName()
java.util.Collection<java.lang.String>	getInitialHosts()
long	getTotalLogicalConnectionCount()
long	getTotalPhysicalConnectionCount()
long	getTotalTransactionCount()
long	registerConnectionProxy(LoadBalancedConnectionProxy proxy, java.util.List<java.lang.String> localHostList)
void	removeHost(java.lang.String hostPortPair) Remove the given host (host:port pair) from this Connection Group.
void	removeHost(java.lang.String hostPortPair, boolean removeExisting) Remove the given host (host:port pair) from this Connection Group.
void	removeHost(java.lang.String hostPortPair, boolean removeExisting, boolean waitForGracefulFailover) Remove the given host (host:port pair) from this Connection Group and, consequently, from all the load-balanced connections it holds.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

groupName

private java.lang.String groupName

connections

private long connections

activeConnections

private long activeConnections

connectionProxies

private java.util.HashMap<java.lang.Long,LoadBalancedConnectionProxy> connectionProxies

hostList

private java.util.Set<java.lang.String> hostList

isInitialized

private boolean isInitialized

closedProxyTotalPhysicalConnections

private long closedProxyTotalPhysicalConnections

closedProxyTotalTransactions

private long closedProxyTotalTransactions

activeHosts

private int activeHosts

closedHosts

private java.util.Set<java.lang.String> closedHosts

Constructor Detail

ConnectionGroup

ConnectionGroup(java.lang.String groupName)

Method Detail

registerConnectionProxy

public long registerConnectionProxy(LoadBalancedConnectionProxy proxy,
                                    java.util.List<java.lang.String> localHostList)

getGroupName

public java.lang.String getGroupName()

getInitialHosts

public java.util.Collection<java.lang.String> getInitialHosts()

getActiveHostCount

public int getActiveHostCount()

getClosedHosts

public java.util.Collection<java.lang.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(java.lang.String hostPortPair)
                throws java.sql.SQLException

Remove the given host (host:port pair) from this Connection Group.

Parameters:

hostPortPair - The host:port pair to remove.

Throws:

java.sql.SQLException - if a database access error occurs

removeHost

public void removeHost(java.lang.String hostPortPair,
                       boolean removeExisting)
                throws java.sql.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:

java.sql.SQLException - if a database access error occurs

removeHost

public void removeHost(java.lang.String hostPortPair,
                       boolean removeExisting,
                       boolean waitForGracefulFailover)
                throws java.sql.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:

java.sql.SQLException - if a database access error occurs

addHost

public void addHost(java.lang.String hostPortPair)

Add the given host (host:port pair) to this Connection Group.

Parameters:

hostPortPair - The host:port pair to add.

addHost

public void addHost(java.lang.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.