public interface Protocol
PrepareResult prepare(String sql) throws QueryException
QueryException
void closePreparedStatement(int statementId) throws QueryException
QueryException
boolean getAutocommit()
boolean noBackslashEscapes()
void connect() throws QueryException
QueryException
UrlParser getUrlParser()
boolean inTransaction()
FailoverProxy getProxy()
void setProxy(FailoverProxy proxy)
Options getOptions()
boolean hasMoreResults()
void close()
void closeExplicit()
boolean isClosed()
void setCatalog(String database) throws QueryException
QueryException
String getServerVersion()
boolean isConnected()
boolean getReadonly()
void setReadonly(boolean readOnly) throws QueryException
QueryException
boolean isMasterConnection()
boolean mustBeMasterConnection()
HostAddress getHostAddress()
void setHostAddress(HostAddress hostAddress)
String getHost()
int getPort()
void rollback()
String getDatabase()
String getUsername()
String getPassword()
boolean ping() throws QueryException
QueryException
ExecutionResult executeQuery(Query query) throws QueryException
QueryException
void executeQuery(Query query, ExecutionResult executionResult, int resultSetScrollType, int fetchSize) throws QueryException
QueryException
void executeMultiQueries(Deque<Query> queries, ExecutionResult executionResult, int fetchSize, boolean isRewritable, int rewriteOffset) throws QueryException
QueryException
void executeQueries(Deque<Query> queries, ExecutionResult executionResult, int resultSetScrollType) throws QueryException
QueryException
void executePreparedQuery(String sql, ExecutionResult executionResult, ParameterHolder[] parameters, PrepareResult prepareResult, MariaDbType[] parameterTypeHeader, int resultSetScrollType) throws QueryException
QueryException
void executePreparedQueryAfterFailover(String sql, ExecutionResult executionResult, ParameterHolder[] parameters, PrepareResult prepareResult, MariaDbType[] parameterTypeHeader, int resultSetScrollType) throws QueryException
QueryException
void getResult(ExecutionResult executionResult, int resultSetScrollType, boolean binaryProtocol) throws QueryException
QueryException
void cancelCurrentQuery() throws QueryException, IOException
QueryException
IOException
void skip() throws SQLException, QueryException
SQLException
QueryException
boolean hasUnreadData()
boolean checkIfMaster() throws QueryException
QueryException
boolean hasWarnings()
int getDataTypeMappingFlags()
void setInternalMaxRows(int max)
int getMaxRows()
void setMaxRows(int max) throws QueryException
QueryException
int getMajorServerVersion()
int getMinorServerVersion()
boolean versionGreaterOrEqual(int major, int minor, int patch)
void setLocalInfileInputStream(InputStream inputStream)
int getTimeout() throws SocketException
SocketException
void setTimeout(int timeout) throws SocketException
SocketException
boolean getPinGlobalTxToPhysicalConnection()
long getServerThreadId()
void setTransactionIsolation(int level) throws QueryException
QueryException
int getTransactionIsolationLevel()
boolean isExplicitClosed()
void closeIfActiveResult() throws SQLException
SQLException
void connectWithoutProxy() throws QueryException
QueryException
boolean shouldReconnectWithoutProxy()
void setHostFailedWithoutProxy()
void releasePrepareStatement(String sql, int statementId) throws QueryException
QueryException
void forceReleasePrepareStatement(int statementId) throws QueryException
QueryException
PrepareStatementCache prepareStatementCache()
Calendar getCalendar()
void setHasWarnings(boolean hasWarnings)
MariaSelectResultSet getActiveResult()
void setActiveResult(MariaSelectResultSet mariaSelectResultSet)
ReentrantLock getLock()
void getMoreResults(ExecutionResult executionResult) throws QueryException
QueryException
void setMoreResults(boolean moreResults, boolean moreResultsTypeBinary)
Copyright © 2016. All rights reserved.