com.oceanbase.jdbc.internal.failover.impl

类 MastersSlavesListener

java.lang.Object

com.oceanbase.jdbc.internal.failover.AbstractMastersListener

com.oceanbase.jdbc.internal.failover.AbstractMastersSlavesListener

com.oceanbase.jdbc.internal.failover.impl.MastersSlavesListener

所有已实现的接口:

Listener

直接已知子类:

AuroraListener

public class MastersSlavesListener
extends AbstractMastersSlavesListener

this class handle the operation when multiple hosts.

字段概要

字段

限定符和类型	字段和说明
protected List<HostAddress>	hostAddresses
protected static Logger	lockLogger
protected Protocol	masterProtocol
protected Protocol	secondaryProtocol

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

waitNewMasterProtocol, waitNewSecondaryProtocol

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

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

构造器概要

构造器

构造器和说明
MastersSlavesListener(UrlParser urlParser, GlobalStateInfo globalInfo) Initialisation.

方法概要

限定符和类型	方法和说明
protected void	checkInitialConnection(SQLException queryException)
boolean	checkMasterStatus(SearchFilter searchFilter) Check master status.
void	checkWaitingConnection() Verify that there is waiting connection that have to replace failing one.
List<HostAddress>	connectedHosts() List current connected HostAddress.
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.
String	getCatalog()
int	getMajorServerVersion()
long	getServerThreadId() Get current connection server id.
int	getTimeout() Get timeout (master connection possibly down).
void	handleFailLoop()
void	initializeConnection() Initialize connections.
boolean	inTransaction() Indicate if connection has an active transaction.
Object	invoke(Method method, Object[] args)
boolean	isClosed()
boolean	isMasterConnected()
boolean	isMasterConnection()
boolean	isServerMariaDb()
boolean	isValid(int timeout)
void	lockAndSwitchMaster(Protocol newMasterProtocol) Use the parameter newMasterProtocol as new current master connection.
void	lockAndSwitchSecondary(Protocol newSecondaryProtocol) Use the parameter newSecondaryProtocol as new current secondary connection.
boolean	noBackslashEscapes()
void	preAbort()
void	preClose() Called after a call on Connection.close().
void	preExecute()
HandleErrorResult	primaryFail(Method method, Object[] args, boolean killCmd, boolean isClosed) To handle the newly detected failover on the master connection.
void	prolog(long maxRows, OceanBaseConnection connection, OceanBaseStatement statement)
void	reconnect() Reconnect failed connection.
void	reconnectFailedConnection(SearchFilter searchFilter) Loop to connect.
protected void	removeListenerFromSchedulers()
void	rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult, boolean mustBeOnMaster)
void	reset() Reset state of master and slave connection.
HandleErrorResult	secondaryFail(Method method, Object[] args, boolean killCmd) To handle the newly detected failover on the secondary connection.
boolean	sessionStateAware()
void	switchReadOnlyConnection(Boolean mustBeReadOnly) Switch to a read-only(secondary) or read and write connection(master).
boolean	versionGreaterOrEqual(int major, int minor, int patch)

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

getFilterForFailedHost, getSecondaryHostFailNanos, handleFailover, hasHostFail, isMasterHostFailReconnect, isSecondaryHostFail, isSecondaryHostFailReconnect, resetMasterFailoverData, resetSecondaryFailoverData, setSecondaryHostFail

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

abortConnection, addToBlacklist, addToPickedList, canRetryFailLoop, clearBlacklist, closeConnection, getBlacklist, getBlacklistKeys, getCurrentLoadBalanceInfo, getCurrentProtocol, getLastQueryNanos, getMasterHostFailNanos, getPickedlist, getProxy, getRetriesAllDown, getRetryAllDowns, getUrlParser, invoke, isAutoReconnect, isExplicitClosed, isMasterHostFail, isQueryRelaunchable, isReadOnly, pingMasterProtocol, preAutoReconnect, relaunchOperation, removeFromBlacklist, removeFromPickedList, resetHostStateInfo, resetOldsBlackListHosts, setCurrentLoadBalanceInfo, setMasterHostFail, setProxy, setRetryAllDowns, setSessionReadOnly, syncConnection, throwFailoverMessage

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

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

字段详细资料

masterProtocol

protected Protocol masterProtocol

secondaryProtocol

protected Protocol secondaryProtocol

hostAddresses

protected List<HostAddress> hostAddresses

lockLogger

protected static final Logger lockLogger

构造器详细资料

MastersSlavesListener

public MastersSlavesListener(UrlParser urlParser,
                             GlobalStateInfo globalInfo)

Initialisation.

参数:

urlParser - connection string object.

globalInfo - server global variables information

方法详细资料

removeListenerFromSchedulers

protected void removeListenerFromSchedulers()

覆盖:

removeListenerFromSchedulers 在类中 AbstractMastersListener

initializeConnection

public void initializeConnection()
                          throws SQLException

Initialize connections.

指定者:

initializeConnection 在接口中 Listener

覆盖:

initializeConnection 在类中 AbstractMastersListener

抛出:

SQLException - if a connection error append.

isClosed

public boolean isClosed()

指定者:

isClosed 在接口中 Listener

覆盖:

isClosed 在类中 AbstractMastersListener

invoke

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

指定者:

invoke 在接口中 Listener

覆盖:

invoke 在类中 AbstractMastersListener

抛出:

Throwable

versionGreaterOrEqual

public boolean versionGreaterOrEqual(int major,
                                     int minor,
                                     int patch)

指定者:

versionGreaterOrEqual 在接口中 Listener

覆盖:

versionGreaterOrEqual 在类中 AbstractMastersListener

isServerMariaDb

public boolean isServerMariaDb()

指定者:

isServerMariaDb 在接口中 Listener

覆盖:

isServerMariaDb 在类中 AbstractMastersListener

sessionStateAware

public boolean sessionStateAware()

指定者:

sessionStateAware 在接口中 Listener

覆盖:

sessionStateAware 在类中 AbstractMastersListener

getCatalog

public String getCatalog()
                  throws SQLException

指定者:

getCatalog 在接口中 Listener

覆盖:

getCatalog 在类中 AbstractMastersListener

抛出:

SQLException

getMajorServerVersion

public int getMajorServerVersion()

指定者:

getMajorServerVersion 在接口中 Listener

覆盖:

getMajorServerVersion 在类中 AbstractMastersListener

isMasterConnection

public boolean isMasterConnection()

指定者:

isMasterConnection 在接口中 Listener

覆盖:

isMasterConnection 在类中 AbstractMastersListener

getTimeout

public int getTimeout()
               throws SocketException

Get timeout (master connection possibly down).

指定者:

getTimeout 在接口中 Listener

覆盖:

getTimeout 在类中 AbstractMastersListener

返回:

socket timeout in ms

抛出:

SocketException - if socket exception

prolog

public void prolog(long maxRows,
                   OceanBaseConnection connection,
                   OceanBaseStatement statement)
            throws SQLException

指定者:

prolog 在接口中 Listener

覆盖:

prolog 在类中 AbstractMastersListener

抛出:

SQLException

noBackslashEscapes

public boolean noBackslashEscapes()

指定者:

noBackslashEscapes 在接口中 Listener

覆盖:

noBackslashEscapes 在类中 AbstractMastersListener

getServerThreadId

public long getServerThreadId()

Get current connection server id.

返回:

server id.

checkInitialConnection

protected void checkInitialConnection(SQLException queryException)
                               throws SQLException

抛出:

SQLException

preClose

public void preClose()

Called after a call on Connection.close(). Will explicitly closed all connections.

指定者:

preClose 在接口中 Listener

指定者:

preClose 在类中 AbstractMastersListener

preAbort

public void preAbort()

preExecute

public void preExecute()
                throws SQLException

指定者:

preExecute 在接口中 Listener

指定者:

preExecute 在类中 AbstractMastersListener

抛出:

SQLException

isValid

public boolean isValid(int timeout)
                throws SQLException

指定者:

isValid 在接口中 Listener

覆盖:

isValid 在类中 AbstractMastersListener

抛出:

SQLException

checkWaitingConnection

public void checkWaitingConnection()
                            throws SQLException

Verify that there is waiting connection that have to replace failing one. If there is replace failed connection with new one.

抛出:

SQLException - if error occur

reconnectFailedConnection

public void reconnectFailedConnection(SearchFilter searchFilter)
                               throws SQLException

Loop to connect.

指定者:

reconnectFailedConnection 在接口中 Listener

指定者:

reconnectFailedConnection 在类中 AbstractMastersListener

抛出:

SQLException - if there is any error during reconnection

foundActiveMaster

public void foundActiveMaster(Protocol newMasterProtocol)

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

参数:

newMasterProtocol - the new active connection

lockAndSwitchMaster

public void lockAndSwitchMaster(Protocol newMasterProtocol)
                         throws ReconnectDuringTransactionException

Use the parameter newMasterProtocol as new current master connection.

Lock must be set

参数:

newMasterProtocol - new master connection

抛出:

ReconnectDuringTransactionException - if there was an active transaction.

foundActiveSecondary

public void foundActiveSecondary(Protocol newSecondaryProtocol)
                          throws SQLException

Method called when a new secondary connection is found after a fallback.

指定者:

foundActiveSecondary 在类中 AbstractMastersSlavesListener

参数:

newSecondaryProtocol - the new active connection

抛出:

SQLException - if switch failed

lockAndSwitchSecondary

public void lockAndSwitchSecondary(Protocol newSecondaryProtocol)
                            throws SQLException

Use the parameter newSecondaryProtocol as new current secondary connection.

参数:

newSecondaryProtocol - new secondary connection

抛出:

SQLException - if an error occur during setting session read-only

switchReadOnlyConnection

public void switchReadOnlyConnection(Boolean mustBeReadOnly)
                              throws SQLException

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

指定者:

switchReadOnlyConnection 在接口中 Listener

指定者:

switchReadOnlyConnection 在类中 AbstractMastersListener

参数:

mustBeReadOnly - the read-only status asked

抛出:

SQLException - if operation hasn't change protocol

primaryFail

public HandleErrorResult primaryFail(Method method,
                                     Object[] args,
                                     boolean killCmd,
                                     boolean isClosed)

To handle the newly detected failover on the master connection.

指定者:

primaryFail 在接口中 Listener

指定者:

primaryFail 在类中 AbstractMastersListener

参数:

method - the initial called method

args - the initial args

killCmd - is the fail due to a KILL cmd

返回:

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

reconnect

public void reconnect()
               throws SQLException

Reconnect failed connection.

指定者:

reconnect 在接口中 Listener

指定者:

reconnect 在类中 AbstractMastersListener

抛出:

SQLException - if reconnection has failed

secondaryFail

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

To handle the newly detected failover on the secondary connection.

指定者:

secondaryFail 在类中 AbstractMastersSlavesListener

参数:

method - the initial called method

args - the initial args

killCmd - is fail due to a KILL command

返回:

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

抛出:

SQLException - if relaunch operation fails

handleFailLoop

public void handleFailLoop()

指定者:

handleFailLoop 在类中 AbstractMastersListener

isMasterConnected

public boolean isMasterConnected()

inTransaction

public boolean inTransaction()

Indicate if connection has an active transaction.

指定者:

inTransaction 在接口中 Listener

覆盖:

inTransaction 在类中 AbstractMastersListener

返回:

boolean

checkMasterStatus

public boolean checkMasterStatus(SearchFilter searchFilter)

Check master status.

指定者:

checkMasterStatus 在接口中 Listener

指定者:

checkMasterStatus 在类中 AbstractMastersListener

参数:

searchFilter - search filter

返回:

has some status changed

rePrepareOnSlave

public void rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult,
                             boolean mustBeOnMaster)
                      throws SQLException

抛出:

SQLException

connectedHosts

public List<HostAddress> connectedHosts()

List current connected HostAddress.

返回:

hostAddress List.

reset

public void reset()
           throws SQLException

Reset state of master and slave connection.

抛出:

SQLException - if command fail.