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