testsuite

Class BaseTestCase

java.lang.Object

testsuite.BaseTestCase

Direct Known Subclasses:

AuthenticationTest, BasePerfTest, BlobRegressionTest, BlobTest, CachedRowsetTest, CallableStatementRegressionTest, CallableStatementTest, CharsetRegressionTest, CharsetTest, ConnectionRegressionTest, ConnectionTest, DataSourceRegressionTest, DataSourceTest, DateTest, DateTimeRegressionTest, DateTimeTest, EscapeProcessingTest, EscapeProcessorRegressionTest, ExceptionsTest, ExceptionSubclassesTest, MetaDataRegressionTest, MetadataTest, MicroPerformanceRegressionTest, MiniAdminTest, MultiHostConnectionTest, NumbersRegressionTest, NumbersTest, PooledConnectionRegressionTest, QueryAttributesTest, ReadOnlyCallableStatementTest, ResultSetRegressionTest, ResultSetTest, RetrievalPerfTest, SaslPrepTest, SequentialIdLeaseTest, ServerControllerTest, SplitDBdotNameTest, SSLTest, StatementsTest, StressRegressionTest, StringInspectorTest, StringRegressionTest, StringUtilsTest, SubqueriesRegressionTest, SyntaxRegressionTest, TransactionTest, TraversalTest, UpdatabilityTest, UtilsRegressionTest, UtilsTest, XATest

public abstract class BaseTestCase
extends java.lang.Object

Base class for all test cases. Creates connections, statements, etc. and closes them.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BaseTestCase.MockConnectionConfiguration

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
BaseTestCase() Creates a new BaseTestCase object.

Method Summary

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> EX	assertThrows(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.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	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

Methods inherited from class java.lang.Object

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

Field Detail

dbUrl

public 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.

timeZoneFreeDbUrl

public static java.lang.String timeZoneFreeDbUrl

mainConnectionUrl

protected static ConnectionUrl mainConnectionUrl

isOpenSSL

protected boolean isOpenSSL

instanceCount

private static int instanceCount

Instance counter

conn

protected java.sql.Connection conn

Connection to server, initialized in setUp() Cleaned up in tearDown().

serverVersion

protected ServerVersion serverVersion

Server version `this.conn' is connected to.

createdObjects

private java.util.List<java.lang.String[]> createdObjects

list of schema objects to be dropped in tearDown

dbClass

protected java.lang.String dbClass

The driver to use

myInstanceNumber

private int myInstanceNumber

My instance number

mysqlRunningLocally

private java.lang.Boolean mysqlRunningLocally

Is MySQL running locally?

dbName

protected java.lang.String dbName

Default catalog.

pstmt

protected java.sql.PreparedStatement pstmt

PreparedStatement to be used in tests, not initialized. Cleaned up in tearDown().

rs

protected java.sql.ResultSet rs

ResultSet to be used in tests, not initialized. Cleaned up in tearDown().

stmt

protected java.sql.Statement stmt

Statement to be used in tests, initialized in setUp(). Cleaned up in tearDown().

isOnCSFS

private boolean isOnCSFS

Constructor Detail

BaseTestCase

public BaseTestCase()

Creates a new BaseTestCase object.

Method Detail

sanitizeDbName

private java.lang.String sanitizeDbName(java.lang.String url)

createSchemaObject

protected void createSchemaObject(java.lang.String objectType,
                                  java.lang.String objectName,
                                  java.lang.String columnsAndOtherStuff)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

createSchemaObject

protected void createSchemaObject(java.sql.Statement st,
                                  java.lang.String objectType,
                                  java.lang.String objectName,
                                  java.lang.String columnsAndOtherStuff)
                           throws java.sql.SQLException

Throws:

java.sql.SQLException

createFunction

protected void createFunction(java.sql.Statement st,
                              java.lang.String functionName,
                              java.lang.String functionDefn)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

createFunction

protected void createFunction(java.lang.String functionName,
                              java.lang.String functionDefn)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

dropFunction

protected void dropFunction(java.sql.Statement st,
                            java.lang.String functionName)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

dropFunction

protected void dropFunction(java.lang.String functionName)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

createProcedure

protected void createProcedure(java.sql.Statement st,
                               java.lang.String procedureName,
                               java.lang.String procedureDefn)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

createProcedure

protected void createProcedure(java.lang.String procedureName,
                               java.lang.String procedureDefn)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

dropProcedure

protected void dropProcedure(java.sql.Statement st,
                             java.lang.String procedureName)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

dropProcedure

protected void dropProcedure(java.lang.String procedureName)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException

createTable

protected void createTable(java.sql.Statement st,
                           java.lang.String tableName,
                           java.lang.String columnsAndOtherStuff)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

createTable

protected void createTable(java.lang.String tableName,
                           java.lang.String columnsAndOtherStuff)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

createTable

protected void createTable(java.sql.Statement st,
                           java.lang.String tableName,
                           java.lang.String columnsAndOtherStuff,
                           java.lang.String engine)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

createTable

protected void createTable(java.lang.String tableName,
                           java.lang.String columnsAndOtherStuff,
                           java.lang.String engine)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

dropTable

protected void dropTable(java.sql.Statement st,
                         java.lang.String tableName)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

dropTable

protected void dropTable(java.lang.String tableName)
                  throws java.sql.SQLException

Throws:

java.sql.SQLException

createView

protected void createView(java.sql.Statement st,
                          java.lang.String viewName,
                          java.lang.String columnsAndOtherStuff)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

createView

protected void createView(java.lang.String viewName,
                          java.lang.String columnsAndOtherStuff)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

dropView

protected void dropView(java.sql.Statement st,
                        java.lang.String viewName)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

dropView

protected void dropView(java.lang.String viewName)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

createDatabase

protected void createDatabase(java.sql.Statement st,
                              java.lang.String databaseName)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

createDatabase

protected void createDatabase(java.lang.String databaseName)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

dropDatabase

protected void dropDatabase(java.sql.Statement st,
                            java.lang.String databaseName)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

dropDatabase

protected void dropDatabase(java.lang.String databaseName)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

createUser

protected void createUser(java.sql.Statement st,
                          java.lang.String userName,
                          java.lang.String otherStuff)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

createUser

protected void createUser(java.lang.String userName,
                          java.lang.String otherStuff)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

dropUser

protected void dropUser(java.sql.Statement st,
                        java.lang.String user)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

dropUser

protected void dropUser(java.lang.String user)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

dropSchemaObject

protected void dropSchemaObject(java.lang.String objectType,
                                java.lang.String objectName)
                         throws java.sql.SQLException

Throws:

java.sql.SQLException

dropSchemaObject

protected void dropSchemaObject(java.sql.Statement st,
                                java.lang.String objectType,
                                java.lang.String objectName)
                         throws java.sql.SQLException

Throws:

java.sql.SQLException

getConnectionWithProps

public java.sql.Connection getConnectionWithProps(java.lang.String propsList)
                                           throws java.sql.SQLException

Throws:

java.sql.SQLException

getConnectionWithProps

protected java.sql.Connection getConnectionWithProps(java.lang.String url,
                                                     java.lang.String propsList)
                                              throws java.sql.SQLException

Throws:

java.sql.SQLException

getConnectionWithProps

public java.sql.Connection getConnectionWithProps(java.util.Properties props)
                                           throws java.sql.SQLException

Returns a new connection with the given properties

Parameters:

props - the properties to use (the URL will come from the standard for this testcase).

Returns:

a new connection using the given properties.

Throws:

java.sql.SQLException

getConnectionWithProps

protected java.sql.Connection getConnectionWithProps(java.lang.String url,
                                                     java.util.Properties props)
                                              throws java.sql.SQLException

Throws:

java.sql.SQLException

getNewConnection

protected java.sql.Connection getNewConnection()
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

getInstanceNumber

protected int getInstanceNumber()

Returns the per-instance counter (for messages when multi-threading stress tests)

Returns:

int the instance number

getMysqlVariable

protected java.lang.String getMysqlVariable(java.sql.Connection c,
                                            java.lang.String variableName)
                                     throws java.sql.SQLException

Throws:

java.sql.SQLException

getMysqlVariable

protected java.lang.String getMysqlVariable(java.lang.String variableName)
                                     throws java.sql.SQLException

Returns the named MySQL variable from the currently connected server.

Parameters:

variableName - the name of the variable to return

Returns:

the value of the given variable, or NULL if it doesn't exist

Throws:

java.sql.SQLException - if an error occurs

getPropertiesFromTestsuiteUrl

protected java.util.Properties getPropertiesFromTestsuiteUrl()
                                                      throws java.sql.SQLException

Returns the properties that represent the default URL used for connections for all testcases.

Returns:

properties parsed from com.mysql.jdbc.testsuite.url

Throws:

java.sql.SQLException - if parsing fails

getPropertiesFromUrl

protected java.util.Properties getPropertiesFromUrl(ConnectionUrl url)
                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getHostFreePropertiesFromTestsuiteUrl

protected java.util.Properties getHostFreePropertiesFromTestsuiteUrl()
                                                              throws java.sql.SQLException

Throws:

java.sql.SQLException

getHostFreePropertiesFromTestsuiteUrl

protected java.util.Properties getHostFreePropertiesFromTestsuiteUrl(java.util.Properties props)
                                                              throws java.sql.SQLException

Throws:

java.sql.SQLException

removeHostRelatedProps

protected void removeHostRelatedProps(java.util.Properties props)

appendRequiredProperties

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. For example 'connectionTimeZone' is one of those properties.

Parameters:

props - the Properties object where to add the missing connection properties

Returns:

the modified Properties objects or a new one if props is null

getHostFromTestsuiteUrl

protected java.lang.String getHostFromTestsuiteUrl()
                                            throws java.sql.SQLException

Throws:

java.sql.SQLException

getPortFromTestsuiteUrl

protected int getPortFromTestsuiteUrl()
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

getEncodedHostFromTestsuiteUrl

protected java.lang.String getEncodedHostFromTestsuiteUrl()
                                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getEncodedHostPortPairFromTestsuiteUrl

protected java.lang.String getEncodedHostPortPairFromTestsuiteUrl()
                                                           throws java.sql.SQLException

Throws:

java.sql.SQLException

getNoDbUrl

protected java.lang.String getNoDbUrl(java.lang.String url)
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

getRowCount

protected int getRowCount(java.lang.String tableName)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getSingleIndexedValueWithQuery

protected java.lang.Object getSingleIndexedValueWithQuery(java.sql.Connection c,
                                                          int columnIndex,
                                                          java.lang.String query)
                                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getSingleIndexedValueWithQuery

protected java.lang.Object getSingleIndexedValueWithQuery(int columnIndex,
                                                          java.lang.String query)
                                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getSingleValue

protected java.lang.Object getSingleValue(java.lang.String tableName,
                                          java.lang.String columnName,
                                          java.lang.String whereClause)
                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getSingleValueWithQuery

protected java.lang.Object getSingleValueWithQuery(java.lang.String query)
                                            throws java.sql.SQLException

Throws:

java.sql.SQLException

isServerRunningOnWindows

protected boolean isServerRunningOnWindows()
                                    throws java.sql.SQLException

Throws:

java.sql.SQLException

logDebug

public void logDebug(java.lang.String message)

newTempBinaryFile

protected java.io.File newTempBinaryFile(java.lang.String name,
                                         long size)
                                  throws java.io.IOException

Throws:

java.io.IOException

runLongTests

protected final boolean runLongTests()

isSysPropDefined

protected boolean isSysPropDefined(java.lang.String propName)

Checks whether a certain system property is defined, in order to run/not-run certain tests

Parameters:

propName - the property name to check for

Returns:

true if the property is defined.

setUpBase

@BeforeEach
public void setUpBase(org.junit.jupiter.api.TestInfo testInfo)
                           throws java.lang.Exception

Creates resources used by all tests.

Parameters:

testInfo -

Throws:

java.lang.Exception - if an error occurs.

tearDownBase

@AfterEach
public void tearDownBase()
                             throws java.lang.Exception

Destroys resources created during the test case.

Throws:

java.lang.Exception

versionMeetsMinimum

protected boolean versionMeetsMinimum(int major,
                                      int minor)
                               throws java.sql.SQLException

Checks whether the database we're connected to meets the given version minimum

Parameters:

major - the major version to meet

minor - the minor version to meet

Returns:

boolean if the major/minor is met

Throws:

java.sql.SQLException - if an error occurs.

versionMeetsMinimum

public boolean versionMeetsMinimum(int major,
                                   int minor,
                                   int subminor)
                            throws java.sql.SQLException

Checks whether the database we're connected to meets the given version minimum

Parameters:

major - the major version to meet

minor - the minor version to meet

subminor - the subminor version to meet

Returns:

boolean if the major/minor is met

Throws:

java.sql.SQLException - if an error occurs.

isCommunityEdition

protected boolean isCommunityEdition()

Checks whether the server we're connected to is a MySQL Community edition

Returns:

true if connected to a community/gpl server

isEnterpriseEdition

protected boolean isEnterpriseEdition()

Checks whether the server we're connected to is an MySQL Enterprise edition

Returns:

true if connected to an enterprise/commercial server

isClassAvailable

protected boolean isClassAvailable(java.lang.String classname)

isRunningOnJRockit

protected boolean isRunningOnJRockit()

isMysqlRunningLocally

protected boolean isMysqlRunningLocally()

randomString

protected java.lang.String randomString()

cleanupTempFiles

protected void cleanupTempFiles(java.io.File exampleTempFile,
                                java.lang.String tempfilePrefix)

assertResultSetLength

protected void assertResultSetLength(java.sql.ResultSet rset,
                                     int len)
                              throws java.lang.Exception

Throws:

java.lang.Exception

assertResultSetsEqual

protected void assertResultSetsEqual(java.sql.ResultSet control,
                                     java.sql.ResultSet test)
                              throws java.lang.Exception

Throws:

java.lang.Exception

assertThrows

protected static <EX extends java.lang.Throwable> EX assertThrows(java.lang.Class<EX> throwable,
                                                                  java.util.concurrent.Callable<?> testRoutine)

assertThrows

protected static <EX extends java.lang.Throwable> EX assertThrows(java.lang.String message,
                                                                  java.lang.Class<EX> throwable,
                                                                  java.util.concurrent.Callable<?> testRoutine)

assertThrows

protected static <EX extends java.lang.Throwable> EX assertThrows(java.lang.Class<EX> throwable,
                                                                  java.lang.String msgMatchesRegex,
                                                                  java.util.concurrent.Callable<?> testRoutine)

assertThrows

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)

assertByteArrayEquals

protected void assertByteArrayEquals(java.lang.String message,
                                     byte[] expected,
                                     byte[] actual)

assertConnectionsHistory

protected static void assertConnectionsHistory(java.lang.String... expectedConnectionsHistory)

Asserts the most recent history of connection attempts from the global data in UnreliableSocketFactory.

Parameters:

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.

assertSecureConnection

protected static void assertSecureConnection(java.sql.Connection conn)
                                      throws java.lang.Exception

Throws:

java.lang.Exception

assertSecureConnection

protected static void assertSecureConnection(java.sql.Connection conn,
                                             java.lang.String user)
                                      throws java.lang.Exception

Throws:

java.lang.Exception

assertNonSecureConnection

protected static void assertNonSecureConnection(java.sql.Connection conn)
                                         throws java.lang.Exception

Throws:

java.lang.Exception

fillPrimitiveDefaults

protected void fillPrimitiveDefaults(java.lang.Class<?>[] types,
                                     java.lang.Object[] vals,
                                     int count)

currentTimeMillis

protected static final long currentTimeMillis()

Retrieve the current system time in milliseconds, using the nanosecond time if possible.

Returns:

current time in milliseconds

getFailoverConnection

protected java.sql.Connection getFailoverConnection()
                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getFailoverConnection

protected java.sql.Connection getFailoverConnection(java.util.Properties props)
                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getSourceReplicaReplicationConnection

protected java.sql.Connection getSourceReplicaReplicationConnection()
                                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getSourceReplicaReplicationConnection

protected java.sql.Connection getSourceReplicaReplicationConnection(java.util.Properties props)
                                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

getSourceReplicaUrl

protected java.lang.String getSourceReplicaUrl()
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

getSourceReplicaUrl

protected java.lang.String getSourceReplicaUrl(java.lang.String protocol)
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

getLoadBalancedConnection

protected java.sql.Connection getLoadBalancedConnection(int customHostLocation,
                                                        java.lang.String customHost,
                                                        java.util.Properties props)
                                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

getLoadBalancedConnection

protected java.sql.Connection getLoadBalancedConnection()
                                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

getLoadBalancedConnection

protected java.sql.Connection getLoadBalancedConnection(java.util.Properties props)
                                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

getPort

protected java.lang.String getPort(java.util.Properties props)
                            throws java.sql.SQLException

Throws:

java.sql.SQLException

getPortFreeHostname

protected java.lang.String getPortFreeHostname(java.util.Properties props)
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

getUnreliableMultiHostConnection

protected 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

Throws:

java.lang.Exception

getUnreliableFailoverConnection

protected java.sql.Connection getUnreliableFailoverConnection(java.lang.String[] hostNames,
                                                              java.util.Properties props)
                                                       throws java.lang.Exception

Throws:

java.lang.Exception

getUnreliableFailoverConnection

protected java.sql.Connection getUnreliableFailoverConnection(java.lang.String[] hostNames,
                                                              java.util.Properties props,
                                                              java.util.Set<java.lang.String> downedHosts)
                                                       throws java.lang.Exception

Throws:

java.lang.Exception

getUnreliableLoadBalancedConnection

protected java.sql.Connection getUnreliableLoadBalancedConnection(java.lang.String[] hostNames,
                                                                  java.util.Properties props)
                                                           throws java.lang.Exception

Throws:

java.lang.Exception

getUnreliableLoadBalancedConnection

protected java.sql.Connection getUnreliableLoadBalancedConnection(java.lang.String[] hostNames,
                                                                  java.util.Properties props,
                                                                  java.util.Set<java.lang.String> downedHosts)
                                                           throws java.lang.Exception

Throws:

java.lang.Exception

getUnreliableReplicationConnection

protected ReplicationConnection getUnreliableReplicationConnection(java.lang.String[] hostNames,
                                                                   java.util.Properties props)
                                                            throws java.lang.Exception

Throws:

java.lang.Exception

getUnreliableReplicationConnection

protected ReplicationConnection getUnreliableReplicationConnection(java.lang.String[] hostNames,
                                                                   java.util.Properties props,
                                                                   java.util.Set<java.lang.String> downedHosts)
                                                            throws java.lang.Exception

Throws:

java.lang.Exception

getUnreliableReplicationConnection

protected ReplicationConnection getUnreliableReplicationConnection(java.util.Set<BaseTestCase.MockConnectionConfiguration> configs,
                                                                   java.util.Properties props)
                                                            throws java.lang.Exception

Throws:

java.lang.Exception

assertEqualsFSAware

protected boolean assertEqualsFSAware(java.lang.String matchStr,
                                      java.lang.String inStr)
                               throws java.lang.Exception

Throws:

java.lang.Exception

removeSqlMode

protected java.lang.String removeSqlMode(java.lang.String mode,
                                         java.lang.String fromStr)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

supportsTimeZoneNames

protected boolean supportsTimeZoneNames(java.sql.Statement st)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

supportsLoadLocalInfile

protected boolean supportsLoadLocalInfile(java.sql.Statement st)
                                   throws java.lang.Exception

Throws:

java.lang.Exception

supportsTestCertificates

protected boolean supportsTestCertificates(java.sql.Statement st)
                                    throws java.lang.Exception

Throws:

java.lang.Exception

supportsTestSha256PasswordKeys

protected boolean supportsTestSha256PasswordKeys(java.sql.Statement st)
                                          throws java.lang.Exception

Throws:

java.lang.Exception

supportsTestCachingSha2PasswordKeys

protected boolean supportsTestCachingSha2PasswordKeys(java.sql.Statement st)
                                               throws java.lang.Exception

Throws:

java.lang.Exception

supportsTLSv1_2

protected boolean supportsTLSv1_2(ServerVersion version)
                           throws java.lang.Exception

Throws:

java.lang.Exception

assertSessionStatusEquals

protected void assertSessionStatusEquals(java.sql.Statement st,
                                         java.lang.String statusVariable,
                                         java.lang.String expected)
                                  throws java.lang.Exception

Throws:

java.lang.Exception