public class MastersFailoverListener extends AbstractMastersListener
currentConnectionAttempts, currentProtocol, currentReadOnlyAsked, explicitClosed, globalInfo, lastQueryNanos, lastRetry, proxy, urlParser
Constructor and Description |
---|
MastersFailoverListener(UrlParser urlParser,
GlobalStateInfo globalInfo)
Initialisation.
|
Modifier and Type | Method and Description |
---|---|
boolean |
checkMasterStatus(SearchFilter searchFilter)
Check master status.
|
void |
foundActiveMaster(Protocol protocol)
method called when a new Master connection is found after a fallback.
|
void |
handleFailLoop()
Add listener to FailoverLoop if master connection is not active, so a reconnection will be done.
|
void |
initializeConnection()
Connect to database.
|
boolean |
isMasterConnected() |
void |
preClose() |
void |
preExecute()
Before executing query, reconnect if connection is closed, and autoReconnect option is set.
|
HandleErrorResult |
primaryFail(Method method,
Object[] args,
boolean killCmd) |
void |
reconnect()
Try to reconnect connection.
|
void |
reconnectFailedConnection(SearchFilter searchFilter)
Loop to connect failed hosts.
|
void |
rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult,
boolean mustExecuteOnSlave) |
void |
reset()
Reset state of master connection.
|
void |
switchReadOnlyConnection(Boolean mustBeReadOnly)
Force session to read-only according to options.
|
addToBlacklist, canRetryFailLoop, clearBlacklist, closeConnection, getBlacklistKeys, getCurrentProtocol, getFilterForFailedHost, getLastQueryNanos, getMasterHostFailNanos, getProxy, getRetriesAllDown, getUrlParser, handleFailover, hasHostFail, invoke, invoke, isAutoReconnect, isClosed, isExplicitClosed, isMasterHostFail, isQueryRelaunchable, isReadOnly, isValid, pingMasterProtocol, preAutoReconnect, relaunchOperation, removeFromBlacklist, removeListenerFromSchedulers, resetMasterFailoverData, resetOldsBlackListHosts, setMasterHostFail, setProxy, setSessionReadOnly, syncConnection, throwFailoverMessage
public MastersFailoverListener(UrlParser urlParser, GlobalStateInfo globalInfo)
urlParser
- url options.globalInfo
- server global variables informationpublic void initializeConnection() throws SQLException
initializeConnection
in interface Listener
initializeConnection
in class AbstractMastersListener
SQLException
- if connection is on error.public void preExecute() throws SQLException
preExecute
in interface Listener
preExecute
in class AbstractMastersListener
SQLException
- if connection has been explicitly closed.public void preClose()
preClose
in interface Listener
preClose
in class AbstractMastersListener
public HandleErrorResult primaryFail(Method method, Object[] args, boolean killCmd) throws Throwable
primaryFail
in interface Listener
primaryFail
in class AbstractMastersListener
Throwable
public void reconnectFailedConnection(SearchFilter searchFilter) throws SQLException
reconnectFailedConnection
in interface Listener
reconnectFailedConnection
in class AbstractMastersListener
searchFilter
- search parameters.SQLException
- if there is any error during reconnectionpublic void switchReadOnlyConnection(Boolean mustBeReadOnly) throws SQLException
switchReadOnlyConnection
in interface Listener
switchReadOnlyConnection
in class AbstractMastersListener
mustBeReadOnly
- is read-only flagSQLException
- if a connection error occurpublic void foundActiveMaster(Protocol protocol) throws SQLException
protocol
- the new active connectionSQLException
public void reconnect() throws SQLException
reconnect
in interface Listener
reconnect
in class AbstractMastersListener
SQLException
- if reconnect a new connection but there was an active transaction.public void handleFailLoop()
handleFailLoop
in class AbstractMastersListener
public boolean isMasterConnected()
public boolean checkMasterStatus(SearchFilter searchFilter)
checkMasterStatus
in interface Listener
checkMasterStatus
in class AbstractMastersListener
searchFilter
- search filterpublic void rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult, boolean mustExecuteOnSlave)
public void reset() throws SQLException
SQLException
- if command fail.Copyright © 2018 mariadb.org. All rights reserved.