public class MastersSlavesListener extends AbstractMastersSlavesListener
Modifier and Type | Field and Description |
---|---|
protected List<HostAddress> |
hostAddresses |
protected Protocol |
masterProtocol |
protected Protocol |
secondaryProtocol |
waitNewMasterProtocol, waitNewSecondaryProtocol
currentConnectionAttempts, currentProtocol, currentReadOnlyAsked, explicitClosed, globalInfo, lastQueryNanos, lastRetry, proxy, urlParser
Constructor and Description |
---|
MastersSlavesListener(UrlParser urlParser,
GlobalStateInfo globalInfo)
Initialisation.
|
Modifier and Type | Method and Description |
---|---|
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,
MariaDbConnection connection,
MariaDbStatement 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) |
getFilterForFailedHost, getSecondaryHostFailNanos, handleFailover, hasHostFail, isMasterHostFailReconnect, isSecondaryHostFail, isSecondaryHostFailReconnect, resetMasterFailoverData, resetSecondaryFailoverData, setSecondaryHostFail
abortConnection, addToBlacklist, canRetryFailLoop, clearBlacklist, closeConnection, getBlacklistKeys, getCurrentProtocol, getLastQueryNanos, getMasterHostFailNanos, getProxy, getRetriesAllDown, getUrlParser, invoke, isAutoReconnect, isExplicitClosed, isMasterHostFail, isQueryRelaunchable, isReadOnly, pingMasterProtocol, preAutoReconnect, relaunchOperation, removeFromBlacklist, resetOldsBlackListHosts, setMasterHostFail, setProxy, setSessionReadOnly, syncConnection, throwFailoverMessage
protected Protocol masterProtocol
protected Protocol secondaryProtocol
protected List<HostAddress> hostAddresses
public MastersSlavesListener(UrlParser urlParser, GlobalStateInfo globalInfo)
urlParser
- connection string object.globalInfo
- server global variables informationprotected void removeListenerFromSchedulers()
removeListenerFromSchedulers
in class AbstractMastersListener
public void initializeConnection() throws SQLException
initializeConnection
in interface Listener
initializeConnection
in class AbstractMastersListener
SQLException
- if a connection error append.public boolean isClosed()
isClosed
in interface Listener
isClosed
in class AbstractMastersListener
public Object invoke(Method method, Object[] args) throws Throwable
invoke
in interface Listener
invoke
in class AbstractMastersListener
Throwable
public boolean versionGreaterOrEqual(int major, int minor, int patch)
versionGreaterOrEqual
in interface Listener
versionGreaterOrEqual
in class AbstractMastersListener
public boolean isServerMariaDb()
isServerMariaDb
in interface Listener
isServerMariaDb
in class AbstractMastersListener
public boolean sessionStateAware()
sessionStateAware
in interface Listener
sessionStateAware
in class AbstractMastersListener
public String getCatalog() throws SQLException
getCatalog
in interface Listener
getCatalog
in class AbstractMastersListener
SQLException
public int getMajorServerVersion()
getMajorServerVersion
in interface Listener
getMajorServerVersion
in class AbstractMastersListener
public boolean isMasterConnection()
isMasterConnection
in interface Listener
isMasterConnection
in class AbstractMastersListener
public int getTimeout() throws SocketException
getTimeout
in interface Listener
getTimeout
in class AbstractMastersListener
SocketException
- if socket exceptionpublic void prolog(long maxRows, MariaDbConnection connection, MariaDbStatement statement) throws SQLException
prolog
in interface Listener
prolog
in class AbstractMastersListener
SQLException
public boolean noBackslashEscapes()
noBackslashEscapes
in interface Listener
noBackslashEscapes
in class AbstractMastersListener
public long getServerThreadId()
protected void checkInitialConnection(SQLException queryException) throws SQLException
SQLException
public void preClose()
preClose
in interface Listener
preClose
in class AbstractMastersListener
public void preAbort()
public void preExecute() throws SQLException
preExecute
in interface Listener
preExecute
in class AbstractMastersListener
SQLException
public boolean isValid(int timeout) throws SQLException
isValid
in interface Listener
isValid
in class AbstractMastersListener
SQLException
public void checkWaitingConnection() throws SQLException
SQLException
- if error occurpublic void reconnectFailedConnection(SearchFilter searchFilter) throws SQLException
reconnectFailedConnection
in interface Listener
reconnectFailedConnection
in class AbstractMastersListener
SQLException
- if there is any error during reconnectionpublic void foundActiveMaster(Protocol newMasterProtocol)
newMasterProtocol
- the new active connectionpublic void lockAndSwitchMaster(Protocol newMasterProtocol) throws ReconnectDuringTransactionException
Lock must be set
newMasterProtocol
- new master connectionReconnectDuringTransactionException
- if there was an active transaction.public void foundActiveSecondary(Protocol newSecondaryProtocol) throws SQLException
foundActiveSecondary
in class AbstractMastersSlavesListener
newSecondaryProtocol
- the new active connectionSQLException
- if switch failedpublic void lockAndSwitchSecondary(Protocol newSecondaryProtocol) throws SQLException
newSecondaryProtocol
- new secondary connectionSQLException
- if an error occur during setting session read-onlypublic void switchReadOnlyConnection(Boolean mustBeReadOnly) throws SQLException
switchReadOnlyConnection
in interface Listener
switchReadOnlyConnection
in class AbstractMastersListener
mustBeReadOnly
- the read-only status askedSQLException
- if operation hasn't change protocolpublic HandleErrorResult primaryFail(Method method, Object[] args, boolean killCmd, boolean isClosed)
primaryFail
in interface Listener
primaryFail
in class AbstractMastersListener
method
- the initial called methodargs
- the initial argskillCmd
- is the fail due to a KILL cmdpublic void reconnect() throws SQLException
reconnect
in interface Listener
reconnect
in class AbstractMastersListener
SQLException
- if reconnection has failedpublic HandleErrorResult secondaryFail(Method method, Object[] args, boolean killCmd) throws SQLException
secondaryFail
in class AbstractMastersSlavesListener
method
- the initial called methodargs
- the initial argskillCmd
- is fail due to a KILL commandSQLException
- if relaunch operation failspublic void handleFailLoop()
handleFailLoop
in class AbstractMastersListener
public boolean isMasterConnected()
public boolean inTransaction()
inTransaction
in interface Listener
inTransaction
in class AbstractMastersListener
public boolean checkMasterStatus(SearchFilter searchFilter)
checkMasterStatus
in interface Listener
checkMasterStatus
in class AbstractMastersListener
searchFilter
- search filterpublic void rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult, boolean mustBeOnMaster) throws SQLException
SQLException
public List<HostAddress> connectedHosts()
public void reset() throws SQLException
SQLException
- if command fail.Copyright © 2020 mariadb.com. All rights reserved.