org.mariadb.jdbc.internal.failover

Class AbstractMastersReplicasListener

java.lang.Object

org.mariadb.jdbc.internal.failover.AbstractMastersListener

org.mariadb.jdbc.internal.failover.AbstractMastersReplicasListener

All Implemented Interfaces:

Listener

Direct Known Subclasses:

MastersReplicasListener

public abstract class AbstractMastersReplicasListener
extends AbstractMastersListener

Field Summary

Fields

Modifier and Type	Field and Description
private static Logger	logger
private java.util.concurrent.atomic.AtomicBoolean	secondaryHostFail
private long	secondaryHostFailNanos
protected java.util.concurrent.atomic.AtomicReference<Protocol>	waitNewMasterProtocol
protected java.util.concurrent.atomic.AtomicReference<Protocol>	waitNewSecondaryProtocol

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

currentConnectionAttempts, currentProtocol, currentReadOnlyAsked, explicitClosed, globalInfo, lastQueryNanos, lastRetry, proxy, urlParser

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMastersReplicasListener(UrlParser urlParser, GlobalStateInfo globalInfo)

Method Summary

Modifier and Type	Method and Description
abstract void	foundActiveSecondary(Protocol newSecondaryProtocol)
SearchFilter	getFilterForFailedHost()
long	getSecondaryHostFailNanos()
HandleErrorResult	handleFailover(java.sql.SQLException qe, java.lang.reflect.Method method, java.lang.Object[] args, Protocol protocol, boolean isClosed) Handle failover on master or replica connection.
boolean	hasHostFail()
boolean	isMasterHostFailReconnect()
boolean	isSecondaryHostFail()
boolean	isSecondaryHostFailReconnect()
protected void	resetMasterFailoverData()
protected void	resetSecondaryFailoverData()
abstract HandleErrorResult	secondaryFail(java.lang.reflect.Method method, java.lang.Object[] args, boolean killCmd)
boolean	setSecondaryHostFail() Set replica connection lost variables.

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

abortConnection, addToBlacklist, canRetryFailLoop, checkMasterStatus, clearBlacklist, closeConnection, getBlacklistKeys, getCatalog, getCurrentProtocol, getLastQueryNanos, getMajorServerVersion, getMasterHostFailNanos, getProxy, getRetriesAllDown, getTimeout, getUrlParser, handleFailLoop, initializeConnection, inTransaction, invoke, invoke, isAutoReconnect, isClosed, isExplicitClosed, isMasterConnection, isMasterHostFail, isQueryRelaunchable, isReadOnly, isServerMariaDb, isValid, noBackslashEscapes, pingMasterProtocol, preAutoReconnect, preClose, preExecute, primaryFail, prolog, reconnect, reconnectFailedConnection, relaunchOperation, removeFromBlacklist, removeListenerFromSchedulers, resetOldsBlackListHosts, sessionStateAware, setMasterHostFail, setProxy, setSessionReadOnly, switchReadOnlyConnection, syncConnection, throwFailoverMessage, versionGreaterOrEqual

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.mariadb.jdbc.internal.failover.Listener

foundActiveMaster, getServerThreadId, isMasterConnected, preAbort, rePrepareOnReplica, reset

Field Detail

logger

private static final Logger logger

waitNewSecondaryProtocol

protected final java.util.concurrent.atomic.AtomicReference<Protocol> waitNewSecondaryProtocol

waitNewMasterProtocol

protected final java.util.concurrent.atomic.AtomicReference<Protocol> waitNewMasterProtocol

secondaryHostFail

private final java.util.concurrent.atomic.AtomicBoolean secondaryHostFail

secondaryHostFailNanos

private volatile long secondaryHostFailNanos

Constructor Detail

AbstractMastersReplicasListener

protected AbstractMastersReplicasListener(UrlParser urlParser,
                                          GlobalStateInfo globalInfo)

Method Detail

handleFailover

public HandleErrorResult handleFailover(java.sql.SQLException qe,
                                        java.lang.reflect.Method method,
                                        java.lang.Object[] args,
                                        Protocol protocol,
                                        boolean isClosed)
                                 throws java.sql.SQLException

Handle failover on master or replica connection.

Specified by:

handleFailover in interface Listener

Overrides:

handleFailover in class AbstractMastersListener

Parameters:

method - called method

args - methods parameters

protocol - current protocol

Returns:

HandleErrorResult object to indicate if query has finally been relaunched or exception if not.

Throws:

java.sql.SQLException - if primary fail reconnection fails

resetMasterFailoverData

protected void resetMasterFailoverData()

Overrides:

resetMasterFailoverData in class AbstractMastersListener

resetSecondaryFailoverData

protected void resetSecondaryFailoverData()

getSecondaryHostFailNanos

public long getSecondaryHostFailNanos()

setSecondaryHostFail

public boolean setSecondaryHostFail()

Set replica connection lost variables.

Returns:

true if fail wasn't seen before

isSecondaryHostFail

public boolean isSecondaryHostFail()

isSecondaryHostFailReconnect

public boolean isSecondaryHostFailReconnect()

isMasterHostFailReconnect

public boolean isMasterHostFailReconnect()

hasHostFail

public boolean hasHostFail()

Specified by:

hasHostFail in interface Listener

Overrides:

hasHostFail in class AbstractMastersListener

getFilterForFailedHost

public SearchFilter getFilterForFailedHost()

Specified by:

getFilterForFailedHost in interface Listener

Overrides:

getFilterForFailedHost in class AbstractMastersListener

secondaryFail

public abstract HandleErrorResult secondaryFail(java.lang.reflect.Method method,
                                                java.lang.Object[] args,
                                                boolean killCmd)
                                         throws java.sql.SQLException

Throws:

java.sql.SQLException

foundActiveSecondary

public abstract void foundActiveSecondary(Protocol newSecondaryProtocol)
                                   throws java.sql.SQLException

Throws:

java.sql.SQLException