Package org.mariadb.jdbc.message.client
Class QueryPacket
java.lang.Object
org.mariadb.jdbc.message.client.QueryPacket
- All Implemented Interfaces:
RedoableClientMessage
,ClientMessage
Query client packet COM_QUERY see https://mariadb.com/kb/en/com_query/
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionQueryPacket
(String sql) ConstructorQueryPacket
(String sql, InputStream localInfileInputStream) Constructor with local infile input stream -
Method Summary
Modifier and TypeMethodDescriptionint
Number of parameter rows, and so expected return lengthMessage descriptionint
Encode client message to socket.Get current local infile input stream.boolean
isCommit()
Check that command is a COMMIT commandboolean
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
binaryProtocol, canSkipMeta, mightBeBulkResult, readPacket
Methods inherited from interface org.mariadb.jdbc.message.client.RedoableClientMessage
encode, ensureReplayable, reEncode, saveParameters
-
Field Details
-
sql
-
localInfileInputStream
-
-
Constructor Details
-
QueryPacket
Constructor- Parameters:
sql
- sql command
-
QueryPacket
Constructor with local infile input stream- Parameters:
sql
- sqllocalInfileInputStream
- local infile input stream
-
-
Method Details
-
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
-
encode
Description copied from interface:ClientMessage
Encode client message to socket.- Specified by:
encode
in interfaceClientMessage
- Parameters:
writer
- socket writercontext
- connection context- Returns:
- number of client message written
- Throws:
IOException
- if socket error occur
-
isCommit
public boolean isCommit()Check that command is a COMMIT command- Returns:
- true if a commit command
-
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
-
getLocalInfileInputStream
Description copied from interface:ClientMessage
Get current local infile input stream.- Specified by:
getLocalInfileInputStream
in interfaceClientMessage
- Returns:
- default to null
-
description
Description copied from interface:ClientMessage
Message description- Specified by:
description
in interfaceClientMessage
- Returns:
- description
-