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 final boolean
private final Results
private String
protected int
private final PacketOutputStream
-
Constructor Summary
ConstructorsConstructorDescriptionAbstractMultiSend
(Protocol protocol, PacketOutputStream writer, Results results, List<String> queries) Bulk execute for statement.executeBatch().AbstractMultiSend
(Protocol protocol, PacketOutputStream writer, Results results, ClientPrepareResult clientPrepareResult, List<ParameterHolder[]> parametersList) Bulk execute for client-side PreparedStatement.executeBatch (no prepare).AbstractMultiSend
(Protocol protocol, PacketOutputStream writer, Results results, ServerPrepareResult serverPrepareResult, List<ParameterHolder[]> parametersList, boolean readPrepareStmtResult, String sql) Bulk execute for Server PreparedStatement.executeBatch (when no COM_MULTI) -
Method Summary
Modifier and TypeMethodDescriptionExecute Bulk execution (send packets by batch of useBatchMultiSendNumber or when max packet is reached) before reading results.private PrepareResult
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 -
readPrepareStmtResult
private final boolean readPrepareStmtResult -
statementId
protected int statementId -
parameterTypeHeader
-
parametersList
-
prepareResult
-
queries
-
sql
-
-
Constructor Details
-
AbstractMultiSend
public AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, ServerPrepareResult serverPrepareResult, List<ParameterHolder[]> parametersList, boolean readPrepareStmtResult, String sql) Bulk execute for Server PreparedStatement.executeBatch (when no COM_MULTI)- Parameters:
protocol
- protocolwriter
- outputStreamresults
- query resultsserverPrepareResult
- Prepare resultparametersList
- parametersreadPrepareStmtResult
- must execute prepare resultsql
- sql query.
-
AbstractMultiSend
public AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, ClientPrepareResult clientPrepareResult, List<ParameterHolder[]> parametersList) Bulk execute for client-side PreparedStatement.executeBatch (no prepare).- Parameters:
protocol
- current protocolwriter
- outputStreamresults
- resultsclientPrepareResult
- clientPrepareResultparametersList
- parameters
-
AbstractMultiSend
public AbstractMultiSend(Protocol protocol, PacketOutputStream writer, Results results, List<String> queries) Bulk execute for statement.executeBatch().- Parameters:
protocol
- protocolwriter
- outputStreamresults
- resultsqueries
- query list
-
-
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.- Returns:
- prepare result
- 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- Returns:
- prepare result
- Throws:
SQLException
- if any error occur
-