public class MastersSlavesProtocol extends MasterProtocol
activeResult, charset, connected, currentHost, database, dataTypeMappingFlags, explicitClosed, hasWarnings, lock, moreResultsTypeBinary, packetFetcher, prepareStatementCache, proxy, readOnly, serverStatus, serverThreadId, socket, urlParser, writer
Constructor and Description |
---|
MastersSlavesProtocol(UrlParser url,
ReentrantLock lock) |
Modifier and Type | Method and Description |
---|---|
protected static boolean |
foundMaster(MastersSlavesListener listener,
MastersSlavesProtocol protocol,
SearchFilter searchFilter) |
protected static boolean |
foundSecondary(MastersSlavesListener listener,
MastersSlavesProtocol protocol,
SearchFilter searchFilter) |
static MastersSlavesProtocol |
getNewProtocol(FailoverProxy proxy,
UrlParser urlParser)
Get new instance of MastersSlavesProtocol.
|
static void |
loop(MastersSlavesListener listener,
List<HostAddress> addresses,
SearchFilter searchFilter)
loop until found the failed connection.
|
boolean |
mustBeMasterConnection() |
void |
setMustBeMasterConnection(boolean mustBeMasterConnection) |
loop
cancelCurrentQuery, closeExplicit, closeIfActiveResult, closePreparedStatement, executeMultiQueries, executePreparedQuery, executePreparedQueryAfterFailover, executeQueries, executeQuery, executeQuery, forceReleasePrepareStatement, getAutocommit, getMaxRows, getMoreResults, getResult, getTimeout, getTransactionIsolationLevel, hasUnreadData, hexdump, hexdump, inTransaction, ping, prepare, prepareStatementCache, releasePrepareStatement, rollback, setCatalog, setInternalMaxRows, setLocalInfileInputStream, setMaxRows, setTimeout, setTransactionIsolation
checkIfMaster, close, close, connect, connectWithoutProxy, getActiveResult, getCalendar, getDatabase, getDataTypeMappingFlags, getHost, getHostAddress, getLock, getMajorServerVersion, getMinorServerVersion, getOptions, getPassword, getPinGlobalTxToPhysicalConnection, getPort, getPrepareStatementCache, getProxy, getReadonly, getServerData, getServerThreadId, getServerVersion, getUrlParser, getUsername, hasMoreResults, hasWarnings, isClosed, isConnected, isExplicitClosed, isMasterConnection, noBackslashEscapes, readEofPacket, resetMoreResults, setActiveResult, setHasWarnings, setHostAddress, setHostFailedWithoutProxy, setMoreResults, setProxy, setReadonly, shouldReconnectWithoutProxy, skip, versionGreaterOrEqual
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
checkIfMaster, close, connect, connectWithoutProxy, getActiveResult, getCalendar, getDatabase, getDataTypeMappingFlags, getHost, getHostAddress, getLock, getMajorServerVersion, getMinorServerVersion, getOptions, getPassword, getPinGlobalTxToPhysicalConnection, getPort, getProxy, getReadonly, getServerData, getServerThreadId, getServerVersion, getUrlParser, getUsername, hasMoreResults, hasWarnings, isClosed, isConnected, isExplicitClosed, isMasterConnection, noBackslashEscapes, setActiveResult, setHasWarnings, setHostAddress, setHostFailedWithoutProxy, setMoreResults, setProxy, setReadonly, shouldReconnectWithoutProxy, skip, versionGreaterOrEqual
public MastersSlavesProtocol(UrlParser url, ReentrantLock lock)
public static void loop(MastersSlavesListener listener, List<HostAddress> addresses, SearchFilter searchFilter) throws QueryException
listener
- current failoveraddresses
- list of HostAddress to loopsearchFilter
- search parameterQueryException
- if not foundprotected static boolean foundMaster(MastersSlavesListener listener, MastersSlavesProtocol protocol, SearchFilter searchFilter)
protected static boolean foundSecondary(MastersSlavesListener listener, MastersSlavesProtocol protocol, SearchFilter searchFilter) throws QueryException
QueryException
public static MastersSlavesProtocol getNewProtocol(FailoverProxy proxy, UrlParser urlParser)
proxy
- proxyurlParser
- connection string Object.public boolean mustBeMasterConnection()
mustBeMasterConnection
in interface Protocol
mustBeMasterConnection
in class AbstractConnectProtocol
public void setMustBeMasterConnection(boolean mustBeMasterConnection)
Copyright © 2016. All rights reserved.