public abstract class AbstractMultiSend
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private boolean |
binaryProtocol |
private java.util.List<ParameterHolder[]> |
parametersList |
protected ColumnType[] |
parameterTypeHeader |
private PrepareResult |
prepareResult |
private Protocol |
protocol |
private java.util.List<java.lang.String> |
queries |
private java.util.concurrent.ThreadPoolExecutor |
readScheduler |
private Results |
results |
private java.lang.String |
sql |
protected int |
statementId |
private PacketOutputStream |
writer |
Constructor and Description |
---|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
Results results,
ClientPrepareResult clientPrepareResult,
java.util.List<ParameterHolder[]> parametersList,
java.util.concurrent.ThreadPoolExecutor readScheduler)
Bulk execute for client-side PreparedStatement.executeBatch (no prepare).
|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
Results results,
java.util.List<java.lang.String> queries,
java.util.concurrent.ThreadPoolExecutor readScheduler)
Bulk execute for statement.executeBatch().
|
AbstractMultiSend(Protocol protocol,
PacketOutputStream writer,
Results results,
ServerPrepareResult serverPrepareResult,
java.util.List<ParameterHolder[]> parametersList,
java.lang.String sql,
java.util.concurrent.ThreadPoolExecutor readScheduler)
Bulk execute for Server PreparedStatement.executeBatch (when no COM_MULTI)
|
Modifier and Type | Method and Description |
---|---|
void |
executeBatch()
Execute Bulk execution (send packets by batch of useBatchMultiSendNumber or when max packet is
reached) before reading results.
|
private void |
executeBatchStandard(int estimatedParameterCount)
Execute Bulk execution (send packets by batch of useBatchMultiSendNumber or when max packet is
reached) before reading results.
|
abstract int |
getParamCount() |
PrepareResult |
getPrepareResult() |
abstract int |
getTotalExecutionNumber() |
abstract java.sql.SQLException |
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) |
abstract void |
sendCmd(PacketOutputStream writer,
Results results,
java.util.List<ParameterHolder[]> parametersList,
java.util.List<java.lang.String> queries,
int paramCount,
BulkStatus status,
PrepareResult prepareResult) |
private final Protocol protocol
private final PacketOutputStream writer
private final Results results
private final boolean binaryProtocol
protected int statementId
protected ColumnType[] parameterTypeHeader
private java.util.List<ParameterHolder[]> parametersList
private PrepareResult prepareResult
private java.util.List<java.lang.String> queries
private java.lang.String sql
private java.util.concurrent.ThreadPoolExecutor readScheduler
public AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, ServerPrepareResult serverPrepareResult, java.util.List<ParameterHolder[]> parametersList, java.lang.String sql, java.util.concurrent.ThreadPoolExecutor readScheduler)
protocol
- protocolwriter
- outputStreamresults
- query resultsserverPrepareResult
- Prepare resultparametersList
- parameterssql
- sql query.readScheduler
- reading thread-poolpublic AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, ClientPrepareResult clientPrepareResult, java.util.List<ParameterHolder[]> parametersList, java.util.concurrent.ThreadPoolExecutor readScheduler)
protocol
- current protocolwriter
- outputStreamresults
- resultsclientPrepareResult
- clientPrepareResultparametersList
- parametersreadScheduler
- reading thread-poolpublic AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, java.util.List<java.lang.String> queries, java.util.concurrent.ThreadPoolExecutor readScheduler)
protocol
- protocolwriter
- outputStreamresults
- resultsqueries
- query listreadScheduler
- reading thread-poolpublic abstract void sendCmd(PacketOutputStream writer, Results results, java.util.List<ParameterHolder[]> parametersList, java.util.List<java.lang.String> queries, int paramCount, BulkStatus status, PrepareResult prepareResult) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
public abstract java.sql.SQLException 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)
public abstract int getParamCount()
public abstract int getTotalExecutionNumber()
public PrepareResult getPrepareResult()
public void executeBatch() throws java.sql.SQLException
java.sql.SQLException
- if any error occurprivate void executeBatchStandard(int estimatedParameterCount) throws java.sql.SQLException
estimatedParameterCount
- parameter counterjava.sql.SQLException
- if any error occur