com.oceanbase.jdbc.internal.failover

类 AbstractMastersSlavesListener

java.lang.Object

com.oceanbase.jdbc.internal.failover.AbstractMastersListener

com.oceanbase.jdbc.internal.failover.AbstractMastersSlavesListener

所有已实现的接口:

Listener

直接已知子类:

MastersSlavesListener

public abstract class AbstractMastersSlavesListener
extends AbstractMastersListener

字段概要

字段

限定符和类型	字段和说明
protected AtomicReference<Protocol>	waitNewMasterProtocol
protected AtomicReference<Protocol>	waitNewSecondaryProtocol

从类继承的字段 com.oceanbase.jdbc.internal.failover.AbstractMastersListener

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

构造器概要

构造器

限定符	构造器和说明
protected	AbstractMastersSlavesListener(UrlParser urlParser, GlobalStateInfo globalInfo)

方法概要

限定符和类型	方法和说明
abstract void	foundActiveSecondary(Protocol newSecondaryProtocol)
SearchFilter	getFilterForFailedHost()
long	getSecondaryHostFailNanos()
HandleErrorResult	handleFailover(SQLException qe, Method method, Object[] args, Protocol protocol, boolean isClosed) Handle failover on master or slave connection.
boolean	hasHostFail()
boolean	isMasterHostFailReconnect()
boolean	isSecondaryHostFail()
boolean	isSecondaryHostFailReconnect()
void	resetMasterFailoverData()
protected void	resetSecondaryFailoverData()
abstract HandleErrorResult	secondaryFail(Method method, Object[] args, boolean killCmd)
boolean	setSecondaryHostFail() Set slave connection lost variables.

从类继承的方法 com.oceanbase.jdbc.internal.failover.AbstractMastersListener

abortConnection, addToBlacklist, addToPickedList, canRetryFailLoop, checkMasterStatus, clearBlacklist, closeConnection, getBlacklist, getBlacklistKeys, getCatalog, getCurrentLoadBalanceInfo, getCurrentProtocol, getLastQueryNanos, getMajorServerVersion, getMasterHostFailNanos, getPickedlist, getProxy, getRetriesAllDown, getRetryAllDowns, 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, removeFromPickedList, removeListenerFromSchedulers, resetHostStateInfo, resetOldsBlackListHosts, sessionStateAware, setCurrentLoadBalanceInfo, setMasterHostFail, setProxy, setRetryAllDowns, setSessionReadOnly, switchReadOnlyConnection, syncConnection, throwFailoverMessage, versionGreaterOrEqual

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.oceanbase.jdbc.internal.failover.Listener

foundActiveMaster, getServerThreadId, isMasterConnected, preAbort, rePrepareOnSlave, reset

字段详细资料

waitNewSecondaryProtocol

protected final AtomicReference<Protocol> waitNewSecondaryProtocol

waitNewMasterProtocol

protected final AtomicReference<Protocol> waitNewMasterProtocol

构造器详细资料

AbstractMastersSlavesListener

protected AbstractMastersSlavesListener(UrlParser urlParser,
                                        GlobalStateInfo globalInfo)

方法详细资料

handleFailover

public HandleErrorResult handleFailover(SQLException qe,
                                        Method method,
                                        Object[] args,
                                        Protocol protocol,
                                        boolean isClosed)
                                 throws SQLException

Handle failover on master or slave connection.

指定者:

handleFailover 在接口中 Listener

覆盖:

handleFailover 在类中 AbstractMastersListener

参数:

method - called method

args - methods parameters

protocol - current protocol

返回:

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

抛出:

SQLException - if primary fail reconnection fails

resetMasterFailoverData

public void resetMasterFailoverData()

覆盖:

resetMasterFailoverData 在类中 AbstractMastersListener

resetSecondaryFailoverData

protected void resetSecondaryFailoverData()

getSecondaryHostFailNanos

public long getSecondaryHostFailNanos()

setSecondaryHostFail

public boolean setSecondaryHostFail()

Set slave connection lost variables.

返回:

true if fail wasn't seen before

isSecondaryHostFail

public boolean isSecondaryHostFail()

isSecondaryHostFailReconnect

public boolean isSecondaryHostFailReconnect()

isMasterHostFailReconnect

public boolean isMasterHostFailReconnect()

hasHostFail

public boolean hasHostFail()

指定者:

hasHostFail 在接口中 Listener

覆盖:

hasHostFail 在类中 AbstractMastersListener

getFilterForFailedHost

public SearchFilter getFilterForFailedHost()

指定者:

getFilterForFailedHost 在接口中 Listener

覆盖:

getFilterForFailedHost 在类中 AbstractMastersListener

secondaryFail

public abstract HandleErrorResult secondaryFail(Method method,
                                                Object[] args,
                                                boolean killCmd)
                                         throws SQLException

抛出:

SQLException

foundActiveSecondary

public abstract void foundActiveSecondary(Protocol newSecondaryProtocol)
                                   throws SQLException

抛出:

SQLException