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) |
Execute clientPrepareQuery batch.
|
boolean |
Protocol.executeBatchClient(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult prepareResult,
java.util.List<ParameterHolder[]> parametersList) |
|
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) |
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) |
|
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,
java.lang.String sql) |
Execute query directly to outputStream.
|
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
java.lang.String sql,
java.nio.charset.Charset charset) |
|
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters) |
Execute a unique clientPrepareQuery.
|
void |
AbstractQueryProtocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters,
int queryTimeout) |
Execute a unique clientPrepareQuery.
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
java.lang.String sql) |
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
java.lang.String sql,
java.nio.charset.Charset charset) |
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters) |
|
void |
Protocol.executeQuery(boolean mustExecuteOnMaster,
Results results,
ClientPrepareResult clientPrepareResult,
ParameterHolder[] parameters,
int timeout) |
|
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 |
AbstractConnectProtocol.setActiveStreamingResult(Results activeStreamingResult) |
|
void |
Protocol.setActiveStreamingResult(Results mariaSelectResultSet) |
|