Package | Description |
---|---|
org.mariadb.jdbc | |
org.mariadb.jdbc.internal.com.read.resultset | |
org.mariadb.jdbc.internal.protocol |
Modifier and Type | Field and Description |
---|---|
protected Results |
MariaDbStatement.results |
Modifier and Type | Method and Description |
---|---|
private void |
UpdatableResultSet.checkIfUpdatable(Results results) |
Constructor and Description |
---|
SelectResultSet(ColumnInformation[] columnInformation,
Results results,
Protocol protocol,
PacketInputStream reader,
boolean callableResult,
boolean eofDeprecated)
Create Streaming resultSet.
|
UpdatableResultSet(ColumnInformation[] columnsInformation,
Results results,
Protocol protocol,
PacketInputStream reader,
boolean callableResult,
boolean eofDeprecated)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
Results |
AbstractConnectProtocol.activeStreamingResult |
private Results |
AbstractMultiSend.results |
private Results |
AsyncMultiRead.results |
Modifier and Type | Method and Description |
---|---|
Results |
Protocol.getActiveStreamingResult() |
Results |
AbstractConnectProtocol.getActiveStreamingResult() |
Modifier and Type | Method and Description |
---|---|
private void |
AbstractQueryProtocol.executeBatch(Results results,
java.util.List<java.lang.String> queries)
Execute list of queries not rewritable.
|
private void |
AbstractQueryProtocol.executeBatchAggregateSemiColon(Results results,
java.util.List<java.lang.String> queries)
Execute list of queries.
|
boolean |
AbstractQueryProtocol.executeBatchClient(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult prepareResult,
java.util.List<ParameterHolder[]> parametersList,
boolean hasLongData)
Execute clientPrepareQuery batch.
|
boolean |
Protocol.executeBatchClient(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult prepareResult,
java.util.List<ParameterHolder[]> parametersList,
boolean hasLongData) |
private void |
AbstractQueryProtocol.executeBatchMulti(Results results,
ClientPrepareResult clientPrepareResult,
java.util.List<ParameterHolder[]> parametersList)
Execute clientPrepareQuery batch.
|
private void |
AbstractQueryProtocol.executeBatchRewrite(Results results,
ClientPrepareResult prepareResult,
java.util.List<ParameterHolder[]> parameterList,
boolean rewriteValues)
Specific execution for batch rewrite that has specific query for memory.
|
boolean |
AbstractQueryProtocol.executeBatchServer(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
Results results,
java.lang.String sql,
java.util.List<ParameterHolder[]> parametersList,
boolean hasLongData)
Execute Prepare if needed, and execute COM_STMT_EXECUTE queries in batch.
|
boolean |
Protocol.executeBatchServer(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
Results results,
java.lang.String sql,
java.util.List<ParameterHolder[]> parameterList,
boolean hasLongData) |
void |
AbstractQueryProtocol.executeBatchStmt(boolean mustExecuteOnMaster,
Results results,
java.util.List<java.lang.String> queries)
Execute batch from Statement.executeBatch().
|
void |
Protocol.executeBatchStmt(boolean mustExecuteOnMaster,
Results results,
java.util.List<java.lang.String> queries) |
private boolean |
AbstractQueryProtocol.executeBulkBatch(Results results,
java.lang.String sql,
ServerPrepareResult serverPrepareResult,
java.util.List<ParameterHolder[]> parametersList)
Execute clientPrepareQuery batch.
|
void |
AbstractQueryProtocol.executePreparedQuery(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
Results results,
ParameterHolder[] parameters)
Execute a query that is already prepared.
|
void |
Protocol.executePreparedQuery(boolean mustExecuteOnMaster,
ServerPrepareResult serverPrepareResult,
Results results,
ParameterHolder[] parameters) |
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters)
Execute a unique clientPrepareQuery.
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters) |
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters,
int queryTimeout)
Execute a unique clientPrepareQuery.
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters,
int timeout) |
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
java.lang.String sql)
Execute query directly to outputStream.
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
java.lang.String sql) |
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
java.lang.String sql,
java.nio.charset.Charset charset) |
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
java.lang.String sql,
java.nio.charset.Charset charset) |
void |
AbstractQueryProtocol.getResult(Results results) |
void |
Protocol.getResult(Results results) |
abstract java.sql.SQLException |
AbstractMultiSend.handleResultException(java.sql.SQLException qex,
Results results,
java.util.List<ParameterHolder[]> parametersList,
java.util.List<java.lang.String> queries,
int currentCounter,
int sendCmdCounter,
int paramCount,
PrepareResult prepareResult) |
private void |
AbstractQueryProtocol.handleStateChange(Buffer buf,
Results results) |
private java.sql.SQLException |
AbstractQueryProtocol.readErrorPacket(Buffer buffer,
Results results)
Read ERR_Packet.
|
private void |
AbstractQueryProtocol.readLocalInfilePacket(Buffer buffer,
Results results)
Read Local_infile Packet.
|
private void |
AbstractQueryProtocol.readOkPacket(Buffer buffer,
Results results)
Read OK_Packet.
|
private void |
AbstractQueryProtocol.readPacket(Results results)
Read server response packet.
|
private void |
AbstractQueryProtocol.readResultSet(Buffer buffer,
Results results)
Read ResultSet Packet.
|
abstract void |
AbstractMultiSend.sendCmd(PacketOutputStream writer,
Results results,
java.util.List<ParameterHolder[]> parametersList,
java.util.List<java.lang.String> queries,
int paramCount,
BulkStatus status,
PrepareResult prepareResult) |
void |
Protocol.setActiveStreamingResult(Results mariaSelectResultSet) |
void |
AbstractConnectProtocol.setActiveStreamingResult(Results activeStreamingResult) |
Constructor and Description |
---|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
Results results,
ClientPrepareResult clientPrepareResult,
java.util.List<ParameterHolder[]> parametersList)
Bulk execute for client-side PreparedStatement.executeBatch (no prepare).
|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
Results results,
java.util.List<java.lang.String> queries)
Bulk execute for statement.executeBatch().
|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
Results results,
ServerPrepareResult serverPrepareResult,
java.util.List<ParameterHolder[]> parametersList,
boolean readPrepareStmtResult,
java.lang.String sql)
Bulk execute for Server PreparedStatement.executeBatch (when no COM_MULTI)
|
AsyncMultiRead(ComStmtPrepare comStmtPrepare,
BulkStatus status,
Protocol protocol,
boolean readPrepareStmtResult,
AbstractMultiSend bulkSend,
int paramCount,
Results results,
java.util.List<ParameterHolder[]> parametersList,
java.util.List<java.lang.String> queries,
PrepareResult prepareResult)
Read results async to avoid local and remote networking stack buffer overflow "lock".
|