org.mariadb.jdbc.internal.protocol

Interface Protocol

All Known Implementing Classes:

AbstractConnectProtocol, AbstractQueryProtocol, AuroraProtocol, MasterProtocol, MastersSlavesProtocol

public interface Protocol

Method Summary

Modifier and Type	Method and Description
void	cancelCurrentQuery()
boolean	checkIfMaster()
void	close()
void	closeExplicit()
void	closeIfActiveResult()
void	connect()
void	connectWithoutProxy()
AbstractQueryResult	executePreparedQuery(PrepareResult prepareResult, String sql, ParameterHolder[] parameters, MariaDbType[] parameterTypeHeader, boolean isStreaming)
AbstractQueryResult	executePreparedQueryAfterFailover(PrepareResult prepareResult, String sql, ParameterHolder[] parameters, MariaDbType[] parameterTypeHeader, boolean isStreaming)
AbstractQueryResult	executeQueries(List<String> queryParts, List<ParameterHolder[]> parameterList, boolean streaming, boolean isRewritable)
AbstractQueryResult	executeQuery(List<String> queries, boolean streaming, boolean isRewritable, int rewriteOffset)
AbstractQueryResult	executeQuery(String query, boolean streaming)
void	forceReleasePrepareStatement(int statementId)
boolean	getAutocommit()
Calendar	getCalendar()
String	getDatabase()
int	getDataTypeMappingFlags()
String	getHost()
HostAddress	getHostAddress()
int	getMajorServerVersion()
int	getMaxRows()
int	getMinorServerVersion()
AbstractQueryResult	getMoreResults(boolean streaming)
Options	getOptions()
String	getPassword()
boolean	getPinGlobalTxToPhysicalConnection()
int	getPort()
FailoverProxy	getProxy()
boolean	getReadonly()
AbstractQueryResult	getResult(boolean streaming, boolean binaryProtocol)
String	getServerData(String code)
long	getServerThreadId()
String	getServerVersion()
int	getTimeout()
int	getTransactionIsolationLevel()
UrlParser	getUrlParser()
String	getUsername()
boolean	hasMoreResults()
boolean	hasWarnings()
boolean	inTransaction()
boolean	isClosed()
boolean	isConnected()
boolean	isExplicitClosed()
boolean	isMasterConnection()
boolean	mustBeMasterConnection()
boolean	noBackslashEscapes()
boolean	ping()
PrepareResult	prepare(String sql, boolean forceNew)
PrepareStatementCache	prepareStatementCache()
void	prolog(boolean isStreaming, int maxRows, boolean hasProxy, MariaDbConnection connection, Statement statement)
void	prologProxy(PrepareResult prepareResult, boolean isStreaming, int maxRows, boolean hasProxy, MariaDbConnection connection, Statement statement)
void	releasePrepareStatement(PrepareResult prepareResult, String sql)
void	rollback()
void	setCatalog(String database)
void	setHostAddress(HostAddress hostAddress)
void	setHostFailedWithoutProxy()
void	setInternalMaxRows(int max)
void	setLocalInfileInputStream(InputStream inputStream)
void	setMaxRows(int max)
void	setProxy(FailoverProxy proxy)
void	setReadonly(boolean readOnly)
void	setTimeout(int timeout)
void	setTransactionIsolation(int level)
boolean	shouldReconnectWithoutProxy()
boolean	versionGreaterOrEqual(int major, int minor, int patch)

Method Detail

prepare

PrepareResult prepare(String sql,
                      boolean forceNew)
               throws QueryException

Throws:

QueryException

getAutocommit

boolean getAutocommit()

noBackslashEscapes

boolean noBackslashEscapes()

connect

void connect()
      throws QueryException

Throws:

QueryException

getUrlParser

UrlParser getUrlParser()

inTransaction

boolean inTransaction()

getProxy

FailoverProxy getProxy()

setProxy

void setProxy(FailoverProxy proxy)

getOptions

Options getOptions()

hasMoreResults

boolean hasMoreResults()

close

void close()

closeExplicit

void closeExplicit()

isClosed

boolean isClosed()

setCatalog

void setCatalog(String database)
         throws QueryException

Throws:

QueryException

getServerVersion

String getServerVersion()

isConnected

boolean isConnected()

getReadonly

boolean getReadonly()

setReadonly

void setReadonly(boolean readOnly)
          throws QueryException

Throws:

QueryException

isMasterConnection

boolean isMasterConnection()

mustBeMasterConnection

boolean mustBeMasterConnection()

getHostAddress

HostAddress getHostAddress()

setHostAddress

void setHostAddress(HostAddress hostAddress)

getHost

String getHost()

getPort

int getPort()

rollback

void rollback()

getDatabase

String getDatabase()

getUsername

String getUsername()

getPassword

String getPassword()

ping

boolean ping()
      throws QueryException

Throws:

QueryException

executeQuery

AbstractQueryResult executeQuery(String query,
                                 boolean streaming)
                          throws QueryException

Throws:

QueryException

executeQuery

AbstractQueryResult executeQuery(List<String> queries,
                                 boolean streaming,
                                 boolean isRewritable,
                                 int rewriteOffset)
                          throws QueryException

Throws:

QueryException

executeQueries

AbstractQueryResult executeQueries(List<String> queryParts,
                                   List<ParameterHolder[]> parameterList,
                                   boolean streaming,
                                   boolean isRewritable)
                            throws QueryException

Throws:

QueryException

getResult

AbstractQueryResult getResult(boolean streaming,
                              boolean binaryProtocol)
                       throws QueryException

Throws:

QueryException

cancelCurrentQuery

void cancelCurrentQuery()
                 throws QueryException,
                        IOException

Throws:

QueryException

IOException

getMoreResults

AbstractQueryResult getMoreResults(boolean streaming)
                            throws QueryException

Throws:

QueryException

checkIfMaster

boolean checkIfMaster()
               throws QueryException

Throws:

QueryException

hasWarnings

boolean hasWarnings()

getDataTypeMappingFlags

int getDataTypeMappingFlags()

setInternalMaxRows

void setInternalMaxRows(int max)

getMaxRows

int getMaxRows()

setMaxRows

void setMaxRows(int max)
         throws QueryException

Throws:

QueryException

getMajorServerVersion

int getMajorServerVersion()

getMinorServerVersion

int getMinorServerVersion()

versionGreaterOrEqual

boolean versionGreaterOrEqual(int major,
                              int minor,
                              int patch)

setLocalInfileInputStream

void setLocalInfileInputStream(InputStream inputStream)

getTimeout

int getTimeout()
        throws SocketException

Throws:

SocketException

setTimeout

void setTimeout(int timeout)
         throws SocketException

Throws:

SocketException

getPinGlobalTxToPhysicalConnection

boolean getPinGlobalTxToPhysicalConnection()

getServerThreadId

long getServerThreadId()

setTransactionIsolation

void setTransactionIsolation(int level)
                      throws QueryException

Throws:

QueryException

getTransactionIsolationLevel

int getTransactionIsolationLevel()

isExplicitClosed

boolean isExplicitClosed()

closeIfActiveResult

void closeIfActiveResult()

connectWithoutProxy

void connectWithoutProxy()
                  throws QueryException

Throws:

QueryException

shouldReconnectWithoutProxy

boolean shouldReconnectWithoutProxy()

setHostFailedWithoutProxy

void setHostFailedWithoutProxy()

executePreparedQuery

AbstractQueryResult executePreparedQuery(PrepareResult prepareResult,
                                         String sql,
                                         ParameterHolder[] parameters,
                                         MariaDbType[] parameterTypeHeader,
                                         boolean isStreaming)
                                  throws QueryException

Throws:

QueryException

executePreparedQueryAfterFailover

AbstractQueryResult executePreparedQueryAfterFailover(PrepareResult prepareResult,
                                                      String sql,
                                                      ParameterHolder[] parameters,
                                                      MariaDbType[] parameterTypeHeader,
                                                      boolean isStreaming)
                                               throws QueryException

Throws:

QueryException

releasePrepareStatement

void releasePrepareStatement(PrepareResult prepareResult,
                             String sql)
                      throws QueryException

Throws:

QueryException

forceReleasePrepareStatement

void forceReleasePrepareStatement(int statementId)
                           throws QueryException

Throws:

QueryException

prepareStatementCache

PrepareStatementCache prepareStatementCache()

getServerData

String getServerData(String code)

getCalendar

Calendar getCalendar()

prolog

void prolog(boolean isStreaming,
            int maxRows,
            boolean hasProxy,
            MariaDbConnection connection,
            Statement statement)
     throws SQLException

Throws:

SQLException

prologProxy

void prologProxy(PrepareResult prepareResult,
                 boolean isStreaming,
                 int maxRows,
                 boolean hasProxy,
                 MariaDbConnection connection,
                 Statement statement)
          throws SQLException

Throws:

SQLException