public interface Listener
FailoverProxy getProxy()
void setProxy(FailoverProxy proxy)
void initializeConnection() throws SQLException
SQLException
void preExecute() throws SQLException
SQLException
void preClose() throws SQLException
SQLException
void reconnectFailedConnection(SearchFilter filter) throws SQLException
SQLException
void switchReadOnlyConnection(Boolean readonly) throws SQLException
SQLException
HandleErrorResult primaryFail(Method method, Object[] args, boolean killCmd) throws Throwable
Throwable
Object invoke(Method method, Object[] args, Protocol specificProtocol) throws Throwable
Throwable
HandleErrorResult handleFailover(SQLException qe, Method method, Object[] args, Protocol protocol) throws Throwable
Throwable
void foundActiveMaster(Protocol protocol) throws SQLException
SQLException
Set<HostAddress> getBlacklistKeys()
void addToBlacklist(HostAddress hostAddress)
void removeFromBlacklist(HostAddress hostAddress)
void syncConnection(Protocol from, Protocol to) throws SQLException
SQLException
UrlParser getUrlParser()
void throwFailoverMessage(HostAddress failHostAddress, boolean wasMaster, SQLException queryException, boolean reconnected) throws SQLException
SQLException
boolean isAutoReconnect()
int getRetriesAllDown()
boolean isExplicitClosed()
void reconnect() throws SQLException
SQLException
boolean isReadOnly()
boolean isClosed()
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 SQLException
SQLException
Copyright © 2017. All rights reserved.