org.mariadb.jdbc.internal.failover.impl

Class MastersFailoverListener

java.lang.Object

org.mariadb.jdbc.internal.failover.AbstractMastersListener

org.mariadb.jdbc.internal.failover.impl.MastersFailoverListener

All Implemented Interfaces:

Listener

public class MastersFailoverListener
extends AbstractMastersListener

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor and Description
MastersFailoverListener(UrlParser urlParser) Initialisation.

Method Summary

Modifier and Type	Method and Description
void	foundActiveMaster(Protocol protocol) method called when a new Master connection is found after a fallback.
void	initializeConnection() Connect to database.
void	preClose()
void	preExecute() Before executing query, reconnect if connection is closed, and autoReconnect option is set.
HandleErrorResult	primaryFail(Method method, Object[] args)
void	reconnect()
void	reconnectFailedConnection(SearchFilter searchFilter) Loop to connect.
boolean	shouldReconnect()
void	switchReadOnlyConnection(Boolean mustBeReadOnly) Force session to read-only according to options.
void	throwFailoverMessage(QueryException queryException, boolean reconnected) Throw a human readable message after a failoverException.

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

addToBlacklist, getBlacklist, getCurrentProtocol, getFilterForFailedHost, getMasterHostFailTimestamp, getProxy, getRetriesAllDown, getUrlParser, handleFailover, hasHostFail, invoke, isAutoReconnect, isClosed, isExplicitClosed, isMasterHostFail, isReadOnly, launchFailLoopIfNotlaunched, relaunchOperation, resetMasterFailoverData, 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

MastersFailoverListener

public MastersFailoverListener(UrlParser urlParser)

Initialisation.

Parameters:

urlParser - url options.

Method Detail

initializeConnection

public void initializeConnection()
                          throws QueryException

Connect to database.

Specified by:

initializeConnection in interface Listener

Specified by:

initializeConnection in class AbstractMastersListener

Throws:

QueryException - if connection is on error.

preExecute

public void preExecute()
                throws QueryException

Before executing query, reconnect if connection is closed, and autoReconnect option is set.

Specified by:

preExecute in interface Listener

Specified by:

preExecute in class AbstractMastersListener

Throws:

QueryException - if connection has been explicitly closed.

shouldReconnect

public boolean shouldReconnect()

Specified by:

shouldReconnect in interface Listener

Specified by:

shouldReconnect in class AbstractMastersListener

preClose

public void preClose()
              throws SQLException

Specified by:

preClose in interface Listener

Specified by:

preClose in class AbstractMastersListener

Throws:

SQLException

primaryFail

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

Specified by:

primaryFail in interface Listener

Specified by:

primaryFail in class AbstractMastersListener

Throws:

Throwable

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

switchReadOnlyConnection

public void switchReadOnlyConnection(Boolean mustBeReadOnly)
                              throws QueryException

Force session to read-only according to options.

Specified by:

switchReadOnlyConnection in interface Listener

Specified by:

switchReadOnlyConnection in class AbstractMastersListener

Parameters:

mustBeReadOnly - is read-only flag

Throws:

QueryException - if a connection error occur

foundActiveMaster

public void foundActiveMaster(Protocol protocol)
                       throws QueryException

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

Parameters:

protocol - the new active connection

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

reconnect

public void reconnect()
               throws QueryException

Specified by:

reconnect in interface Listener

Specified by:

reconnect in class AbstractMastersListener

Throws:

QueryException