Class AbstractMultiSend
java.lang.Object
org.mariadb.jdbc.internal.protocol.AbstractMultiSend
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final boolean
private List<ParameterHolder[]>
protected ColumnType[]
private PrepareResult
private final Protocol
private ThreadPoolExecutor
private final Results
private String
protected int
private final PacketOutputStream
-
Constructor Summary
ConstructorsConstructorDescriptionAbstractMultiSend
(Protocol protocol, PacketOutputStream writer, Results results, List<String> queries, ThreadPoolExecutor readScheduler) Bulk execute for statement.executeBatch().AbstractMultiSend
(Protocol protocol, PacketOutputStream writer, Results results, ClientPrepareResult clientPrepareResult, List<ParameterHolder[]> parametersList, ThreadPoolExecutor readScheduler) Bulk execute for client-side PreparedStatement.executeBatch (no prepare).AbstractMultiSend
(Protocol protocol, PacketOutputStream writer, Results results, ServerPrepareResult serverPrepareResult, List<ParameterHolder[]> parametersList, String sql, ThreadPoolExecutor readScheduler) Bulk execute for Server PreparedStatement.executeBatch (when no COM_MULTI) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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
abstract int
abstract SQLException
handleResultException
(SQLException qex, Results results, List<ParameterHolder[]> parametersList, List<String> queries, int currentCounter, int sendCmdCounter, int paramCount, PrepareResult prepareResult) abstract void
sendCmd
(PacketOutputStream writer, Results results, List<ParameterHolder[]> parametersList, List<String> queries, int paramCount, BulkStatus status, PrepareResult prepareResult)
-
Field Details
-
protocol
-
writer
-
results
-
binaryProtocol
private final boolean binaryProtocol -
statementId
protected int statementId -
parameterTypeHeader
-
parametersList
-
prepareResult
-
queries
-
sql
-
readScheduler
-
-
Constructor Details
-
AbstractMultiSend
public AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, ServerPrepareResult serverPrepareResult, List<ParameterHolder[]> parametersList, String sql, ThreadPoolExecutor readScheduler) Bulk execute for Server PreparedStatement.executeBatch (when no COM_MULTI)- Parameters:
protocol
- protocolwriter
- outputStreamresults
- query resultsserverPrepareResult
- Prepare resultparametersList
- parameterssql
- sql query.readScheduler
- reading thread-pool
-
AbstractMultiSend
public AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, ClientPrepareResult clientPrepareResult, List<ParameterHolder[]> parametersList, ThreadPoolExecutor readScheduler) Bulk execute for client-side PreparedStatement.executeBatch (no prepare).- Parameters:
protocol
- current protocolwriter
- outputStreamresults
- resultsclientPrepareResult
- clientPrepareResultparametersList
- parametersreadScheduler
- reading thread-pool
-
AbstractMultiSend
public AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, List<String> queries, ThreadPoolExecutor readScheduler) Bulk execute for statement.executeBatch().- Parameters:
protocol
- protocolwriter
- outputStreamresults
- resultsqueries
- query listreadScheduler
- reading thread-pool
-
-
Method Details
-
sendCmd
public abstract void sendCmd(PacketOutputStream writer, Results results, List<ParameterHolder[]> parametersList, List<String> queries, int paramCount, BulkStatus status, PrepareResult prepareResult) throws SQLException, IOException - Throws:
SQLException
IOException
-
handleResultException
public abstract SQLException handleResultException(SQLException qex, Results results, List<ParameterHolder[]> parametersList, List<String> queries, int currentCounter, int sendCmdCounter, int paramCount, PrepareResult prepareResult) -
getParamCount
public abstract int getParamCount() -
getTotalExecutionNumber
public abstract int getTotalExecutionNumber() -
getPrepareResult
-
executeBatch
Execute Bulk execution (send packets by batch of useBatchMultiSendNumber or when max packet is reached) before reading results.- Throws:
SQLException
- if any error occur
-
executeBatchStandard
Execute Bulk execution (send packets by batch of useBatchMultiSendNumber or when max packet is reached) before reading results.- Parameters:
estimatedParameterCount
- parameter counter- Throws:
SQLException
- if any error occur
-