org.apache.ignite.internal.processors.odbc.jdbc

Class JdbcMessageParser

java.lang.Object

org.apache.ignite.internal.processors.odbc.jdbc.JdbcMessageParser

All Implemented Interfaces:

ClientListenerMessageParser

public class JdbcMessageParser
extends Object
implements ClientListenerMessageParser

JDBC message parser.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	INIT_CAP Initial output stream capacity.

Constructor Summary

Constructors

Constructor and Description
JdbcMessageParser(GridKernalContext ctx, JdbcProtocolContext protoCtx)

Method Summary

Modifier and Type	Method and Description
protected BinaryReaderExImpl	createReader(ClientMessage msg)
protected BinaryWriterExImpl	createWriter(int cap)
ClientListenerRequest	decode(ClientMessage msg) Decode request from byte array.
int	decodeCommandType(ClientMessage msg) Decode command type.
long	decodeRequestId(ClientMessage msg) Decode request Id.
ClientMessage	encode(ClientListenerResponse msg) Encode response to byte array.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INIT_CAP

protected static final int INIT_CAP

Initial output stream capacity.

See Also:

Constant Field Values

Constructor Detail

JdbcMessageParser

public JdbcMessageParser(GridKernalContext ctx,
                         JdbcProtocolContext protoCtx)

Parameters:

ctx - Context.

protoCtx - Protocol context.

Method Detail

createReader

protected BinaryReaderExImpl createReader(ClientMessage msg)

Parameters:

msg - Message.

Returns:

Reader.

createWriter

protected BinaryWriterExImpl createWriter(int cap)

Parameters:

cap - Capacisty

Returns:

Writer.

decode

public ClientListenerRequest decode(ClientMessage msg)

Decode request from byte array.

Specified by:

decode in interface ClientListenerMessageParser

Parameters:

msg - Message.

Returns:

Request.

encode

public ClientMessage encode(ClientListenerResponse msg)

Encode response to byte array.

Specified by:

encode in interface ClientListenerMessageParser

Parameters:

msg - Response.

Returns:

Message.

decodeCommandType

public int decodeCommandType(ClientMessage msg)

Decode command type. Allows to recognize the command (message type) without decoding the entire message.

Specified by:

decodeCommandType in interface ClientListenerMessageParser

Parameters:

msg - Message.

Returns:

Command type.

decodeRequestId

public long decodeRequestId(ClientMessage msg)

Decode request Id. Allows to recognize the request Id, if any, without decoding the entire message.

Specified by:

decodeRequestId in interface ClientListenerMessageParser

Parameters:

msg - Message.

Returns:

Request Id.