Class ReplicationConnectionGroupManager

java.lang.Object

com.mysql.jdbc.ReplicationConnectionGroupManager

public class ReplicationConnectionGroupManager
extends Object

Constructor Summary

Constructors

Constructor	Description
ReplicationConnectionGroupManager()

Method Summary

Modifier and Type	Method	Description
static void	addSlaveHost(String group, String hostPortPair)
static long	getActiveConnectionCount(String group)
static int	getConnectionCountWithHostAsMaster(String groupFilter, String hostPortPair)
static int	getConnectionCountWithHostAsSlave(String groupFilter, String hostPortPair)
static ReplicationConnectionGroup	getConnectionGroup(String groupName)
static ReplicationConnectionGroup	getConnectionGroupInstance(String groupName)
static Collection<ReplicationConnectionGroup>	getGroupsMatching(String group)
static Collection<String>	getMasterHosts(String groupFilter)
static int	getNumberOfMasterPromotion(String groupFilter)
static String	getRegisteredReplicationConnectionGroups()
static Collection<String>	getSlaveHosts(String groupFilter)
static long	getSlavePromotionCount(String group)
static long	getTotalConnectionCount(String group)
static void	promoteSlaveToMaster(String group, String hostPortPair)
static void	registerJmx()
static void	removeMasterHost(String group, String hostPortPair)
static void	removeMasterHost(String group, String hostPortPair, boolean closeGently)
static void	removeSlaveHost(String group, String hostPortPair)
static void	removeSlaveHost(String group, String hostPortPair, boolean closeGently)

Methods inherited from class Object

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

Constructor Details

ReplicationConnectionGroupManager

public ReplicationConnectionGroupManager()

Method Details

getConnectionGroupInstance

public static ReplicationConnectionGroup getConnectionGroupInstance(String groupName)

registerJmx

public static void registerJmx()
                        throws SQLException

Throws:

SQLException

getConnectionGroup

public static ReplicationConnectionGroup getConnectionGroup(String groupName)

getGroupsMatching

public static Collection<ReplicationConnectionGroup> getGroupsMatching(String group)

addSlaveHost

public static void addSlaveHost(String group,
 String hostPortPair)
                         throws SQLException

Throws:

SQLException

removeSlaveHost

public static void removeSlaveHost(String group,
 String hostPortPair)
                            throws SQLException

Throws:

SQLException

removeSlaveHost

public static void removeSlaveHost(String group,
 String hostPortPair,
 boolean closeGently)
                            throws SQLException

Throws:

SQLException

promoteSlaveToMaster

public static void promoteSlaveToMaster(String group,
 String hostPortPair)
                                 throws SQLException

Throws:

SQLException

getSlavePromotionCount

public static long getSlavePromotionCount(String group)
                                   throws SQLException

Throws:

SQLException

removeMasterHost

public static void removeMasterHost(String group,
 String hostPortPair)
                             throws SQLException

Throws:

SQLException

removeMasterHost

public static void removeMasterHost(String group,
 String hostPortPair,
 boolean closeGently)
                             throws SQLException

Throws:

SQLException

getRegisteredReplicationConnectionGroups

public static String getRegisteredReplicationConnectionGroups()

getNumberOfMasterPromotion

public static int getNumberOfMasterPromotion(String groupFilter)

getConnectionCountWithHostAsSlave

public static int getConnectionCountWithHostAsSlave(String groupFilter,
 String hostPortPair)

getConnectionCountWithHostAsMaster

public static int getConnectionCountWithHostAsMaster(String groupFilter,
 String hostPortPair)

getSlaveHosts

public static Collection<String> getSlaveHosts(String groupFilter)

getMasterHosts

public static Collection<String> getMasterHosts(String groupFilter)

getTotalConnectionCount

public static long getTotalConnectionCount(String group)

getActiveConnectionCount

public static long getActiveConnectionCount(String group)