Commit 555769ea authored by terrymanu's avatar terrymanu
Browse files

remove ComStatExecutePacket

parent c2475964

sharding-jdbc-server/src/main/java/io/shardingjdbc/server/packet/command/ComStatExecutePacket.java

deleted100644 → 0
+0 −26
Original line number Diff line number Diff line 
package io.shardingjdbc.server.packet.command;



import io.shardingjdbc.server.packet.MySQLPacketPayload;

import io.shardingjdbc.server.packet.AbstractMySQLSentPacket;

import io.shardingjdbc.server.packet.ok.ErrPacket;



import java.util.Collections;

import java.util.List;



/**

 * COM_STMT_EXECUTE command packet.

 *

 * @author zhangliang

 */

public final class ComStatExecutePacket extends AbstractCommandPacket {

    

    @Override

    public ComStatExecutePacket read(final MySQLPacketPayload mysqlPacketPayload) {

        return this;

    }

    

    @Override

    public List<AbstractMySQLSentPacket> execute() {

        return Collections.<AbstractMySQLSentPacket>singletonList(new ErrPacket(getSequenceId() + 1, 1, "x", "xxxxx", "xxxxxxx"));

    }

}

sharding-jdbc-server/src/main/java/io/shardingjdbc/server/packet/command/CommandPacketFactory.java

+1 −2
Original line number Diff line number Diff line
@@ -14,8 +14,6 @@ public final class CommandPacketFactory { 
                return new ComQuitPacket();

            case COM_QUERY:

                return new ComQueryPacket();

            case COM_STMT_EXECUTE:

                return new ComStatExecutePacket();

            case COM_SLEEP:

            case COM_INIT_DB:

            case COM_FIELD_LIST:
@@ -37,6 +35,7 @@ public final class CommandPacketFactory { 
            case COM_CONNECT_OUT:

            case COM_REGISTER_SLAVE:

            case COM_STMT_PREPARE:

            case COM_STMT_EXECUTE:

            case COM_STMT_SEND_LONG_DATA:

            case COM_STMT_CLOSE:

            case COM_STMT_RESET: