public abstract class BaseTestCase
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
BaseTestCase.MockConnectionConfiguration |
| Modifier and Type | Field and Description |
|---|---|
protected java.sql.Connection |
conn
Connection to server, initialized in setUp() Cleaned up in tearDown().
|
private java.util.List<java.lang.String[]> |
createdObjects
list of schema objects to be dropped in tearDown
|
protected java.lang.String |
dbClass
The driver to use
|
protected java.lang.String |
dbName
Default catalog.
|
static java.lang.String |
dbUrl
JDBC URL, initialized from com.mysql.cj.testsuite.url system property, or defaults to jdbc:mysql:///test and its connection URL.
|
private static int |
instanceCount
Instance counter
|
private boolean |
isOnCSFS |
protected boolean |
isOpenSSL |
protected static ConnectionUrl |
mainConnectionUrl |
private int |
myInstanceNumber
My instance number
|
private java.lang.Boolean |
mysqlRunningLocally
Is MySQL running locally?
|
protected java.sql.PreparedStatement |
pstmt
PreparedStatement to be used in tests, not initialized.
|
protected java.sql.ResultSet |
rs
ResultSet to be used in tests, not initialized.
|
protected ServerVersion |
serverVersion
Server version `this.conn' is connected to.
|
protected java.sql.Statement |
stmt
Statement to be used in tests, initialized in setUp().
|
static java.lang.String |
timeZoneFreeDbUrl |
| Constructor and Description |
|---|
BaseTestCase()
Creates a new BaseTestCase object.
|
| Modifier and Type | Method and Description |
|---|---|
protected java.util.Properties |
appendRequiredProperties(java.util.Properties props)
Some tests build connections strings for internal usage but, in order for them to work, they may require some connection properties set in the main test
suite URL.
|
protected void |
assertByteArrayEquals(java.lang.String message,
byte[] expected,
byte[] actual) |
protected static void |
assertConnectionsHistory(java.lang.String... expectedConnectionsHistory)
Asserts the most recent history of connection attempts from the global data in UnreliableSocketFactory.
|
protected boolean |
assertEqualsFSAware(java.lang.String matchStr,
java.lang.String inStr) |
protected static void |
assertNonSecureConnection(java.sql.Connection conn) |
protected void |
assertResultSetLength(java.sql.ResultSet rset,
int len) |
protected void |
assertResultSetsEqual(java.sql.ResultSet control,
java.sql.ResultSet test) |
protected static void |
assertSecureConnection(java.sql.Connection conn) |
protected static void |
assertSecureConnection(java.sql.Connection conn,
java.lang.String user) |
protected void |
assertSessionStatusEquals(java.sql.Statement st,
java.lang.String statusVariable,
java.lang.String expected) |
protected static <EX extends java.lang.Throwable> |
assertThrows(java.lang.Class<EX> throwable,
java.util.concurrent.Callable<?> testRoutine) |
protected static <EX extends java.lang.Throwable> |
assertThrows(java.lang.Class<EX> throwable,
java.lang.String msgMatchesRegex,
java.util.concurrent.Callable<?> testRoutine) |
protected static <EX extends java.lang.Throwable> |
assertThrows(java.lang.String message,
java.lang.Class<EX> throwable,
java.util.concurrent.Callable<?> testRoutine) |
protected static <EX extends java.lang.Throwable> |
assertThrows(java.lang.String message,
java.lang.Class<EX> throwable,
java.lang.String msgMatchesRegex,
java.util.concurrent.Callable<?> testRoutine) |
protected void |
cleanupTempFiles(java.io.File exampleTempFile,
java.lang.String tempfilePrefix) |
protected void |
createDatabase(java.sql.Statement st,
java.lang.String databaseName) |
protected void |
createDatabase(java.lang.String databaseName) |
protected void |
createFunction(java.sql.Statement st,
java.lang.String functionName,
java.lang.String functionDefn) |
protected void |
createFunction(java.lang.String functionName,
java.lang.String functionDefn) |
protected void |
createProcedure(java.sql.Statement st,
java.lang.String procedureName,
java.lang.String procedureDefn) |
protected void |
createProcedure(java.lang.String procedureName,
java.lang.String procedureDefn) |
protected void |
createSchemaObject(java.sql.Statement st,
java.lang.String objectType,
java.lang.String objectName,
java.lang.String columnsAndOtherStuff) |
protected void |
createSchemaObject(java.lang.String objectType,
java.lang.String objectName,
java.lang.String columnsAndOtherStuff) |
protected void |
createTable(java.sql.Statement st,
java.lang.String tableName,
java.lang.String columnsAndOtherStuff) |
protected void |
createTable(java.sql.Statement st,
java.lang.String tableName,
java.lang.String columnsAndOtherStuff,
java.lang.String engine) |
protected void |
createTable(java.lang.String tableName,
java.lang.String columnsAndOtherStuff) |
protected void |
createTable(java.lang.String tableName,
java.lang.String columnsAndOtherStuff,
java.lang.String engine) |
protected void |
createUser(java.sql.Statement st,
java.lang.String userName,
java.lang.String otherStuff) |
protected void |
createUser(java.lang.String userName,
java.lang.String otherStuff) |
protected void |
createView(java.sql.Statement st,
java.lang.String viewName,
java.lang.String columnsAndOtherStuff) |
protected void |
createView(java.lang.String viewName,
java.lang.String columnsAndOtherStuff) |
protected static long |
currentTimeMillis()
Retrieve the current system time in milliseconds, using the nanosecond
time if possible.
|
protected void |
dropDatabase(java.sql.Statement st,
java.lang.String databaseName) |
protected void |
dropDatabase(java.lang.String databaseName) |
protected void |
dropFunction(java.sql.Statement st,
java.lang.String functionName) |
protected void |
dropFunction(java.lang.String functionName) |
protected void |
dropProcedure(java.sql.Statement st,
java.lang.String procedureName) |
protected void |
dropProcedure(java.lang.String procedureName) |
protected void |
dropSchemaObject(java.sql.Statement st,
java.lang.String objectType,
java.lang.String objectName) |
protected void |
dropSchemaObject(java.lang.String objectType,
java.lang.String objectName) |
protected void |
dropTable(java.sql.Statement st,
java.lang.String tableName) |
protected void |
dropTable(java.lang.String tableName) |
protected void |
dropUser(java.sql.Statement st,
java.lang.String user) |
protected void |
dropUser(java.lang.String user) |
protected void |
dropView(java.sql.Statement st,
java.lang.String viewName) |
protected void |
dropView(java.lang.String viewName) |
protected void |
fillPrimitiveDefaults(java.lang.Class<?>[] types,
java.lang.Object[] vals,
int count) |
java.sql.Connection |
getConnectionWithProps(java.util.Properties props)
Returns a new connection with the given properties
|
java.sql.Connection |
getConnectionWithProps(java.lang.String propsList) |
protected java.sql.Connection |
getConnectionWithProps(java.lang.String url,
java.util.Properties props) |
protected java.sql.Connection |
getConnectionWithProps(java.lang.String url,
java.lang.String propsList) |
protected java.lang.String |
getEncodedHostFromTestsuiteUrl() |
protected java.lang.String |
getEncodedHostPortPairFromTestsuiteUrl() |
protected java.sql.Connection |
getFailoverConnection() |
protected java.sql.Connection |
getFailoverConnection(java.util.Properties props) |
protected java.util.Properties |
getHostFreePropertiesFromTestsuiteUrl() |
protected java.util.Properties |
getHostFreePropertiesFromTestsuiteUrl(java.util.Properties props) |
protected java.lang.String |
getHostFromTestsuiteUrl() |
protected int |
getInstanceNumber()
Returns the per-instance counter (for messages when multi-threading
stress tests)
|
protected java.sql.Connection |
getLoadBalancedConnection() |
protected java.sql.Connection |
getLoadBalancedConnection(int customHostLocation,
java.lang.String customHost,
java.util.Properties props) |
protected java.sql.Connection |
getLoadBalancedConnection(java.util.Properties props) |
protected java.lang.String |
getMysqlVariable(java.sql.Connection c,
java.lang.String variableName) |
protected java.lang.String |
getMysqlVariable(java.lang.String variableName)
Returns the named MySQL variable from the currently connected server.
|
protected java.sql.Connection |
getNewConnection() |
protected java.lang.String |
getNoDbUrl(java.lang.String url) |
protected java.lang.String |
getPort(java.util.Properties props) |
protected java.lang.String |
getPortFreeHostname(java.util.Properties props) |
protected int |
getPortFromTestsuiteUrl() |
protected java.util.Properties |
getPropertiesFromTestsuiteUrl()
Returns the properties that represent the default URL used for
connections for all testcases.
|
protected java.util.Properties |
getPropertiesFromUrl(ConnectionUrl url) |
protected int |
getRowCount(java.lang.String tableName) |
protected java.lang.Object |
getSingleIndexedValueWithQuery(java.sql.Connection c,
int columnIndex,
java.lang.String query) |
protected java.lang.Object |
getSingleIndexedValueWithQuery(int columnIndex,
java.lang.String query) |
protected java.lang.Object |
getSingleValue(java.lang.String tableName,
java.lang.String columnName,
java.lang.String whereClause) |
protected java.lang.Object |
getSingleValueWithQuery(java.lang.String query) |
protected java.sql.Connection |
getSourceReplicaReplicationConnection() |
protected java.sql.Connection |
getSourceReplicaReplicationConnection(java.util.Properties props) |
protected java.lang.String |
getSourceReplicaUrl() |
protected java.lang.String |
getSourceReplicaUrl(java.lang.String protocol) |
protected java.sql.Connection |
getUnreliableFailoverConnection(java.lang.String[] hostNames,
java.util.Properties props) |
protected java.sql.Connection |
getUnreliableFailoverConnection(java.lang.String[] hostNames,
java.util.Properties props,
java.util.Set<java.lang.String> downedHosts) |
protected java.sql.Connection |
getUnreliableLoadBalancedConnection(java.lang.String[] hostNames,
java.util.Properties props) |
protected java.sql.Connection |
getUnreliableLoadBalancedConnection(java.lang.String[] hostNames,
java.util.Properties props,
java.util.Set<java.lang.String> downedHosts) |
protected java.sql.Connection |
getUnreliableMultiHostConnection(java.lang.String haMode,
java.lang.String[] hostNames,
java.util.Properties props,
java.util.Set<java.lang.String> downedHosts) |
protected ReplicationConnection |
getUnreliableReplicationConnection(java.util.Set<BaseTestCase.MockConnectionConfiguration> configs,
java.util.Properties props) |
protected ReplicationConnection |
getUnreliableReplicationConnection(java.lang.String[] hostNames,
java.util.Properties props) |
protected ReplicationConnection |
getUnreliableReplicationConnection(java.lang.String[] hostNames,
java.util.Properties props,
java.util.Set<java.lang.String> downedHosts) |
protected boolean |
isClassAvailable(java.lang.String classname) |
protected boolean |
isCommunityEdition()
Checks whether the server we're connected to is a MySQL Community edition
|
protected boolean |
isEnterpriseEdition()
Checks whether the server we're connected to is an MySQL Enterprise edition
|
protected boolean |
isMysqlRunningLocally() |
protected boolean |
isRunningOnJRockit() |
protected boolean |
isServerRunningOnWindows() |
protected boolean |
isSysPropDefined(java.lang.String propName)
Checks whether a certain system property is defined, in order to
run/not-run certain tests
|
void |
logDebug(java.lang.String message) |
protected java.io.File |
newTempBinaryFile(java.lang.String name,
long size) |
protected java.lang.String |
randomString() |
protected void |
removeHostRelatedProps(java.util.Properties props) |
protected java.lang.String |
removeSqlMode(java.lang.String mode,
java.lang.String fromStr) |
protected boolean |
runLongTests() |
private java.lang.String |
sanitizeDbName(java.lang.String url) |
void |
setUpBase(org.junit.jupiter.api.TestInfo testInfo)
Creates resources used by all tests.
|
protected boolean |
supportsLoadLocalInfile(java.sql.Statement st) |
protected boolean |
supportsTestCachingSha2PasswordKeys(java.sql.Statement st) |
protected boolean |
supportsTestCertificates(java.sql.Statement st) |
protected boolean |
supportsTestSha256PasswordKeys(java.sql.Statement st) |
protected boolean |
supportsTimeZoneNames(java.sql.Statement st) |
protected boolean |
supportsTLSv1_2(ServerVersion version) |
void |
tearDownBase()
Destroys resources created during the test case.
|
protected boolean |
versionMeetsMinimum(int major,
int minor)
Checks whether the database we're connected to meets the given version
minimum
|
boolean |
versionMeetsMinimum(int major,
int minor,
int subminor)
Checks whether the database we're connected to meets the given version
minimum
|
public static java.lang.String dbUrl
public static java.lang.String timeZoneFreeDbUrl
protected static ConnectionUrl mainConnectionUrl
protected boolean isOpenSSL
private static int instanceCount
protected java.sql.Connection conn
protected ServerVersion serverVersion
private java.util.List<java.lang.String[]> createdObjects
protected java.lang.String dbClass
private int myInstanceNumber
private java.lang.Boolean mysqlRunningLocally
protected java.lang.String dbName
protected java.sql.PreparedStatement pstmt
protected java.sql.ResultSet rs
protected java.sql.Statement stmt
private boolean isOnCSFS
private java.lang.String sanitizeDbName(java.lang.String url)
protected void createSchemaObject(java.lang.String objectType,
java.lang.String objectName,
java.lang.String columnsAndOtherStuff)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createSchemaObject(java.sql.Statement st,
java.lang.String objectType,
java.lang.String objectName,
java.lang.String columnsAndOtherStuff)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createFunction(java.sql.Statement st,
java.lang.String functionName,
java.lang.String functionDefn)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createFunction(java.lang.String functionName,
java.lang.String functionDefn)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropFunction(java.sql.Statement st,
java.lang.String functionName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropFunction(java.lang.String functionName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createProcedure(java.sql.Statement st,
java.lang.String procedureName,
java.lang.String procedureDefn)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createProcedure(java.lang.String procedureName,
java.lang.String procedureDefn)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropProcedure(java.sql.Statement st,
java.lang.String procedureName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropProcedure(java.lang.String procedureName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createTable(java.sql.Statement st,
java.lang.String tableName,
java.lang.String columnsAndOtherStuff)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createTable(java.lang.String tableName,
java.lang.String columnsAndOtherStuff)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createTable(java.sql.Statement st,
java.lang.String tableName,
java.lang.String columnsAndOtherStuff,
java.lang.String engine)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createTable(java.lang.String tableName,
java.lang.String columnsAndOtherStuff,
java.lang.String engine)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropTable(java.sql.Statement st,
java.lang.String tableName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropTable(java.lang.String tableName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createView(java.sql.Statement st,
java.lang.String viewName,
java.lang.String columnsAndOtherStuff)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createView(java.lang.String viewName,
java.lang.String columnsAndOtherStuff)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropView(java.sql.Statement st,
java.lang.String viewName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropView(java.lang.String viewName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createDatabase(java.sql.Statement st,
java.lang.String databaseName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createDatabase(java.lang.String databaseName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropDatabase(java.sql.Statement st,
java.lang.String databaseName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropDatabase(java.lang.String databaseName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createUser(java.sql.Statement st,
java.lang.String userName,
java.lang.String otherStuff)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void createUser(java.lang.String userName,
java.lang.String otherStuff)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropUser(java.sql.Statement st,
java.lang.String user)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropUser(java.lang.String user)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropSchemaObject(java.lang.String objectType,
java.lang.String objectName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void dropSchemaObject(java.sql.Statement st,
java.lang.String objectType,
java.lang.String objectName)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.Connection getConnectionWithProps(java.lang.String propsList)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getConnectionWithProps(java.lang.String url,
java.lang.String propsList)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.Connection getConnectionWithProps(java.util.Properties props)
throws java.sql.SQLException
props - the properties to use (the URL will come from the standard for
this testcase).java.sql.SQLExceptionprotected java.sql.Connection getConnectionWithProps(java.lang.String url,
java.util.Properties props)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getNewConnection()
throws java.sql.SQLException
java.sql.SQLExceptionprotected int getInstanceNumber()
protected java.lang.String getMysqlVariable(java.sql.Connection c,
java.lang.String variableName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getMysqlVariable(java.lang.String variableName)
throws java.sql.SQLException
variableName - the name of the variable to returnjava.sql.SQLException - if an error occursprotected java.util.Properties getPropertiesFromTestsuiteUrl()
throws java.sql.SQLException
java.sql.SQLException - if parsing failsprotected java.util.Properties getPropertiesFromUrl(ConnectionUrl url) throws java.sql.SQLException
java.sql.SQLExceptionprotected java.util.Properties getHostFreePropertiesFromTestsuiteUrl()
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.util.Properties getHostFreePropertiesFromTestsuiteUrl(java.util.Properties props)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void removeHostRelatedProps(java.util.Properties props)
protected java.util.Properties appendRequiredProperties(java.util.Properties props)
props - the Properties object where to add the missing connection propertiesprops is nullprotected java.lang.String getHostFromTestsuiteUrl()
throws java.sql.SQLException
java.sql.SQLExceptionprotected int getPortFromTestsuiteUrl()
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getEncodedHostFromTestsuiteUrl()
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getEncodedHostPortPairFromTestsuiteUrl()
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getNoDbUrl(java.lang.String url)
throws java.sql.SQLException
java.sql.SQLExceptionprotected int getRowCount(java.lang.String tableName)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.Object getSingleIndexedValueWithQuery(java.sql.Connection c,
int columnIndex,
java.lang.String query)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.Object getSingleIndexedValueWithQuery(int columnIndex,
java.lang.String query)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.Object getSingleValue(java.lang.String tableName,
java.lang.String columnName,
java.lang.String whereClause)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.Object getSingleValueWithQuery(java.lang.String query)
throws java.sql.SQLException
java.sql.SQLExceptionprotected boolean isServerRunningOnWindows()
throws java.sql.SQLException
java.sql.SQLExceptionpublic void logDebug(java.lang.String message)
protected java.io.File newTempBinaryFile(java.lang.String name,
long size)
throws java.io.IOException
java.io.IOExceptionprotected final boolean runLongTests()
protected boolean isSysPropDefined(java.lang.String propName)
propName - the property name to check for@BeforeEach
public void setUpBase(org.junit.jupiter.api.TestInfo testInfo)
throws java.lang.Exception
testInfo - java.lang.Exception - if an error occurs.@AfterEach
public void tearDownBase()
throws java.lang.Exception
java.lang.Exceptionprotected boolean versionMeetsMinimum(int major,
int minor)
throws java.sql.SQLException
major - the major version to meetminor - the minor version to meetjava.sql.SQLException - if an error occurs.public boolean versionMeetsMinimum(int major,
int minor,
int subminor)
throws java.sql.SQLException
major - the major version to meetminor - the minor version to meetsubminor - the subminor version to meetjava.sql.SQLException - if an error occurs.protected boolean isCommunityEdition()
protected boolean isEnterpriseEdition()
protected boolean isClassAvailable(java.lang.String classname)
protected boolean isRunningOnJRockit()
protected boolean isMysqlRunningLocally()
protected java.lang.String randomString()
protected void cleanupTempFiles(java.io.File exampleTempFile,
java.lang.String tempfilePrefix)
protected void assertResultSetLength(java.sql.ResultSet rset,
int len)
throws java.lang.Exception
java.lang.Exceptionprotected void assertResultSetsEqual(java.sql.ResultSet control,
java.sql.ResultSet test)
throws java.lang.Exception
java.lang.Exceptionprotected static <EX extends java.lang.Throwable> EX assertThrows(java.lang.Class<EX> throwable,
java.util.concurrent.Callable<?> testRoutine)
protected static <EX extends java.lang.Throwable> EX assertThrows(java.lang.String message,
java.lang.Class<EX> throwable,
java.util.concurrent.Callable<?> testRoutine)
protected static <EX extends java.lang.Throwable> EX assertThrows(java.lang.Class<EX> throwable,
java.lang.String msgMatchesRegex,
java.util.concurrent.Callable<?> testRoutine)
protected static <EX extends java.lang.Throwable> EX assertThrows(java.lang.String message,
java.lang.Class<EX> throwable,
java.lang.String msgMatchesRegex,
java.util.concurrent.Callable<?> testRoutine)
protected void assertByteArrayEquals(java.lang.String message,
byte[] expected,
byte[] actual)
protected static void assertConnectionsHistory(java.lang.String... expectedConnectionsHistory)
expectedConnectionsHistory - The list of expected events. Use UnreliableSocketFactory.getHostConnectedStatus(String), UnreliableSocketFactory.getHostFailedStatus(String)
and UnreliableSocketFactory.getHostUnknownStatus(String) to build proper syntax for host+status identification.protected static void assertSecureConnection(java.sql.Connection conn)
throws java.lang.Exception
java.lang.Exceptionprotected static void assertSecureConnection(java.sql.Connection conn,
java.lang.String user)
throws java.lang.Exception
java.lang.Exceptionprotected static void assertNonSecureConnection(java.sql.Connection conn)
throws java.lang.Exception
java.lang.Exceptionprotected void fillPrimitiveDefaults(java.lang.Class<?>[] types,
java.lang.Object[] vals,
int count)
protected static final long currentTimeMillis()
protected java.sql.Connection getFailoverConnection()
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getFailoverConnection(java.util.Properties props)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getSourceReplicaReplicationConnection()
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getSourceReplicaReplicationConnection(java.util.Properties props)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getSourceReplicaUrl()
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getSourceReplicaUrl(java.lang.String protocol)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getLoadBalancedConnection(int customHostLocation,
java.lang.String customHost,
java.util.Properties props)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getLoadBalancedConnection()
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getLoadBalancedConnection(java.util.Properties props)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getPort(java.util.Properties props)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.String getPortFreeHostname(java.util.Properties props)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Connection getUnreliableMultiHostConnection(java.lang.String haMode,
java.lang.String[] hostNames,
java.util.Properties props,
java.util.Set<java.lang.String> downedHosts)
throws java.lang.Exception
java.lang.Exceptionprotected java.sql.Connection getUnreliableFailoverConnection(java.lang.String[] hostNames,
java.util.Properties props)
throws java.lang.Exception
java.lang.Exceptionprotected java.sql.Connection getUnreliableFailoverConnection(java.lang.String[] hostNames,
java.util.Properties props,
java.util.Set<java.lang.String> downedHosts)
throws java.lang.Exception
java.lang.Exceptionprotected java.sql.Connection getUnreliableLoadBalancedConnection(java.lang.String[] hostNames,
java.util.Properties props)
throws java.lang.Exception
java.lang.Exceptionprotected java.sql.Connection getUnreliableLoadBalancedConnection(java.lang.String[] hostNames,
java.util.Properties props,
java.util.Set<java.lang.String> downedHosts)
throws java.lang.Exception
java.lang.Exceptionprotected ReplicationConnection getUnreliableReplicationConnection(java.lang.String[] hostNames, java.util.Properties props) throws java.lang.Exception
java.lang.Exceptionprotected ReplicationConnection getUnreliableReplicationConnection(java.lang.String[] hostNames, java.util.Properties props, java.util.Set<java.lang.String> downedHosts) throws java.lang.Exception
java.lang.Exceptionprotected ReplicationConnection getUnreliableReplicationConnection(java.util.Set<BaseTestCase.MockConnectionConfiguration> configs, java.util.Properties props) throws java.lang.Exception
java.lang.Exceptionprotected boolean assertEqualsFSAware(java.lang.String matchStr,
java.lang.String inStr)
throws java.lang.Exception
java.lang.Exceptionprotected java.lang.String removeSqlMode(java.lang.String mode,
java.lang.String fromStr)
throws java.lang.Exception
java.lang.Exceptionprotected boolean supportsTimeZoneNames(java.sql.Statement st)
throws java.lang.Exception
java.lang.Exceptionprotected boolean supportsLoadLocalInfile(java.sql.Statement st)
throws java.lang.Exception
java.lang.Exceptionprotected boolean supportsTestCertificates(java.sql.Statement st)
throws java.lang.Exception
java.lang.Exceptionprotected boolean supportsTestSha256PasswordKeys(java.sql.Statement st)
throws java.lang.Exception
java.lang.Exceptionprotected boolean supportsTestCachingSha2PasswordKeys(java.sql.Statement st)
throws java.lang.Exception
java.lang.Exceptionprotected boolean supportsTLSv1_2(ServerVersion version) throws java.lang.Exception
java.lang.Exceptionprotected void assertSessionStatusEquals(java.sql.Statement st,
java.lang.String statusVariable,
java.lang.String expected)
throws java.lang.Exception
java.lang.Exception