org.mariadb.jdbc.internal.mysql.listener.impl

Class MastersSlavesListener

java.lang.Object

org.mariadb.jdbc.internal.mysql.listener.AbstractMastersListener

org.mariadb.jdbc.internal.mysql.listener.AbstractMastersSlavesListener

org.mariadb.jdbc.internal.mysql.listener.impl.MastersSlavesListener

All Implemented Interfaces:

Listener

Direct Known Subclasses:

AuroraListener

public class MastersSlavesListener
extends AbstractMastersSlavesListener

this class handle the operation when multiple hosts.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	MastersSlavesListener.PingLoop private class to chech of currents connections are still ok.

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

AbstractMastersListener.FailLoop

Field Summary

Fields

Modifier and Type	Field and Description
protected long	lastQueryTime
protected Protocol	masterProtocol
protected ScheduledFuture	scheduledPing
protected Protocol	secondaryProtocol

Fields inherited from class org.mariadb.jdbc.internal.mysql.listener.AbstractMastersSlavesListener

queriesSinceFailover

Fields inherited from class org.mariadb.jdbc.internal.mysql.listener.AbstractMastersListener

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

Constructor Summary

Constructors

Constructor and Description
MastersSlavesListener(JDBCUrl jdbcUrl)

Method Summary

Modifier and Type	Method and Description
void	checkIfTypeHaveChanged(SearchFilter searchFilter)
protected void	checkInitialConnection()
void	foundActiveMaster(Protocol newMasterProtocol) method called when a new Master connection is found after a fallback
void	foundActiveSecondary(Protocol newSecondaryProtocol) method called when a new secondary connection is found after a fallback
void	initializeConnection()
void	preClose()
void	preExecute()
HandleErrorResult	primaryFail(Method method, Object[] args) to handle the newly detected failover on the master connection
void	reconnect()
void	reconnectFailedConnection(SearchFilter searchFilter) Loop to connect
HandleErrorResult	secondaryFail(Method method, Object[] args) to handle the newly detected failover on the secondary connection
boolean	shouldReconnect() When failing to a different type of host, when to retry So he doesn't appear here.
void	switchReadOnlyConnection(Boolean mustBeReadOnly) switch to a read-only(secondary) or read and write connection(master)
void	throwFailoverMessage(QueryException queryException, boolean reconnected) Throw a human readable message after a failoverException

Methods inherited from class org.mariadb.jdbc.internal.mysql.listener.AbstractMastersSlavesListener

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

Methods inherited from class org.mariadb.jdbc.internal.mysql.listener.AbstractMastersListener

addToBlacklist, getBlacklist, getCurrentProtocol, getJdbcUrl, getMasterHostFailTimestamp, getProxy, getRetriesAllDown, 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

Field Detail

masterProtocol

protected Protocol masterProtocol

secondaryProtocol

protected Protocol secondaryProtocol

lastQueryTime

protected long lastQueryTime

scheduledPing

protected ScheduledFuture scheduledPing

Constructor Detail

MastersSlavesListener

public MastersSlavesListener(JDBCUrl jdbcUrl)

Method Detail

initializeConnection

public void initializeConnection()
                          throws QueryException

Specified by:

initializeConnection in interface Listener

Specified by:

initializeConnection in class AbstractMastersListener

Throws:

QueryException

checkInitialConnection

protected void checkInitialConnection()

preClose

public void preClose()
              throws SQLException

Specified by:

preClose in interface Listener

Specified by:

preClose in class AbstractMastersListener

Throws:

SQLException

preExecute

public void preExecute()
                throws QueryException

Specified by:

preExecute in interface Listener

Specified by:

preExecute in class AbstractMastersListener

Throws:

QueryException

shouldReconnect

public boolean shouldReconnect()

When failing to a different type of host, when to retry So he doesn't appear here.

Specified by:

shouldReconnect in interface Listener

Specified by:

shouldReconnect in class AbstractMastersListener

Returns:

true if should reconnect.

reconnectFailedConnection

public void reconnectFailedConnection(SearchFilter searchFilter)
                               throws QueryException

Loop to connect

Specified by:

reconnectFailedConnection in interface Listener

Specified by:

reconnectFailedConnection in class AbstractMastersListener

Throws:

QueryException - if there is any error during reconnection

QueryException - sqlException

foundActiveMaster

public void foundActiveMaster(Protocol newMasterProtocol)

method called when a new Master connection is found after a fallback

Parameters:

newMasterProtocol - the new active connection

foundActiveSecondary

public void foundActiveSecondary(Protocol newSecondaryProtocol)

method called when a new secondary connection is found after a fallback

Specified by:

foundActiveSecondary in class AbstractMastersSlavesListener

Parameters:

newSecondaryProtocol - the new active connection

switchReadOnlyConnection

public void switchReadOnlyConnection(Boolean mustBeReadOnly)
                              throws QueryException

switch to a read-only(secondary) or read and write connection(master)

Specified by:

switchReadOnlyConnection in interface Listener

Specified by:

switchReadOnlyConnection in class AbstractMastersListener

Parameters:

mustBeReadOnly - the read-only status asked

Throws:

QueryException - if operation hasn't change protocol

primaryFail

public HandleErrorResult primaryFail(Method method,
                                     Object[] args)
                              throws Throwable

to handle the newly detected failover on the master connection

Specified by:

primaryFail in interface Listener

Specified by:

primaryFail in class AbstractMastersListener

Parameters:

method - the initial called method

args - the initial args

Returns:

an object to indicate if the previous Exception must be thrown, or the object resulting if a failover worked

Throws:

Throwable - if failover has not been catch

reconnect

public void reconnect()
               throws QueryException

Specified by:

reconnect in interface Listener

Specified by:

reconnect in class AbstractMastersListener

Throws:

QueryException

secondaryFail

public HandleErrorResult secondaryFail(Method method,
                                       Object[] args)
                                throws Throwable

to handle the newly detected failover on the secondary connection

Specified by:

secondaryFail in class AbstractMastersSlavesListener

Parameters:

method - the initial called method

args - the initial args

Returns:

an object to indicate if the previous Exception must be thrown, or the object resulting if a failover worked

Throws:

Throwable - if failover has not catch error

checkIfTypeHaveChanged

public void checkIfTypeHaveChanged(SearchFilter searchFilter)
                            throws QueryException

Throws:

QueryException

throwFailoverMessage

public void throwFailoverMessage(QueryException queryException,
                                 boolean reconnected)
                          throws QueryException

Throw a human readable message after a failoverException

Specified by:

throwFailoverMessage in interface Listener

Specified by:

throwFailoverMessage in class AbstractMastersListener

Parameters:

queryException - internal error

reconnected - connection status

Throws:

QueryException - error with failover information