Package org.mariadb.jdbc.message.client
Class BulkExecutePacket
- java.lang.Object
-
- org.mariadb.jdbc.message.client.BulkExecutePacket
-
- All Implemented Interfaces:
RedoableClientMessage
,RedoableWithPrepareClientMessage
,ClientMessage
public final class BulkExecutePacket extends java.lang.Object implements RedoableWithPrepareClientMessage
batch execution. This relies on COM_STMT_BULK_EXECUTE- See Also:
- documentation
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.List<Parameters>
batchParameterList
private java.lang.String
command
private boolean
mightBeBulkResult
private BasePreparedStatement
prep
private Prepare
prepareResult
-
Constructor Summary
Constructors Constructor Description BulkExecutePacket(Prepare prepareResult, java.util.List<Parameters> batchParameterList, java.lang.String command, BasePreparedStatement prep)
Constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
batchUpdateLength()
Number of parameter rows, and so expected return lengthboolean
binaryProtocol()
Are return value encoded in binary protocoljava.lang.String
description()
Message descriptionint
encode(Writer writer, Context context, Prepare newPrepareResult)
encoder method in case of failover, passing new prepared objectjava.lang.String
getCommand()
sql command valueboolean
mightBeBulkResult()
Indicating if result might be a COM_STMT_BULK resultBasePreparedStatement
prep()
Server prepare statement callervoid
saveParameters()
Save parameters of command that can be re-executedvoid
setPrepareResult(PrepareResultPacket prepareResult)
Set prepare result, if pipelining prepare-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.mariadb.jdbc.message.ClientMessage
canSkipMeta, getLocalInfileInputStream, readPacket, validateLocalFileName
-
Methods inherited from interface org.mariadb.jdbc.message.client.RedoableClientMessage
ensureReplayable
-
Methods inherited from interface org.mariadb.jdbc.message.client.RedoableWithPrepareClientMessage
encode, reEncode, rePrepare
-
-
-
-
Field Detail
-
command
private final java.lang.String command
-
prep
private final BasePreparedStatement prep
-
batchParameterList
private java.util.List<Parameters> batchParameterList
-
prepareResult
private Prepare prepareResult
-
mightBeBulkResult
private boolean mightBeBulkResult
-
-
Constructor Detail
-
BulkExecutePacket
public BulkExecutePacket(Prepare prepareResult, java.util.List<Parameters> batchParameterList, java.lang.String command, BasePreparedStatement prep)
Constructor- Parameters:
prepareResult
- prepare resultbatchParameterList
- batch parameter listcommand
- sql commandprep
- object creator
-
-
Method Detail
-
saveParameters
public void saveParameters()
Description copied from interface:RedoableClientMessage
Save parameters of command that can be re-executed- Specified by:
saveParameters
in interfaceRedoableClientMessage
-
encode
public int encode(Writer writer, Context context, Prepare newPrepareResult) throws java.io.IOException, java.sql.SQLException
Description copied from interface:RedoableWithPrepareClientMessage
encoder method in case of failover, passing new prepared object- Specified by:
encode
in interfaceRedoableClientMessage
- Specified by:
encode
in interfaceRedoableWithPrepareClientMessage
- Parameters:
writer
- socket writercontext
- connection contextnewPrepareResult
- new prepare result- Returns:
- number of command sent
- Throws:
java.io.IOException
- if a socket exception occursjava.sql.SQLException
- for any other kind of error
-
mightBeBulkResult
public boolean mightBeBulkResult()
Description copied from interface:ClientMessage
Indicating if result might be a COM_STMT_BULK result- Specified by:
mightBeBulkResult
in interfaceClientMessage
- Returns:
- true if so.
-
batchUpdateLength
public int batchUpdateLength()
Description copied from interface:ClientMessage
Number of parameter rows, and so expected return length- Specified by:
batchUpdateLength
in interfaceClientMessage
- Returns:
- batch update length
-
getCommand
public java.lang.String getCommand()
Description copied from interface:RedoableWithPrepareClientMessage
sql command value- Specified by:
getCommand
in interfaceRedoableWithPrepareClientMessage
- Returns:
- sql command
-
prep
public BasePreparedStatement prep()
Description copied from interface:RedoableWithPrepareClientMessage
Server prepare statement caller- Specified by:
prep
in interfaceRedoableWithPrepareClientMessage
- Returns:
- caller
-
binaryProtocol
public boolean binaryProtocol()
Description copied from interface:ClientMessage
Are return value encoded in binary protocol- Specified by:
binaryProtocol
in interfaceClientMessage
- Returns:
- use binary protocol
-
description
public java.lang.String description()
Description copied from interface:ClientMessage
Message description- Specified by:
description
in interfaceClientMessage
- Returns:
- description
-
setPrepareResult
public void setPrepareResult(PrepareResultPacket prepareResult)
Description copied from interface:RedoableWithPrepareClientMessage
Set prepare result, if pipelining prepare- Specified by:
setPrepareResult
in interfaceRedoableWithPrepareClientMessage
- Parameters:
prepareResult
- prepare results
-
-