org.mariadb.jdbc.internal.protocol

Interface Protocol

All Known Implementing Classes:

AbstractConnectProtocol, AbstractQueryProtocol, AuroraProtocol, MasterProtocol, MastersReplicasProtocol

public interface Protocol

Method Summary

Modifier and Type	Method and 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, 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()
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