io.shardingsphere.proxy.transport.mysql.codec

Class MySQLPacketCodec

java.lang.Object

<any>

io.shardingsphere.proxy.transport.common.codec.PacketCodec<MySQLPacket>

io.shardingsphere.proxy.transport.mysql.codec.MySQLPacketCodec

public final class MySQLPacketCodec
extends PacketCodec<MySQLPacket>

MySQL packet codec.

Author:

zhangliang

Constructor Summary

Constructors

Constructor and Description
MySQLPacketCodec()

Method Summary

Modifier and Type	Method and Description
protected void	doDecode(ChannelHandlerContext context, ByteBuf in, List<Object> out, int readableBytes)
protected void	doEncode(ChannelHandlerContext context, MySQLPacket message, ByteBuf out)
protected boolean	isValidHeader(int readableBytes)

Methods inherited from class io.shardingsphere.proxy.transport.common.codec.PacketCodec

decode, encode

Methods inherited from class java.lang.Object

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

Constructor Detail

MySQLPacketCodec

public MySQLPacketCodec()

Method Detail

isValidHeader

protected boolean isValidHeader(int readableBytes)

Specified by:

isValidHeader in class PacketCodec<MySQLPacket>

doDecode

protected void doDecode(ChannelHandlerContext context,
                        ByteBuf in,
                        List<Object> out,
                        int readableBytes)

Specified by:

doDecode in class PacketCodec<MySQLPacket>

doEncode

protected void doEncode(ChannelHandlerContext context,
                        MySQLPacket message,
                        ByteBuf out)

Specified by:

doEncode in class PacketCodec<MySQLPacket>