org.mariadb.jdbc.internal.failover.impl

Class AuroraListener

java.lang.Object

org.mariadb.jdbc.internal.failover.AbstractMastersListener

org.mariadb.jdbc.internal.failover.AbstractMastersSlavesListener

org.mariadb.jdbc.internal.failover.impl.MastersSlavesListener

org.mariadb.jdbc.internal.failover.impl.AuroraListener

All Implemented Interfaces:

Listener

public class AuroraListener
extends MastersSlavesListener

Nested Class Summary

Nested classes/interfaces inherited from class org.mariadb.jdbc.internal.failover.impl.MastersSlavesListener

MastersSlavesListener.PingLoop

Nested classes/interfaces inherited from class org.mariadb.jdbc.internal.failover.AbstractMastersListener

AbstractMastersListener.FailLoop

Field Summary

Fields inherited from class org.mariadb.jdbc.internal.failover.impl.MastersSlavesListener

lastQueryTime, masterProtocol, scheduledPing, secondaryProtocol

Fields inherited from class org.mariadb.jdbc.internal.failover.AbstractMastersSlavesListener

queriesSinceFailover

Fields inherited from class org.mariadb.jdbc.internal.failover.AbstractMastersListener

blacklist, currentConnectionAttempts, currentProtocol, currentReadOnlyAsked, executorService, explicitClosed, isLooping, lastRetry, proxy, scheduledFailover, urlParser

Constructor Summary

Constructors

Constructor and Description
AuroraListener(UrlParser urlParser) Constructor for Aurora.

Method Summary

Modifier and Type	Method and Description
void	checkMasterStatus(SearchFilter searchFilter) Check master status.
void	initializeConnection() Initialize connections.
void	reconnectFailedConnection(SearchFilter searchFilter) search a valid connection for failed one.
HostAddress	searchByStartName(Protocol secondaryProtocol, List<HostAddress> loopAddress) Aurora replica doesn't have the master endpoint but the master instance name.

Methods inherited from class org.mariadb.jdbc.internal.failover.impl.MastersSlavesListener

checkInitialConnection, foundActiveMaster, foundActiveSecondary, preClose, preExecute, primaryFail, reconnect, secondaryFail, shouldReconnect, switchReadOnlyConnection, throwFailoverMessage

Methods inherited from class org.mariadb.jdbc.internal.failover.AbstractMastersSlavesListener

getFilterForFailedHost, getSecondaryHostFailTimestamp, handleFailover, hasHostFail, isSecondaryHostFail, resetMasterFailoverData, resetSecondaryFailoverData, setSecondaryHostFail

Methods inherited from class org.mariadb.jdbc.internal.failover.AbstractMastersListener

addToBlacklist, clearBlacklist, getBlacklist, getCurrentProtocol, getMasterHostFailTimestamp, getProxy, getRetriesAllDown, getUrlParser, invoke, isAutoReconnect, isClosed, isExplicitClosed, isMasterHostFail, isReadOnly, launchFailLoopIfNotlaunched, relaunchOperation, resetOldsBlackListHosts, setExplicitClosed, setMasterHostFail, setProxy, setSessionReadOnly, stopFailover, syncConnection

Methods inherited from class java.lang.Object

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

Constructor Detail

AuroraListener

public AuroraListener(UrlParser urlParser)

Constructor for Aurora. This differ from standard failover because : - we don't know current master, we must check that after initial connection - master can change after he has a failover

Parameters:

urlParser - connection informations

Method Detail

initializeConnection

public void initializeConnection()
                          throws QueryException

Description copied from class: MastersSlavesListener

Initialize connections.

Specified by:

initializeConnection in interface Listener

Overrides:

initializeConnection in class MastersSlavesListener

Throws:

QueryException - if a connection error append.

reconnectFailedConnection

public void reconnectFailedConnection(SearchFilter searchFilter)
                               throws QueryException

search a valid connection for failed one. A Node can be a master or a replica depending on the cluster state. so search for each host until found all the failed connection. By default, search for the host not down, and recheck the down one after if not found valid connections.

Specified by:

reconnectFailedConnection in interface Listener

Overrides:

reconnectFailedConnection in class MastersSlavesListener

Throws:

QueryException - if a connection asked is not found

searchByStartName

public HostAddress searchByStartName(Protocol secondaryProtocol,
                                     List<HostAddress> loopAddress)

Aurora replica doesn't have the master endpoint but the master instance name. since the end point normally use the instance name like "instancename.some_ugly_string.region.rds.amazonaws.com", if an endpoint start with this instance name, it will be checked first.

Parameters:

secondaryProtocol - the current secondary protocol

loopAddress - list of possible hosts

Returns:

the probable master address or null if not found

checkMasterStatus

public void checkMasterStatus(SearchFilter searchFilter)
                       throws QueryException

Description copied from class: MastersSlavesListener

Check master status.

Overrides:

checkMasterStatus in class MastersSlavesListener

Parameters:

searchFilter - search filter

Throws:

QueryException - exception