Package org.mariadb.jdbc.message.client

Class QueryWithParametersRewritePacket

java.lang.Object

org.mariadb.jdbc.message.client.QueryWithParametersRewritePacket

All Implemented Interfaces:

RedoableClientMessage, ClientMessage

public final class QueryWithParametersRewritePacket
extends java.lang.Object
implements RedoableClientMessage

batch execution using REWRITE.

See Also:

documentation

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.List<Parameters>	parametersList
private ClientParser	parser
private java.lang.String	preSqlCmd

Fields inherited from interface org.mariadb.jdbc.message.ClientMessage

LOAD_LOCAL_INFILE_PREFIX

Constructor Summary

Constructors

Constructor	Description
QueryWithParametersRewritePacket(java.lang.String preSqlCmd, ClientParser parser, java.util.List<Parameters> batchParameterList)

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
java.lang.String	description()	Message description
int	encode(Writer writer, Context context)	Encode client message to socket.
void	ensureReplayable(Context context)	Ensure that command can be replayed
java.io.InputStream	getLocalInfileInputStream()	Get current local infile input stream.
void	saveParameters()	Save parameters of command that can be re-executed
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

canSkipMeta, mightBeBulkResult, readPacket

Methods inherited from interface org.mariadb.jdbc.message.client.RedoableClientMessage

encode, reEncode

Field Detail

preSqlCmd

private final java.lang.String preSqlCmd

parser

private final ClientParser parser

parametersList

private java.util.List<Parameters> parametersList

Constructor Detail

QueryWithParametersRewritePacket

public QueryWithParametersRewritePacket(java.lang.String preSqlCmd,
                                        ClientParser parser,
                                        java.util.List<Parameters> batchParameterList)

Parameters:

preSqlCmd - pre sql command

parser - parser

batchParameterList - parameters

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)
           throws java.io.IOException,
                  java.sql.SQLException

Description copied from interface: ClientMessage

Encode client message to socket.

Specified by:

encode in interface ClientMessage

Parameters:

writer - socket writer

context - connection context

Returns:

number of client message written

Throws:

java.io.IOException - if socket error occur

java.sql.SQLException - if any issue occurs

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

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

description

public java.lang.String description()

Description copied from interface: ClientMessage

Message description

Specified by:

description in interface ClientMessage

Returns:

description

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

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