org.mariadb.jdbc.internal.failover

Interface Listener

All Known Implementing Classes:

AbstractMastersListener, AbstractMastersReplicasListener, AuroraListener, MastersFailoverListener, MastersReplicasListener

public interface Listener

Method Summary

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 wasClosed)
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	isServerMariaDb()
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, boolean wasClosed)
void	prolog(long maxRows, MariaDbConnection connection, MariaDbStatement statement)
void	reconnect()
void	reconnectFailedConnection(SearchFilter filter)
void	removeFromBlacklist(HostAddress hostAddress)
void	rePrepareOnReplica(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)

Method Detail

getProxy

FailoverProxy getProxy()

setProxy

void setProxy(FailoverProxy proxy)

initializeConnection

void initializeConnection()
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

preExecute

void preExecute()
         throws java.sql.SQLException

Throws:

java.sql.SQLException

preClose

void preClose()

preAbort

void preAbort()

getServerThreadId

long getServerThreadId()

reconnectFailedConnection

void reconnectFailedConnection(SearchFilter filter)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

switchReadOnlyConnection

void switchReadOnlyConnection(java.lang.Boolean readonly)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

primaryFail

HandleErrorResult primaryFail(java.lang.reflect.Method method,
                              java.lang.Object[] args,
                              boolean killCmd,
                              boolean wasClosed)
                       throws java.sql.SQLException

Throws:

java.sql.SQLException

invoke

java.lang.Object invoke(java.lang.reflect.Method method,
                        java.lang.Object[] args,
                        Protocol specificProtocol)
                 throws java.lang.Throwable

Throws:

java.lang.Throwable

invoke

java.lang.Object invoke(java.lang.reflect.Method method,
                        java.lang.Object[] args)
                 throws java.lang.Throwable

Throws:

java.lang.Throwable

handleFailover

HandleErrorResult handleFailover(java.sql.SQLException qe,
                                 java.lang.reflect.Method method,
                                 java.lang.Object[] args,
                                 Protocol protocol,
                                 boolean wasClosed)
                          throws java.lang.Throwable

Throws:

java.lang.Throwable

foundActiveMaster

void foundActiveMaster(Protocol protocol)
                throws java.sql.SQLException

Throws:

java.sql.SQLException

getBlacklistKeys

java.util.Set<HostAddress> getBlacklistKeys()

addToBlacklist

void addToBlacklist(HostAddress hostAddress)

removeFromBlacklist

void removeFromBlacklist(HostAddress hostAddress)

syncConnection

void syncConnection(Protocol from,
                    Protocol to)
             throws java.sql.SQLException

Throws:

java.sql.SQLException

getUrlParser

UrlParser getUrlParser()

throwFailoverMessage

void throwFailoverMessage(HostAddress failHostAddress,
                          boolean wasMaster,
                          java.sql.SQLException queryException,
                          boolean reconnected)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

isAutoReconnect

boolean isAutoReconnect()

getRetriesAllDown

int getRetriesAllDown()

isExplicitClosed

boolean isExplicitClosed()

reconnect

void reconnect()
        throws java.sql.SQLException

Throws:

java.sql.SQLException

isReadOnly

boolean isReadOnly()

inTransaction

boolean inTransaction()

getMajorServerVersion

int getMajorServerVersion()

isMasterConnection

boolean isMasterConnection()

isClosed

boolean isClosed()

versionGreaterOrEqual

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

isServerMariaDb

boolean isServerMariaDb()

sessionStateAware

boolean sessionStateAware()

noBackslashEscapes

boolean noBackslashEscapes()

isValid

boolean isValid(int timeout)
         throws java.sql.SQLException

Throws:

java.sql.SQLException

prolog

void prolog(long maxRows,
            MariaDbConnection connection,
            MariaDbStatement statement)
     throws java.sql.SQLException

Throws:

java.sql.SQLException

getCatalog

java.lang.String getCatalog()
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

getTimeout

int getTimeout()
        throws java.net.SocketException

Throws:

java.net.SocketException

getCurrentProtocol

Protocol getCurrentProtocol()

hasHostFail

boolean hasHostFail()

canRetryFailLoop

boolean canRetryFailLoop()

getFilterForFailedHost

SearchFilter getFilterForFailedHost()

isMasterConnected

boolean isMasterConnected()

setMasterHostFail

boolean setMasterHostFail()

isMasterHostFail

boolean isMasterHostFail()

getLastQueryNanos

long getLastQueryNanos()

checkMasterStatus

boolean checkMasterStatus(SearchFilter searchFilter)

rePrepareOnReplica

void rePrepareOnReplica(ServerPrepareResult oldServerPrepareResult,
                        boolean mustExecuteOnMaster)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

reset

void reset()
    throws java.sql.SQLException

Throws:

java.sql.SQLException