move DummyPacket to api package

sharding-proxy/src/main/java/io/shardingsphere/proxy/frontend/mysql/MySQLFrontendHandler.java

@@ -27,6 +27,7 @@ import io.shardingsphere.proxy.transport.mysql.constant.ServerErrorCode;
 import io.shardingsphere.proxy.transport.mysql.packet.MySQLPacketPayload;
 import io.shardingsphere.proxy.transport.mysql.packet.command.api.CommandPacket;
 import io.shardingsphere.proxy.transport.mysql.packet.command.api.CommandPacketFactory;
+import io.shardingsphere.proxy.transport.mysql.packet.command.api.impl.DummyPacket;
 import io.shardingsphere.proxy.transport.mysql.packet.command.api.impl.QueryCommandPacket;
 import io.shardingsphere.proxy.transport.mysql.packet.command.api.CommandResponsePackets;
 import io.shardingsphere.proxy.transport.mysql.packet.generic.EofPacket;
@@ -95,7 +96,9 @@ public final class MySQLFrontendHandler extends FrontendHandler {
                 CommandPacket commandPacket = getCommandPacket(payload, backendConnection);
                 CommandResponsePackets responsePackets = commandPacket.execute();
                 for (DatabasePacket each : responsePackets.getPackets()) {
-                    context.writeAndFlush(each);
+                    if (!(each instanceof DummyPacket)) {
+                        context.writeAndFlush(each);
+                    }
                 }
                 if (commandPacket instanceof QueryCommandPacket && !(responsePackets.getHeadPacket() instanceof OKPacket) && !(responsePackets.getHeadPacket() instanceof ErrPacket)) {
                     writeMoreResults((QueryCommandPacket) commandPacket, responsePackets.getPackets().size());

sharding-proxy/src/main/java/io/shardingsphere/proxy/transport/common/packet/DatabasePacket.java

@@ -26,6 +26,7 @@ public interface DatabasePacket {
     
     /**
      * Get sequence ID.
+     * 
      * @return sequence ID
      */
     int getSequenceId();

sharding-proxy/src/main/java/io/shardingsphere/proxy/transport/mysql/packet/command/binary/close/DummyPacket.java → sharding-proxy/src/main/java/io/shardingsphere/proxy/transport/mysql/packet/command/api/impl/DummyPacket.java

@@ -15,7 +15,7 @@
  * </p>
  */
 
-package io.shardingsphere.proxy.transport.mysql.packet.command.binary.close;
+package io.shardingsphere.proxy.transport.mysql.packet.command.api.impl;
 
 import io.shardingsphere.proxy.transport.common.packet.DatabasePacket;
 

sharding-proxy/src/main/java/io/shardingsphere/proxy/transport/mysql/packet/command/binary/close/ComStmtClosePacket.java

@@ -20,6 +20,7 @@ package io.shardingsphere.proxy.transport.mysql.packet.command.binary.close;
 import io.shardingsphere.proxy.transport.mysql.packet.MySQLPacketPayload;
 import io.shardingsphere.proxy.transport.mysql.packet.command.api.CommandPacket;
 import io.shardingsphere.proxy.transport.mysql.packet.command.api.CommandResponsePackets;
+import io.shardingsphere.proxy.transport.mysql.packet.command.api.impl.DummyPacket;
 import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 
@@ -50,6 +51,7 @@ public class ComStmtClosePacket implements CommandPacket {
     @Override
     public CommandResponsePackets execute() {
         log.debug("COM_STMT_CLOSE received for Sharding-Proxy: {}", statementId);
+        // TODO need to clean PreparedStatementRegistry?
         return new CommandResponsePackets(new DummyPacket());
     }
 }