Commit 30241c3a authored by terrymanu's avatar terrymanu
Browse files

remove connectionId for ComQueryPacket

parent 87bb38f8

sharding-proxy/src/main/java/io/shardingsphere/proxy/backend/netty/NettyBackendHandler.java

+1 −1
Original line number Diff line number Diff line
@@ -157,7 +157,7 @@ public final class NettyBackendHandler extends AbstractBackendHandler { 
        Channel channel = pool.acquire().get(RULE_REGISTRY.getBackendNIOConfig().getConnectionTimeoutSeconds(), TimeUnit.SECONDS);

        channelMap.get(dataSourceName).add(channel);

        ChannelRegistry.getInstance().putConnectionId(channel.id().asShortText(), connectionId);

        channel.writeAndFlush(new ComQueryPacket(sequenceId, connectionId, sql));

        channel.writeAndFlush(new ComQueryPacket(sequenceId, sql));

    }

    

    private CommandResponsePackets merge(final SQLStatement sqlStatement, final List<CommandResponsePackets> packets, final List<QueryResult> queryResults) {

sharding-proxy/src/main/java/io/shardingsphere/proxy/transport/mysql/packet/command/query/text/query/ComQueryPacket.java

+1 −1
Original line number Diff line number Diff line
@@ -65,7 +65,7 @@ public final class ComQueryPacket implements QueryCommandPacket { 
        transactionEngine = TransactionEngineFactory.create(sql);

    }

    

    public ComQueryPacket(final int sequenceId, final int connectionId, final String sql) {

    public ComQueryPacket(final int sequenceId, final String sql) {

        this.sequenceId = sequenceId;

        this.sql = sql;

        backendHandler = null;