Class BulkExecutePacket

java.lang.Object

org.mariadb.jdbc.message.client.BulkExecutePacket

All Implemented Interfaces:

RedoableClientMessage, RedoableWithPrepareClientMessage, ClientMessage

public final class BulkExecutePacket
extends Object
implements RedoableWithPrepareClientMessage

batch execution. This relies on COM_STMT_BULK_EXECUTE

See Also:

• documentation

Field Summary

Fields

Modifier and Type	Field	Description
private List<Parameters>	batchParameterList
private final String	command
private boolean	mightBeBulkResult
private final BasePreparedStatement	prep
private Prepare	prepareResult

Constructor Summary

Constructors

Constructor	Description
BulkExecutePacket(Prepare prepareResult, List<Parameters> batchParameterList, String command, BasePreparedStatement prep)	Constructor

Method Summary

Modifier and Type	Method	Description
int	batchUpdateLength()	Number of parameter rows, and so expected return length
boolean	binaryProtocol()	Are return value encoded in binary protocol
String	description()	Message description
int	encode(Writer writer, Context context, Prepare newPrepareResult)	encoder method in case of failover, passing new prepared object
String	getCommand()	sql command value
boolean	mightBeBulkResult()	Indicating if result might be a COM_STMT_BULK result
BasePreparedStatement	prep()	Server prepare statement caller
void	saveParameters()	Save parameters of command that can be re-executed
void	setPrepareResult(PrepareResultPacket prepareResult)	Set prepare result, if pipelining prepare

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ClientMessage

canSkipMeta, getLocalInfileInputStream, readPacket, validateLocalFileName

Methods inherited from interface RedoableClientMessage

ensureReplayable

Methods inherited from interface RedoableWithPrepareClientMessage

encode, reEncode, rePrepare

Field Details

command

private final String command

prep

private final BasePreparedStatement prep

batchParameterList

private List<Parameters> batchParameterList

prepareResult

private Prepare prepareResult

mightBeBulkResult

private boolean mightBeBulkResult

Constructor Details

BulkExecutePacket

public BulkExecutePacket(Prepare prepareResult,
 List<Parameters> batchParameterList,
 String command,
 BasePreparedStatement prep)

Constructor

Parameters:

prepareResult - prepare result

batchParameterList - batch parameter list

command - sql command

prep - object creator

Method Details

saveParameters

public void saveParameters()

Description copied from interface: RedoableClientMessage

Save parameters of command that can be re-executed

Specified by:

saveParameters in interface RedoableClientMessage

encode

public int encode(Writer writer,
 Context context,
 Prepare newPrepareResult)
           throws IOException,
SQLException

Description copied from interface: RedoableWithPrepareClientMessage

encoder method in case of failover, passing new prepared object

Specified by:

encode in interface RedoableClientMessage

Specified by:

encode in interface RedoableWithPrepareClientMessage

Parameters:

writer - socket writer

context - connection context

newPrepareResult - new prepare result

Returns:

number of command sent

Throws:

IOException - if a socket exception occurs

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 interface ClientMessage

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 interface ClientMessage

Returns:

batch update length

getCommand

public String getCommand()

Description copied from interface: RedoableWithPrepareClientMessage

sql command value

Specified by:

getCommand in interface RedoableWithPrepareClientMessage

Returns:

sql command

prep

public BasePreparedStatement prep()

Description copied from interface: RedoableWithPrepareClientMessage

Server prepare statement caller

Specified by:

prep in interface RedoableWithPrepareClientMessage

Returns:

caller

binaryProtocol

public boolean binaryProtocol()

Description copied from interface: ClientMessage

Are return value encoded in binary protocol

Specified by:

binaryProtocol in interface ClientMessage

Returns:

use binary protocol

description

public String description()

Description copied from interface: ClientMessage

Message description

Specified by:

description in interface ClientMessage

Returns:

description

setPrepareResult

public void setPrepareResult(PrepareResultPacket prepareResult)

Description copied from interface: RedoableWithPrepareClientMessage

Set prepare result, if pipelining prepare

Specified by:

setPrepareResult in interface RedoableWithPrepareClientMessage

Parameters:

prepareResult - prepare results