Top Fields Constructors Methods

com.mysql.cj.jdbc.ha

public Class ReplicationConnectionGroupManager

Class Inheritance

extends Object

java.lang.Object
com.mysql.cj.jdbc.ha.ReplicationConnectionGroupManager

Imports

java.sql.SQLException, java.util.ArrayList, .Collection, .HashMap, .HashSet, .Set

Field Summary

Modifier and Type	Field and Description
private static HashMap<String, ReplicationConnectionGroup>	GROUP_MAP
private static boolean	hasRegisteredJmx
private static ReplicationGroupManager	mbean

Constructor Summary

Access	Constructor and Description
public	ReplicationConnectionGroupManager()

Method Summary

Modifier and Type	Method and Description
public static void	addReplicaHost(String group, String hostPortPair)
public static long	getActiveConnectionCount(String group)
public static int	getConnectionCountWithHostAsReplica(String groupFilter, String hostPortPair)
public static int	getConnectionCountWithHostAsSource(String groupFilter, String hostPortPair)
public static ReplicationConnectionGroup	getConnectionGroup(String groupName)
public static synchronized ReplicationConnectionGroup	getConnectionGroupInstance(String groupName)
public static Collection<ReplicationConnectionGroup>	getGroupsMatching(String group)
public static int	getNumberOfSourcePromotion(String groupFilter)
public static String	getRegisteredReplicationConnectionGroups()
public static Collection<String>	getReplicaHosts(String groupFilter)
public static long	getReplicaPromotionCount(String group)
public static Collection<String>	getSourceHosts(String groupFilter)
public static long	getTotalConnectionCount(String group)
public static void	promoteReplicaToSource(String group, String hostPortPair)
public static void	registerJmx()
public static void	removeReplicaHost(String group, String hostPortPair)
public static void	removeReplicaHost(String group, String hostPortPair, boolean closeGently)
public static void	removeSourceHost(String group, String hostPortPair)
public static void	removeSourceHost(String group, String hostPortPair, boolean closeGently)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

GROUP_MAP	back to summary
private static HashMap<String, ReplicationConnectionGroup> GROUP_MAP

hasRegisteredJmx	back to summary
private static boolean hasRegisteredJmx

mbean	back to summary
private static ReplicationGroupManager mbean

Constructor Detail

ReplicationConnectionGroupManager	back to summary
public ReplicationConnectionGroupManager()

Method Detail

addReplicaHost	back to summary
public static void addReplicaHost(String group, String hostPortPair) throws SQLException

getActiveConnectionCount	back to summary
public static long getActiveConnectionCount(String group)

getConnectionCountWithHostAsReplica	back to summary
public static int getConnectionCountWithHostAsReplica(String groupFilter, String hostPortPair)

getConnectionCountWithHostAsSource	back to summary
public static int getConnectionCountWithHostAsSource(String groupFilter, String hostPortPair)

getConnectionGroup	back to summary
public static ReplicationConnectionGroup getConnectionGroup(String groupName)

getConnectionGroupInstance	back to summary
public static synchronized ReplicationConnectionGroup getConnectionGroupInstance(String groupName)

getGroupsMatching	back to summary
public static Collection<ReplicationConnectionGroup> getGroupsMatching(String group)

getNumberOfSourcePromotion	back to summary
public static int getNumberOfSourcePromotion(String groupFilter)

getRegisteredReplicationConnectionGroups	back to summary
public static String getRegisteredReplicationConnectionGroups()

getReplicaHosts	back to summary
public static Collection<String> getReplicaHosts(String groupFilter)

getReplicaPromotionCount	back to summary
public static long getReplicaPromotionCount(String group) throws SQLException

getSourceHosts	back to summary
public static Collection<String> getSourceHosts(String groupFilter)

getTotalConnectionCount	back to summary
public static long getTotalConnectionCount(String group)

promoteReplicaToSource	back to summary
public static void promoteReplicaToSource(String group, String hostPortPair) throws SQLException

registerJmx	back to summary
public static void registerJmx() throws SQLException

removeReplicaHost	back to summary
public static void removeReplicaHost(String group, String hostPortPair) throws SQLException

removeReplicaHost	back to summary
public static void removeReplicaHost(String group, String hostPortPair, boolean closeGently) throws SQLException

removeSourceHost	back to summary
public static void removeSourceHost(String group, String hostPortPair) throws SQLException

removeSourceHost	back to summary
public static void removeSourceHost(String group, String hostPortPair, boolean closeGently) throws SQLException