Package org.mariadb.jdbc.message.client
Class ExecutePacket
java.lang.Object
org.mariadb.jdbc.message.client.ExecutePacket
- All Implemented Interfaces:
RedoableClientMessage
,RedoableWithPrepareClientMessage
,ClientMessage
Execute command (COM_STMT_EXECUTE)
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final String
private final InputStream
private Parameters
private final ServerPreparedStatement
private Prepare
-
Constructor Summary
ConstructorsConstructorDescriptionExecutePacket
(Prepare prepareResult, Parameters parameters, String command, ServerPreparedStatement prep, InputStream localInfileInputStream) Constructor -
Method Summary
Modifier and TypeMethodDescriptionint
Number of parameter rows, and so expected return lengthboolean
Are return value encoded in binary protocolboolean
Can skip metadataMessage descriptionint
encoder method in case of failover, passing new prepared objectvoid
ensureReplayable
(Context context) Ensure that command can be replayedsql command valueGet current local infile input stream.prep()
Server prepare statement callervoid
Save parameters of command that can be re-executedvoid
setPrepareResult
(PrepareResultPacket prepareResult) Set prepare result, if pipelining prepareboolean
validateLocalFileName
(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 Details
-
command
-
prep
-
localInfileInputStream
-
prepareResult
-
parameters
-
-
Constructor Details
-
ExecutePacket
public ExecutePacket(Prepare prepareResult, Parameters parameters, String command, ServerPreparedStatement prep, InputStream localInfileInputStream) Constructor- Parameters:
prepareResult
- prepare resultparameters
- parametercommand
- sql commandprep
- prepared statementlocalInfileInputStream
- local infile input stream
-
-
Method Details
-
saveParameters
public void saveParameters()Description copied from interface:RedoableClientMessage
Save parameters of command that can be re-executed- Specified by:
saveParameters
in interfaceRedoableClientMessage
-
ensureReplayable
Description copied from interface:RedoableClientMessage
Ensure that command can be replayed- Specified by:
ensureReplayable
in interfaceRedoableClientMessage
- Parameters:
context
- connection context- Throws:
IOException
- If socket error occursSQLException
- for other type of issue
-
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 interfaceRedoableClientMessage
- Specified by:
encode
in interfaceRedoableWithPrepareClientMessage
- Parameters:
writer
- socket writercontext
- connection contextnewPrepareResult
- new prepare result- Returns:
- number of command sent
- Throws:
IOException
- if a socket exception occursSQLException
- for any other kind of error
-
canSkipMeta
public boolean canSkipMeta()Description copied from interface:ClientMessage
Can skip metadata- Specified by:
canSkipMeta
in interfaceClientMessage
- 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 interfaceClientMessage
- Returns:
- batch update length
-
getCommand
Description copied from interface:RedoableWithPrepareClientMessage
sql command value- Specified by:
getCommand
in interfaceRedoableWithPrepareClientMessage
- Returns:
- sql command
-
getLocalInfileInputStream
Description copied from interface:ClientMessage
Get current local infile input stream.- Specified by:
getLocalInfileInputStream
in interfaceClientMessage
- Returns:
- default to null
-
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
Description copied from interface:ClientMessage
Message description- Specified by:
description
in interfaceClientMessage
- Returns:
- description
-
validateLocalFileName
Description copied from interface:ClientMessage
Request for local file to be validated from current query.- Specified by:
validateLocalFileName
in interfaceClientMessage
- Parameters:
fileName
- server file request pathcontext
- current connection context- Returns:
- true if file name correspond to demand and query is a load local infile
-
setPrepareResult
Description copied from interface:RedoableWithPrepareClientMessage
Set prepare result, if pipelining prepare- Specified by:
setPrepareResult
in interfaceRedoableWithPrepareClientMessage
- Parameters:
prepareResult
- prepare results
-