Interface Protocol
- All Known Implementing Classes:
AbstractConnectProtocol
,AbstractQueryProtocol
,AuroraProtocol
,MasterProtocol
,MastersSlavesProtocol
public interface Protocol
-
Method Summary
Modifier and TypeMethodDescriptionvoid
abort()
addPrepareInCache
(String key, ServerPrepareResult serverPrepareResult) void
void
changeSocketSoTimeout
(int setSoTimeout) void
changeSocketTcpNoDelay
(boolean setTcpNoDelay) boolean
void
close()
void
void
connect()
void
boolean
executeBatchClient
(boolean mustExecuteOnMaster, Results results, ClientPrepareResult prepareResult, List<ParameterHolder[]> parametersList, boolean hasLongData) boolean
executeBatchServer
(boolean mustExecuteOnMaster, ServerPrepareResult serverPrepareResult, Results results, String sql, List<ParameterHolder[]> parameterList, boolean hasLongData) void
executeBatchStmt
(boolean mustExecuteOnMaster, Results results, List<String> queries) void
executePreparedQuery
(boolean mustExecuteOnMaster, ServerPrepareResult serverPrepareResult, Results results, ParameterHolder[] parameters) void
executeQuery
(boolean mustExecuteOnMaster, Results results, String sql) void
executeQuery
(boolean mustExecuteOnMaster, Results results, String sql, Charset charset) void
executeQuery
(boolean mustExecuteOnMaster, Results results, ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters) void
executeQuery
(boolean mustExecuteOnMaster, Results results, ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters, int timeout) void
executeQuery
(String sql) boolean
forceReleasePrepareStatement
(int statementId) void
boolean
int
getHost()
getLock()
int
long
int
boolean
int
getPort()
getProxy()
boolean
void
long
int
int
handleIoException
(Exception initialException) boolean
boolean
void
boolean
boolean
isClosed()
boolean
boolean
boolean
boolean
boolean
boolean
boolean
isValid
(int timeout) boolean
boolean
boolean
ping()
void
prolog
(long maxRows, boolean hasProxy, MariaDbConnection connection, MariaDbStatement statement) void
prologProxy
(ServerPrepareResult serverPrepareResult, long maxRows, boolean hasProxy, MariaDbConnection connection, MariaDbStatement statement) void
void
releasePrepareStatement
(ServerPrepareResult serverPrepareResult) void
void
void
reset()
void
void
resetStateAfterFailover
(long maxRows, int transactionIsolationLevel, String database, boolean autocommit) void
rollback()
boolean
void
setActiveFutureTask
(FutureTask activeFutureTask) void
setActiveStreamingResult
(Results mariaSelectResultSet) void
setCatalog
(String database) void
setHasWarnings
(boolean hasWarnings) void
setHostAddress
(HostAddress hostAddress) void
void
setLocalInfileInputStream
(InputStream inputStream) void
setMaxRows
(long max) void
setProxy
(FailoverProxy proxy) void
setReadonly
(boolean readOnly) void
setServerStatus
(short serverStatus) void
setTimeout
(int timeout) void
setTransactionIsolation
(int level) boolean
void
skip()
void
void
boolean
versionGreaterOrEqual
(int major, int minor, int patch)
-
Method Details
-
prepare
- Throws:
SQLException
-
getAutocommit
- Throws:
SQLException
-
noBackslashEscapes
boolean noBackslashEscapes() -
connect
- Throws:
SQLException
-
getUrlParser
UrlParser getUrlParser() -
inTransaction
boolean inTransaction() -
getProxy
FailoverProxy getProxy() -
setProxy
-
getOptions
Options getOptions() -
hasMoreResults
boolean hasMoreResults() -
close
void close() -
abort
void abort() -
reset
- Throws:
SQLException
-
closeExplicit
void closeExplicit() -
isClosed
boolean isClosed() -
resetDatabase
- Throws:
SQLException
-
getCatalog
- Throws:
SQLException
-
setCatalog
- Throws:
SQLException
-
getServerVersion
String getServerVersion() -
isConnected
boolean isConnected() -
getReadonly
- Throws:
SQLException
-
setReadonly
- Throws:
SQLException
-
isMasterConnection
boolean isMasterConnection() -
mustBeMasterConnection
boolean mustBeMasterConnection() -
getHostAddress
HostAddress getHostAddress() -
setHostAddress
-
getHost
String getHost() -
getPort
int getPort() -
rollback
- Throws:
SQLException
-
getDatabase
String getDatabase() -
getUsername
String getUsername() -
ping
- Throws:
SQLException
-
isValid
- Throws:
SQLException
-
executeQuery
- Throws:
SQLException
-
executeQuery
- Throws:
SQLException
-
executeQuery
void executeQuery(boolean mustExecuteOnMaster, Results results, String sql, Charset charset) throws SQLException - Throws:
SQLException
-
executeQuery
void executeQuery(boolean mustExecuteOnMaster, Results results, ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters) throws SQLException - Throws:
SQLException
-
executeQuery
void executeQuery(boolean mustExecuteOnMaster, Results results, ClientPrepareResult clientPrepareResult, ParameterHolder[] parameters, int timeout) throws SQLException - Throws:
SQLException
-
executeBatchClient
boolean executeBatchClient(boolean mustExecuteOnMaster, Results results, ClientPrepareResult prepareResult, List<ParameterHolder[]> parametersList, boolean hasLongData) throws SQLException - Throws:
SQLException
-
executeBatchStmt
void executeBatchStmt(boolean mustExecuteOnMaster, Results results, List<String> queries) throws SQLException - Throws:
SQLException
-
executePreparedQuery
void executePreparedQuery(boolean mustExecuteOnMaster, ServerPrepareResult serverPrepareResult, Results results, ParameterHolder[] parameters) throws SQLException - Throws:
SQLException
-
executeBatchServer
boolean executeBatchServer(boolean mustExecuteOnMaster, ServerPrepareResult serverPrepareResult, Results results, String sql, List<ParameterHolder[]> parameterList, boolean hasLongData) throws SQLException - Throws:
SQLException
-
getResult
- Throws:
SQLException
-
cancelCurrentQuery
- Throws:
SQLException
-
interrupt
void interrupt() -
skip
- Throws:
SQLException
-
checkIfMaster
- Throws:
SQLException
-
hasWarnings
boolean hasWarnings() -
getMaxRows
long getMaxRows() -
setMaxRows
- Throws:
SQLException
-
getMajorServerVersion
int getMajorServerVersion() -
getMinorServerVersion
int getMinorServerVersion() -
versionGreaterOrEqual
boolean versionGreaterOrEqual(int major, int minor, int patch) -
setLocalInfileInputStream
-
getTimeout
int getTimeout() -
setTimeout
- Throws:
SocketException
-
getPinGlobalTxToPhysicalConnection
boolean getPinGlobalTxToPhysicalConnection() -
getServerThreadId
long getServerThreadId() -
getSocket
Socket getSocket() -
setTransactionIsolation
- Throws:
SQLException
-
getTransactionIsolationLevel
int getTransactionIsolationLevel() -
isExplicitClosed
boolean isExplicitClosed() -
connectWithoutProxy
- Throws:
SQLException
-
shouldReconnectWithoutProxy
boolean shouldReconnectWithoutProxy() -
setHostFailedWithoutProxy
void setHostFailedWithoutProxy() -
releasePrepareStatement
- Throws:
SQLException
-
forceReleasePrepareStatement
- Throws:
SQLException
-
forceReleaseWaitingPrepareStatement
- Throws:
SQLException
-
prepareStatementCache
ServerPrepareStatementCache prepareStatementCache() -
getTimeZone
TimeZone getTimeZone() -
prolog
void prolog(long maxRows, boolean hasProxy, MariaDbConnection connection, MariaDbStatement statement) throws SQLException - Throws:
SQLException
-
prologProxy
void prologProxy(ServerPrepareResult serverPrepareResult, long maxRows, boolean hasProxy, MariaDbConnection connection, MariaDbStatement statement) throws SQLException - Throws:
SQLException
-
getActiveStreamingResult
Results getActiveStreamingResult() -
setActiveStreamingResult
-
getLock
ReentrantLock getLock() -
setServerStatus
void setServerStatus(short serverStatus) -
removeHasMoreResults
void removeHasMoreResults() -
setHasWarnings
void setHasWarnings(boolean hasWarnings) -
addPrepareInCache
-
readEofPacket
- Throws:
SQLException
IOException
-
skipEofPacket
- Throws:
SQLException
IOException
-
changeSocketTcpNoDelay
void changeSocketTcpNoDelay(boolean setTcpNoDelay) -
changeSocketSoTimeout
- Throws:
SocketException
-
removeActiveStreamingResult
void removeActiveStreamingResult() -
resetStateAfterFailover
void resetStateAfterFailover(long maxRows, int transactionIsolationLevel, String database, boolean autocommit) throws SQLException - Throws:
SQLException
-
setActiveFutureTask
-
isServerMariaDb
boolean isServerMariaDb() -
handleIoException
-
getReader
PacketInputStream getReader() -
getWriter
PacketOutputStream getWriter() -
isEofDeprecated
boolean isEofDeprecated() -
getAutoIncrementIncrement
- Throws:
SQLException
-
sessionStateAware
boolean sessionStateAware() -
getTraces
String getTraces() -
isInterrupted
boolean isInterrupted() -
stopIfInterrupted
- Throws:
SQLTimeoutException
-