Interface RedoableWithPrepareClientMessage

All Superinterfaces:

ClientMessage, RedoableClientMessage

All Known Implementing Classes:

BulkExecutePacket, ExecutePacket, PrepareExecutePacket

public interface RedoableWithPrepareClientMessage
extends RedoableClientMessage

Client message that can be replayed with parameter

Method Summary

Modifier and Type	Method	Description
default int	encode(Writer writer, Context context)	Default encoder caller
int	encode(Writer writer, Context context, Prepare newPrepareResult)	encoder method in case of failover, passing new prepared object
String	getCommand()	sql command value
BasePreparedStatement	prep()	Server prepare statement caller
default int	reEncode(Writer writer, Context context, Prepare newPrepareResult)	re-encoder method in case of failover, passing new prepared object
default void	rePrepare(Client client)	Force re-prepare command
void	setPrepareResult(PrepareResultPacket prepareResult)	Set prepare result, if pipelining prepare

Methods inherited from interface ClientMessage

batchUpdateLength, binaryProtocol, canSkipMeta, description, getLocalInfileInputStream, mightBeBulkResult, readPacket, validateLocalFileName

Methods inherited from interface RedoableClientMessage

ensureReplayable, saveParameters

Method Details

getCommand

String getCommand()

sql command value

Returns:

sql command

prep

BasePreparedStatement prep()

Server prepare statement caller

Returns:

caller

encode

default int encode(Writer writer,
 Context context)
            throws IOException,
SQLException

Default encoder caller

Specified by:

encode in interface ClientMessage

Parameters:

writer - socket writer

context - connection context

Returns:

number of command sent

Throws:

IOException - if a socket exception occurs

SQLException - for any other kind of error

encode

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

encoder method in case of failover, passing new prepared object

Specified by:

encode in interface RedoableClientMessage

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

reEncode

default int reEncode(Writer writer,
 Context context,
 Prepare newPrepareResult)
              throws IOException,
SQLException

re-encoder method in case of failover, passing new prepared object

Specified by:

reEncode in interface RedoableClientMessage

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

setPrepareResult

void setPrepareResult(PrepareResultPacket prepareResult)

Set prepare result, if pipelining prepare

Parameters:

prepareResult - prepare results

rePrepare

default void rePrepare(Client client)
                throws SQLException

Force re-prepare command

Parameters:

client - client

Throws:

SQLException - if any error occurs