public interface Listener
Modifier and Type | Method and Description |
---|---|
void |
addToBlacklist(HostAddress hostAddress) |
boolean |
canRetryFailLoop() |
boolean |
checkMasterStatus(SearchFilter searchFilter) |
void |
foundActiveMaster(Protocol protocol) |
java.util.Set<HostAddress> |
getBlacklistKeys() |
java.lang.String |
getCatalog() |
Protocol |
getCurrentProtocol() |
SearchFilter |
getFilterForFailedHost() |
long |
getLastQueryNanos() |
int |
getMajorServerVersion() |
FailoverProxy |
getProxy() |
int |
getRetriesAllDown() |
long |
getServerThreadId() |
int |
getTimeout() |
UrlParser |
getUrlParser() |
HandleErrorResult |
handleFailover(java.sql.SQLException qe,
java.lang.reflect.Method method,
java.lang.Object[] args,
Protocol protocol) |
boolean |
hasHostFail() |
void |
initializeConnection() |
boolean |
inTransaction() |
java.lang.Object |
invoke(java.lang.reflect.Method method,
java.lang.Object[] args) |
java.lang.Object |
invoke(java.lang.reflect.Method method,
java.lang.Object[] args,
Protocol specificProtocol) |
boolean |
isAutoReconnect() |
boolean |
isClosed() |
boolean |
isExplicitClosed() |
boolean |
isMasterConnected() |
boolean |
isMasterConnection() |
boolean |
isMasterHostFail() |
boolean |
isReadOnly() |
boolean |
isValid(int timeout) |
boolean |
noBackslashEscapes() |
void |
preAbort() |
void |
preClose() |
void |
preExecute() |
HandleErrorResult |
primaryFail(java.lang.reflect.Method method,
java.lang.Object[] args,
boolean killCmd) |
void |
prolog(long maxRows,
MariaDbConnection connection,
MariaDbStatement statement) |
void |
reconnect() |
void |
reconnectFailedConnection(SearchFilter filter) |
void |
removeFromBlacklist(HostAddress hostAddress) |
void |
rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult,
boolean mustExecuteOnMaster) |
void |
reset() |
boolean |
sessionStateAware() |
boolean |
setMasterHostFail() |
void |
setProxy(FailoverProxy proxy) |
void |
switchReadOnlyConnection(java.lang.Boolean readonly) |
void |
syncConnection(Protocol from,
Protocol to) |
void |
throwFailoverMessage(HostAddress failHostAddress,
boolean wasMaster,
java.sql.SQLException queryException,
boolean reconnected) |
boolean |
versionGreaterOrEqual(int major,
int minor,
int patch) |
FailoverProxy getProxy()
void setProxy(FailoverProxy proxy)
void initializeConnection() throws java.sql.SQLException
java.sql.SQLException
void preExecute() throws java.sql.SQLException
java.sql.SQLException
void preClose()
void preAbort()
long getServerThreadId()
void reconnectFailedConnection(SearchFilter filter) throws java.sql.SQLException
java.sql.SQLException
void switchReadOnlyConnection(java.lang.Boolean readonly) throws java.sql.SQLException
java.sql.SQLException
HandleErrorResult primaryFail(java.lang.reflect.Method method, java.lang.Object[] args, boolean killCmd) throws java.lang.Throwable
java.lang.Throwable
java.lang.Object invoke(java.lang.reflect.Method method, java.lang.Object[] args, Protocol specificProtocol) throws java.lang.Throwable
java.lang.Throwable
java.lang.Object invoke(java.lang.reflect.Method method, java.lang.Object[] args) throws java.lang.Throwable
java.lang.Throwable
HandleErrorResult handleFailover(java.sql.SQLException qe, java.lang.reflect.Method method, java.lang.Object[] args, Protocol protocol) throws java.lang.Throwable
java.lang.Throwable
void foundActiveMaster(Protocol protocol) throws java.sql.SQLException
java.sql.SQLException
java.util.Set<HostAddress> getBlacklistKeys()
void addToBlacklist(HostAddress hostAddress)
void removeFromBlacklist(HostAddress hostAddress)
void syncConnection(Protocol from, Protocol to) throws java.sql.SQLException
java.sql.SQLException
UrlParser getUrlParser()
void throwFailoverMessage(HostAddress failHostAddress, boolean wasMaster, java.sql.SQLException queryException, boolean reconnected) throws java.sql.SQLException
java.sql.SQLException
boolean isAutoReconnect()
int getRetriesAllDown()
boolean isExplicitClosed()
void reconnect() throws java.sql.SQLException
java.sql.SQLException
boolean isReadOnly()
boolean inTransaction()
int getMajorServerVersion()
boolean isMasterConnection()
boolean isClosed()
boolean versionGreaterOrEqual(int major, int minor, int patch)
boolean sessionStateAware()
boolean noBackslashEscapes()
boolean isValid(int timeout) throws java.sql.SQLException
java.sql.SQLException
void prolog(long maxRows, MariaDbConnection connection, MariaDbStatement statement) throws java.sql.SQLException
java.sql.SQLException
java.lang.String getCatalog() throws java.sql.SQLException
java.sql.SQLException
int getTimeout() throws java.net.SocketException
java.net.SocketException
Protocol getCurrentProtocol()
boolean hasHostFail()
boolean canRetryFailLoop()
SearchFilter getFilterForFailedHost()
boolean isMasterConnected()
boolean setMasterHostFail()
boolean isMasterHostFail()
long getLastQueryNanos()
boolean checkMasterStatus(SearchFilter searchFilter)
void rePrepareOnSlave(ServerPrepareResult oldServerPrepareResult, boolean mustExecuteOnMaster) throws java.sql.SQLException
java.sql.SQLException
void reset() throws java.sql.SQLException
java.sql.SQLException