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