testsuite.regression

Class ConnectionRegressionTest.ForcedLoadBalanceStrategy

java.lang.Object

com.mysql.cj.jdbc.ha.RandomBalanceStrategy

testsuite.regression.ConnectionRegressionTest.ForcedLoadBalanceStrategy

All Implemented Interfaces:

BalanceStrategy

Enclosing class:

ConnectionRegressionTest

public static class ConnectionRegressionTest.ForcedLoadBalanceStrategy
extends RandomBalanceStrategy

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	forcedFutureServer
private static int	forceFutureServerTimes

Constructor Summary

Constructors

Constructor and Description
ForcedLoadBalanceStrategy()

Method Summary

Modifier and Type	Method and Description
static void	dontForceFutureServer()
static void	forceFutureServer(java.lang.String host, int times)
ConnectionImpl	pickConnection(java.lang.reflect.InvocationHandler proxy, java.util.List<java.lang.String> configuredHosts, java.util.Map<java.lang.String,JdbcConnection> liveConnections, long[] responseTimes, int numRetries) Called by the driver to pick a new connection to route requests over.

Methods inherited from class java.lang.Object

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

Field Detail

forcedFutureServer

private static java.lang.String forcedFutureServer

forceFutureServerTimes

private static int forceFutureServerTimes

Constructor Detail

ForcedLoadBalanceStrategy

public ForcedLoadBalanceStrategy()

Method Detail

forceFutureServer

public static void forceFutureServer(java.lang.String host,
                                     int times)

dontForceFutureServer

public static void dontForceFutureServer()

pickConnection

public ConnectionImpl pickConnection(java.lang.reflect.InvocationHandler proxy,
                                     java.util.List<java.lang.String> configuredHosts,
                                     java.util.Map<java.lang.String,JdbcConnection> liveConnections,
                                     long[] responseTimes,
                                     int numRetries)
                              throws java.sql.SQLException

Description copied from interface: BalanceStrategy

Called by the driver to pick a new connection to route requests over. See LoadBalancedConnectionProxy.createConnectionForHost(String)

Specified by:

pickConnection in interface BalanceStrategy

Overrides:

pickConnection in class RandomBalanceStrategy

Parameters:

proxy - the InvocationHandler that deals with actual method calls to the JDBC connection, and serves as a factory for new connections for this strategy via the createConnectionForHost() method. This proxy takes care of maintaining the response time list, map of host/ports to live connections, and taking connections out of the live connections map if they receive a network-related error while they are in use by the application.

configuredHosts - the list of hosts/ports (in "host:port" form) as passed in by the user.

liveConnections - a map of host/ports to "live" connections to them.

responseTimes - the list of response times for a transaction for each host in the configured hosts list.

numRetries - the number of times the driver expects this strategy to re-try connection attempts if creating a new connection fails.

Returns:

the physical JDBC connection for the application to use, based upon the strategy employed.

Throws:

java.sql.SQLException - if a new connection can not be found or created by this strategy.