Package | Description |
---|---|
org.mariadb.jdbc | |
org.mariadb.jdbc.internal.protocol | |
org.mariadb.jdbc.internal.queryresults |
Modifier and Type | Field and Description |
---|---|
protected ExecutionResult |
MariaDbStatement.executionResult |
Modifier and Type | Method and Description |
---|---|
protected ExecutionResult |
MariaDbServerPreparedStatement.getExecutionResult() |
Modifier and Type | Method and Description |
---|---|
ExecutionResult |
Protocol.getResult(ExecutionResult executionResult,
int resultSetScrollType,
boolean binaryProtocol,
boolean loadAllResults) |
ExecutionResult |
AbstractQueryProtocol.getResult(ExecutionResult executionResult,
int resultSetScrollType,
boolean binaryProtocol,
boolean loadAllResults) |
Modifier and Type | Method and Description |
---|---|
void |
Protocol.executeBatch(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
List<String> queries,
int resultSetScrollType) |
void |
AbstractQueryProtocol.executeBatch(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
List<String> queries,
int resultSetScrollType)
Execute list of queries not rewritable.
|
void |
Protocol.executeBatchMulti(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
ClientPrepareResult clientPrepareResult,
List<ParameterHolder[]> parameterList,
int resultSetScrollType) |
void |
AbstractQueryProtocol.executeBatchMulti(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
ClientPrepareResult clientPrepareResult,
List<ParameterHolder[]> parametersList,
int resultSetScrollType)
Execute clientPrepareQuery batch.
|
void |
Protocol.executeBatchMultiple(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
List<String> queries,
int resultSetScrollType) |
void |
AbstractQueryProtocol.executeBatchMultiple(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
List<String> queries,
int resultSetScrollType)
Execute list of queries.
|
void |
Protocol.executeBatchRewrite(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
ClientPrepareResult prepareResult,
List<ParameterHolder[]> parameterList,
int resultSetScrollType,
boolean rewriteValues) |
void |
AbstractQueryProtocol.executeBatchRewrite(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
ClientPrepareResult prepareResult,
List<ParameterHolder[]> parameterList,
int resultSetScrollType,
boolean rewriteValues)
Specific execution for batch rewrite that has specific query for memory.
|
void |
Protocol.executePreparedQuery(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
ExecutionResult executionResult,
ParameterHolder[] parameters,
int resultSetScrollType) |
void |
AbstractQueryProtocol.executePreparedQuery(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
ExecutionResult executionResult,
ParameterHolder[] parameters,
int resultSetScrollType)
Execute a query that is already prepared.
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters,
int resultSetScrollType) |
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters,
int resultSetScrollType)
Execute a unique clientPrepareQuery.
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
String sql,
int resultSetScrollType) |
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
ExecutionResult executionResult,
String sql,
int resultSetScrollType)
Execute query directly to outputStream.
|
void |
Protocol.getMoreResults(ExecutionResult executionResult) |
abstract void |
AbstractConnectProtocol.getMoreResults(ExecutionResult executionResult) |
void |
AbstractQueryProtocol.getMoreResults(ExecutionResult executionResult) |
ExecutionResult |
Protocol.getResult(ExecutionResult executionResult,
int resultSetScrollType,
boolean binaryProtocol,
boolean loadAllResults) |
ExecutionResult |
AbstractQueryProtocol.getResult(ExecutionResult executionResult,
int resultSetScrollType,
boolean binaryProtocol,
boolean loadAllResults) |
abstract QueryException |
AbstractMultiSend.handleResultException(QueryException qex,
ExecutionResult executionResult,
List<ParameterHolder[]> parametersList,
List<String> queries,
int currentCounter,
int sendCmdCounter,
int paramCount,
PrepareResult prepareResult) |
ServerPrepareResult |
Protocol.prepareAndExecute(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
ExecutionResult executionResult,
String sql,
ParameterHolder[] parameters,
int resultSetScrollType) |
ServerPrepareResult |
AbstractQueryProtocol.prepareAndExecute(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
ExecutionResult executionResult,
String sql,
ParameterHolder[] parameters,
int resultSetScrollType)
Execute Prepare if needed, and execute COM_STMT_EXECUTE queries in batch.
|
ServerPrepareResult |
Protocol.prepareAndExecutes(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
ExecutionResult executionResult,
String sql,
List<ParameterHolder[]> parameterList,
int resultSetScrollType) |
ServerPrepareResult |
AbstractQueryProtocol.prepareAndExecutes(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
ExecutionResult executionResult,
String sql,
List<ParameterHolder[]> parametersList,
int resultSetScrollType)
Execute Prepare if needed, and execute COM_STMT_EXECUTE queries in batch.
|
void |
Protocol.prolog(ExecutionResult executionResult,
int maxRows,
boolean hasProxy,
MariaDbConnection connection,
MariaDbStatement statement) |
void |
AbstractQueryProtocol.prolog(ExecutionResult executionResult,
int maxRows,
boolean hasProxy,
MariaDbConnection connection,
MariaDbStatement statement)
Preparation before command.
|
void |
Protocol.prologProxy(ServerPrepareResult serverPrepareResult,
ExecutionResult executionResult,
int maxRows,
boolean hasProxy,
MariaDbConnection connection,
MariaDbStatement statement) |
void |
AbstractQueryProtocol.prologProxy(ServerPrepareResult serverPrepareResult,
ExecutionResult executionResult,
int maxRows,
boolean hasProxy,
MariaDbConnection connection,
MariaDbStatement statement) |
abstract void |
AbstractMultiSend.sendCmd(PacketOutputStream writer,
ExecutionResult executionResult,
List<ParameterHolder[]> parametersList,
List<String> queries,
int paramCount,
BulkStatus status,
PrepareResult prepareResult) |
Constructor and Description |
---|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
ExecutionResult executionResult,
ClientPrepareResult clientPrepareResult,
List<ParameterHolder[]> parametersList,
int resultSetScrollType)
Bulk execute for client-sier PreparedStatement.executeBatch (no prepare).
|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
ExecutionResult executionResult,
List<String> queries,
int resultSetScrollType)
Bulk execute for statement.executeBatch().
|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
ExecutionResult executionResult,
ServerPrepareResult serverPrepareResult,
List<ParameterHolder[]> parametersList,
int resultSetScrollType,
boolean readPrepareStmtResult,
String sql)
Bulk execute for Server PreparedStatement.executeBatch (when no COM_MULTI)
|
AsyncMultiRead(ComStmtPrepare comStmtPrepare,
int nbResult,
int sendCmdCounter,
Protocol protocol,
boolean readPrepareStmtResult,
AbstractMultiSend bulkSend,
int paramCount,
int resultSetScrollType,
boolean binaryProtocol,
ExecutionResult executionResult,
List<ParameterHolder[]> parametersList,
List<String> queries,
PrepareResult prepareResult)
Read results async to avoid local and remote networking stack buffer overflow "lock".
|
Modifier and Type | Interface and Description |
---|---|
interface |
MultiExecutionResult |
Modifier and Type | Class and Description |
---|---|
class |
MultiFixedIntExecutionResult |
class |
MultiVariableIntExecutionResult |
class |
SingleExecutionResult |
Modifier and Type | Field and Description |
---|---|
Deque<ExecutionResult> |
MultiVariableIntExecutionResult.cachedExecutionResults |
Deque<ExecutionResult> |
MultiFixedIntExecutionResult.cachedExecutionResults |
Modifier and Type | Method and Description |
---|---|
Deque<ExecutionResult> |
SingleExecutionResult.getCachedExecutionResults() |
Deque<ExecutionResult> |
MultiVariableIntExecutionResult.getCachedExecutionResults() |
Deque<ExecutionResult> |
MultiFixedIntExecutionResult.getCachedExecutionResults() |
Deque<ExecutionResult> |
ExecutionResult.getCachedExecutionResults() |
Modifier and Type | Method and Description |
---|---|
void |
MultiVariableIntExecutionResult.addResult(ExecutionResult executionResult) |
void |
MultiFixedIntExecutionResult.addResult(ExecutionResult executionResult) |
Copyright © 2017. All rights reserved.