Package org.mariadb.jdbc.message.client

Class ExecutePacket

java.lang.Object

org.mariadb.jdbc.message.client.ExecutePacket

All Implemented Interfaces:

RedoableClientMessage, RedoableWithPrepareClientMessage, ClientMessage

public final class ExecutePacket
extends java.lang.Object
implements RedoableWithPrepareClientMessage

Execute command (COM_STMT_EXECUTE)

See Also:

Execute documentation

Field Summary

Fields

Modifier and Type	Field	Description
private java.lang.String	command
private java.io.InputStream	localInfileInputStream
private Parameters	parameters
private ServerPreparedStatement	prep
private Prepare	prepareResult

Constructor Summary

Constructors

Constructor	Description
ExecutePacket(Prepare prepareResult, Parameters parameters, java.lang.String command, ServerPreparedStatement prep, java.io.InputStream localInfileInputStream)	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
boolean	canSkipMeta()	Can skip metadata
java.lang.String	description()	Message description
int	encode(Writer writer, Context context, Prepare newPrepareResult)	encoder method in case of failover, passing new prepared object
void	ensureReplayable(Context context)	Ensure that command can be replayed
java.lang.String	getCommand()	sql command value
java.io.InputStream	getLocalInfileInputStream()	Get current local infile input stream.
ServerPreparedStatement	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
boolean	validateLocalFileName(java.lang.String fileName, Context context)	Request for local file to be validated from current query.

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

mightBeBulkResult, readPacket

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 ServerPreparedStatement prep

localInfileInputStream

private final java.io.InputStream localInfileInputStream

prepareResult

private Prepare prepareResult

parameters

private Parameters parameters

Constructor Detail

ExecutePacket

public ExecutePacket(Prepare prepareResult,
                     Parameters parameters,
                     java.lang.String command,
                     ServerPreparedStatement prep,
                     java.io.InputStream localInfileInputStream)

Constructor

Parameters:

prepareResult - prepare result

parameters - parameter

command - sql command

prep - prepared statement

localInfileInputStream - local infile input stream

Method Detail

saveParameters

public void saveParameters()

Description copied from interface: RedoableClientMessage

Save parameters of command that can be re-executed

Specified by:

saveParameters in interface RedoableClientMessage

ensureReplayable

public void ensureReplayable(Context context)
                      throws java.io.IOException,
                             java.sql.SQLException

Description copied from interface: RedoableClientMessage

Ensure that command can be replayed

Specified by:

ensureReplayable in interface RedoableClientMessage

Parameters:

context - connection context

Throws:

java.io.IOException - If socket error occurs

java.sql.SQLException - for other type of issue

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 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:

java.io.IOException - if a socket exception occurs

java.sql.SQLException - for any other kind of error

canSkipMeta

public boolean canSkipMeta()

Description copied from interface: ClientMessage

Can skip metadata

Specified by:

canSkipMeta in interface ClientMessage

Returns:

can skip metadata

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 java.lang.String getCommand()

Description copied from interface: RedoableWithPrepareClientMessage

sql command value

Specified by:

getCommand in interface RedoableWithPrepareClientMessage

Returns:

sql command

getLocalInfileInputStream

public java.io.InputStream getLocalInfileInputStream()

Description copied from interface: ClientMessage

Get current local infile input stream.

Specified by:

getLocalInfileInputStream in interface ClientMessage

Returns:

default to null

prep

public ServerPreparedStatement 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 java.lang.String description()

Description copied from interface: ClientMessage

Message description

Specified by:

description in interface ClientMessage

Returns:

description

validateLocalFileName

public boolean validateLocalFileName(java.lang.String fileName,
                                     Context context)

Description copied from interface: ClientMessage

Request for local file to be validated from current query.

Specified by:

validateLocalFileName in interface ClientMessage

Parameters:

fileName - server file request path

context - current connection context

Returns:

true if file name correspond to demand and query is a load local infile

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