testsuite.x.devapi

Class SessionFailoverTest

java.lang.Object

testsuite.x.internal.InternalXBaseTestCase

testsuite.x.devapi.DevApiBaseTestCase

testsuite.x.devapi.SessionFailoverTest

public class SessionFailoverTest
extends DevApiBaseTestCase

Tests for Session client side failover features.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	SessionFailoverTest.ConnectionsCounterFakeServer

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	testsHost

Fields inherited from class testsuite.x.devapi.DevApiBaseTestCase

dbCharset, dbCollation, schema, session

Fields inherited from class testsuite.x.internal.InternalXBaseTestCase

baseUrl, DEFAULT_METADATA_CHARSET, fact, isSetForXTests, testHostInfo, testProperties

Constructor Summary

Constructors

Constructor and Description
SessionFailoverTest()

Method Summary

Modifier and Type	Method and Description
private java.lang.String	buildConnectionString(java.lang.String... hosts) Builds a connection string with the given hosts while setting priorities according to their positions.
private java.lang.String	buildConnectionStringNoUser(java.lang.String... hosts)
void	setupFailoverTest()
private void	testConnectionTimeout_assertFailureTimeout(java.lang.String url, int expLowLimit, int expUpLimit)
private <EX extends java.lang.Throwable> void	testConnectionTimeout_assertFailureTimeout(java.lang.String url, int expLowLimit, int expUpLimit, java.lang.Class<EX> throwable)
private void	testConnectionTimeout_assertSuccessTimeout(java.lang.String url, int expLowLimit, int expUpLimit)
void	testConnectionTimeout() Tests xdevapi.connect-timeout and connectTimeout functionality.
void	testGetSessionForMultipleHostsWithFailover() Tests basic failover while getting a Session instance.
void	testGetSessionForSingleHost() Assures that failover support doesn't affect single host connections.

Methods inherited from class testsuite.x.devapi.DevApiBaseTestCase

assertNonSecureSession, assertPreparedStatementsCount, assertPreparedStatementsCountsAndId, assertPreparedStatementsStatusCounts, assertSecureSession, assertSecureSession, buildString, count_data, destroyTestSession, dropCollection, getPreparedStatementExecutionsCount, getPreparedStatementId, getPreparedStatementsCount, getPreparedStatementsCount, getPreparedStatementsCount, getPrepDeallocateCount, getPrepExecuteCount, getPrepPrepareCount, getThreadId, isMysqlRunningLocally, isServerRunningOnWindows, makeParam, makeParam, makeParam, setupTestSession, sqlUpdate, supportsTestCertificates, supportsTLSv1_2

Methods inherited from class testsuite.x.internal.InternalXBaseTestCase

assertSessionStatusEquals, assertSessionStatusNotEquals, assertThrows, assertThrows, assertThrows, assertThrows, createAuthenticatedTestProtocol, createTempTestCollection, createTestProtocol, createTestSchema, createTestSession, dropTempTestCollection, getEncodedTestHost, getTestDatabase, getTestHost, getTestPassword, getTestPort, getTestUser, mysqlVersionMeetsMinimum, mysqlVersionMeetsMinimum

Methods inherited from class java.lang.Object

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

Field Detail

testsHost

private java.lang.String testsHost

Constructor Detail

SessionFailoverTest

public SessionFailoverTest()

Method Detail

buildConnectionString

private java.lang.String buildConnectionString(java.lang.String... hosts)

Builds a connection string with the given hosts while setting priorities according to their positions.

Parameters:

hosts - the hosts list, 1st has priority=100, 2nd has priority=99, and so on

Returns:

a single host or a multi-host connection string

buildConnectionStringNoUser

private java.lang.String buildConnectionStringNoUser(java.lang.String... hosts)

setupFailoverTest

@BeforeEach
public void setupFailoverTest()

testGetSessionForSingleHost

@Test
public void testGetSessionForSingleHost()
                                       throws java.lang.Exception

Assures that failover support doesn't affect single host connections.

Throws:

java.lang.Exception

testGetSessionForMultipleHostsWithFailover

@Test
public void testGetSessionForMultipleHostsWithFailover()
                                                      throws java.lang.Exception

Tests basic failover while getting a Session instance.

Throws:

java.lang.Exception

testConnectionTimeout

@Test
 @Disabled(value="This test doesn\'t execute deterministically on some systems. It can be run manually in local systems when needed.")
public void testConnectionTimeout()
                                                                                                                                                                        throws java.lang.Exception

Tests xdevapi.connect-timeout and connectTimeout functionality. The real socket connect timeout can be revealed only when trying to connect to the unavailable remote host pointed by IP address. Neither localhost IP nor domain names are working, they fail much faster then the timeout is reached. If default 10.77.77.77:37070 doesn't work in a particular testing setup (if the ip address is available) please add this variable to ant call: -Dcom.mysql.cj.testsuite.unavailable.host=unavailable_ip:port

Throws:

java.lang.Exception

testConnectionTimeout_assertFailureTimeout

private <EX extends java.lang.Throwable> void testConnectionTimeout_assertFailureTimeout(java.lang.String url,
                                                                                         int expLowLimit,
                                                                                         int expUpLimit,
                                                                                         java.lang.Class<EX> throwable)

testConnectionTimeout_assertFailureTimeout

private void testConnectionTimeout_assertFailureTimeout(java.lang.String url,
                                                        int expLowLimit,
                                                        int expUpLimit)

testConnectionTimeout_assertSuccessTimeout

private void testConnectionTimeout_assertSuccessTimeout(java.lang.String url,
                                                        int expLowLimit,
                                                        int expUpLimit)