adjust transport package

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/ShardingProxy.java

@@ -26,8 +26,8 @@ import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
 import io.shardingjdbc.core.constant.DatabaseType;
-import io.shardingjdbc.proxy.transport.codec.PacketCodecFactory;
-import io.shardingjdbc.proxy.transport.handler.DatabaseProxyHandlerFactory;
+import io.shardingjdbc.proxy.transport.common.codec.PacketCodecFactory;
+import io.shardingjdbc.proxy.transport.common.handler.DatabaseProxyHandlerFactory;
 
 /**
  * Sharding-Proxy.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/codec/PacketCodec.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/common/codec/PacketCodec.java

@@ -15,13 +15,13 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.codec;
+package io.shardingjdbc.proxy.transport.common.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufUtil;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.ByteToMessageCodec;
-import io.shardingjdbc.proxy.transport.packet.SentPacket;
+import io.shardingjdbc.proxy.transport.common.packet.SentPacket;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.List;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/codec/PacketCodecFactory.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/common/codec/PacketCodecFactory.java

@@ -15,10 +15,10 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.codec;
+package io.shardingjdbc.proxy.transport.common.codec;
 
 import io.shardingjdbc.core.constant.DatabaseType;
-import io.shardingjdbc.proxy.transport.codec.mysql.MySQLPacketCodec;
+import io.shardingjdbc.proxy.transport.mysql.codec.MySQLPacketCodec;
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
 

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/handler/DatabaseProxyHandler.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/common/handler/DatabaseProxyHandler.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.handler;
+package io.shardingjdbc.proxy.transport.common.handler;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/handler/DatabaseProxyHandlerFactory.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/common/handler/DatabaseProxyHandlerFactory.java

@@ -15,10 +15,10 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.handler;
+package io.shardingjdbc.proxy.transport.common.handler;
 
 import io.shardingjdbc.core.constant.DatabaseType;
-import io.shardingjdbc.proxy.transport.handler.mysql.MySQLProxyHandler;
+import io.shardingjdbc.proxy.transport.mysql.handler.MySQLProxyHandler;
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;
 

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/DatabaseProtocolPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/common/packet/DatabaseProtocolPacket.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet;
+package io.shardingjdbc.proxy.transport.common.packet;
 
 /**
  * Database protocol packet.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/ReceivedPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/common/packet/ReceivedPacket.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet;
+package io.shardingjdbc.proxy.transport.common.packet;
 
 /**
  * Database received protocol packet.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/SentPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/common/packet/SentPacket.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet;
+package io.shardingjdbc.proxy.transport.common.packet;
 
 /**
  * Database sent protocol packet.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/codec/mysql/MySQLPacketCodec.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/codec/MySQLPacketCodec.java

@@ -15,14 +15,14 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.codec.mysql;
+package io.shardingjdbc.proxy.transport.mysql.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
-import io.shardingjdbc.proxy.transport.codec.PacketCodec;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.common.codec.PacketCodec;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 
 import java.util.List;
 

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/handler/mysql/MySQLProxyHandler.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/handler/MySQLProxyHandler.java

@@ -15,21 +15,21 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.handler.mysql;
+package io.shardingjdbc.proxy.transport.mysql.handler;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.shardingjdbc.proxy.constant.StatusFlag;
-import io.shardingjdbc.proxy.transport.handler.DatabaseProxyHandler;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.command.CommandPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.command.CommandPacketFactory;
-import io.shardingjdbc.proxy.transport.packet.mysql.handshake.AuthPluginData;
-import io.shardingjdbc.proxy.transport.packet.mysql.handshake.ConnectionIdGenerator;
-import io.shardingjdbc.proxy.transport.packet.mysql.handshake.HandshakePacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.handshake.HandshakeResponse41Packet;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.OKPacket;
+import io.shardingjdbc.proxy.transport.common.handler.DatabaseProxyHandler;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.command.CommandPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.command.CommandPacketFactory;
+import io.shardingjdbc.proxy.transport.mysql.packet.handshake.AuthPluginData;
+import io.shardingjdbc.proxy.transport.mysql.packet.handshake.ConnectionIdGenerator;
+import io.shardingjdbc.proxy.transport.mysql.packet.handshake.HandshakePacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.handshake.HandshakeResponse41Packet;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.OKPacket;
 
 /**
  * MySQL proxy handler.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/MySQLPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/MySQLPacket.java

@@ -15,9 +15,9 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql;
+package io.shardingjdbc.proxy.transport.mysql.packet;
 
-import io.shardingjdbc.proxy.transport.packet.DatabaseProtocolPacket;
+import io.shardingjdbc.proxy.transport.common.packet.DatabaseProtocolPacket;
 import lombok.Getter;
 import lombok.Setter;
 

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/MySQLPacketPayload.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/MySQLPacketPayload.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql;
+package io.shardingjdbc.proxy.transport.mysql.packet;
 
 import com.google.common.base.Strings;
 import io.netty.buffer.ByteBuf;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/MySQLReceivedPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/MySQLReceivedPacket.java

@@ -15,9 +15,9 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql;
+package io.shardingjdbc.proxy.transport.mysql.packet;
 
-import io.shardingjdbc.proxy.transport.packet.ReceivedPacket;
+import io.shardingjdbc.proxy.transport.common.packet.ReceivedPacket;
 
 /**
  * MySQL received packet.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/MySQLSentPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/MySQLSentPacket.java

@@ -15,9 +15,9 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql;
+package io.shardingjdbc.proxy.transport.mysql.packet;
 
-import io.shardingjdbc.proxy.transport.packet.SentPacket;
+import io.shardingjdbc.proxy.transport.common.packet.SentPacket;
 
 /**
  * MySQL send packet.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/ColumnDefinition41Packet.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/ColumnDefinition41Packet.java

@@ -15,12 +15,12 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
 import io.shardingjdbc.proxy.constant.ColumnType;
 import io.shardingjdbc.proxy.constant.ServerInfo;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 
 /**
  * Column definition above MySQL 4.1 packet protocol.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/ComFieldListPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/ComFieldListPacket.java

@@ -15,16 +15,16 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
 import io.shardingjdbc.core.constant.ShardingConstant;
 import io.shardingjdbc.proxy.backend.DataSourceManager;
 import io.shardingjdbc.proxy.constant.ColumnType;
 import io.shardingjdbc.proxy.constant.StatusFlag;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.EofPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.ErrPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.EofPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.ErrPacket;
 import lombok.extern.slf4j.Slf4j;
 
 import java.sql.Connection;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/ComInitDbPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/ComInitDbPacket.java

@@ -15,14 +15,14 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
 import io.shardingjdbc.core.constant.ShardingConstant;
 import io.shardingjdbc.proxy.constant.StatusFlag;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.ErrPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.OKPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.ErrPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.OKPacket;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.Collections;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/ComQueryPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/ComQueryPacket.java

@@ -15,18 +15,18 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
 import io.shardingjdbc.core.parsing.SQLJudgeEngine;
 import io.shardingjdbc.core.parsing.parser.sql.SQLStatement;
 import io.shardingjdbc.proxy.backend.DataSourceManager;
 import io.shardingjdbc.proxy.constant.ColumnType;
 import io.shardingjdbc.proxy.constant.StatusFlag;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.EofPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.ErrPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.OKPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.EofPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.ErrPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.OKPacket;
 import lombok.extern.slf4j.Slf4j;
 
 import java.sql.Connection;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/ComQuitPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/ComQuitPacket.java

@@ -15,12 +15,12 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
 import io.shardingjdbc.proxy.constant.StatusFlag;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.OKPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.OKPacket;
 
 import java.util.Collections;
 import java.util.List;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/CommandPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/CommandPacket.java

@@ -15,10 +15,10 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLReceivedPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLReceivedPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 
 import java.util.List;
 

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/CommandPacketFactory.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/CommandPacketFactory.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
 /**
  * Command packet factory.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/CommandPacketType.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/CommandPacketType.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
 import lombok.RequiredArgsConstructor;
 

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/FieldCountPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/FieldCountPacket.java

@@ -15,10 +15,10 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 
 /**
  * COM_QUERY response field count packet.

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/TextResultSetRowPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/TextResultSetRowPacket.java

@@ -15,10 +15,10 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 
 import java.util.List;
 

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/command/UnsupportedCommandPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/command/UnsupportedCommandPacket.java

@@ -15,11 +15,11 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.command;
+package io.shardingjdbc.proxy.transport.mysql.packet.command;
 
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
-import io.shardingjdbc.proxy.transport.packet.mysql.ok.ErrPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.ok.ErrPacket;
 import lombok.RequiredArgsConstructor;
 
 import java.util.Collections;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/handshake/AuthPluginData.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/handshake/AuthPluginData.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.handshake;
+package io.shardingjdbc.proxy.transport.mysql.packet.handshake;
 
 import com.google.common.primitives.Bytes;
 import lombok.Getter;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/handshake/ConnectionIdGenerator.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/handshake/ConnectionIdGenerator.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.handshake;
+package io.shardingjdbc.proxy.transport.mysql.packet.handshake;
 
 import lombok.AccessLevel;
 import lombok.Getter;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/handshake/HandshakePacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/handshake/HandshakePacket.java

@@ -15,13 +15,13 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.handshake;
+package io.shardingjdbc.proxy.transport.mysql.packet.handshake;
 
 import io.shardingjdbc.proxy.constant.CapabilityFlag;
 import io.shardingjdbc.proxy.constant.ServerInfo;
 import io.shardingjdbc.proxy.constant.StatusFlag;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 import lombok.Getter;
 
 /**

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/handshake/HandshakeResponse41Packet.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/handshake/HandshakeResponse41Packet.java

@@ -15,11 +15,11 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.handshake;
+package io.shardingjdbc.proxy.transport.mysql.packet.handshake;
 
 import io.shardingjdbc.proxy.constant.CapabilityFlag;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLReceivedPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLReceivedPacket;
 import lombok.Getter;
 
 /**

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/handshake/RandomGenerator.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/handshake/RandomGenerator.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.handshake;
+package io.shardingjdbc.proxy.transport.mysql.packet.handshake;
 
 import lombok.AccessLevel;
 import lombok.Getter;

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/ok/EofPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/ok/EofPacket.java

@@ -15,10 +15,10 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.ok;
+package io.shardingjdbc.proxy.transport.mysql.packet.ok;
 
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 import lombok.Getter;
 
 /**

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/ok/ErrPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/ok/ErrPacket.java

@@ -15,10 +15,10 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.ok;
+package io.shardingjdbc.proxy.transport.mysql.packet.ok;
 
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 import lombok.Getter;
 
 /**

sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/packet/mysql/ok/OKPacket.java → sharding-proxy/src/main/java/io/shardingjdbc/proxy/transport/mysql/packet/ok/OKPacket.java

@@ -15,10 +15,10 @@
  * </p>
  */
 
-package io.shardingjdbc.proxy.transport.packet.mysql.ok;
+package io.shardingjdbc.proxy.transport.mysql.packet.ok;
 
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLPacketPayload;
-import io.shardingjdbc.proxy.transport.packet.mysql.MySQLSentPacket;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLPacketPayload;
+import io.shardingjdbc.proxy.transport.mysql.packet.MySQLSentPacket;
 import lombok.Getter;
 
 /**

sharding-proxy/src/test/java/io/shardingjdbc/proxy/util/RandomGeneratorTest.java

@@ -17,7 +17,7 @@
 
 package io.shardingjdbc.proxy.util;
 
-import io.shardingjdbc.proxy.transport.packet.mysql.handshake.RandomGenerator;
+import io.shardingjdbc.proxy.transport.mysql.packet.handshake.RandomGenerator;
 import org.junit.Test;
 
 import static org.hamcrest.CoreMatchers.is;