From 984b353718f3cf43e3da4832bac0f4dd8bc5ac1e Mon Sep 17 00:00:00 2001
From: LUA <guoaomen@actionsky.com>
Date: Thu, 5 Nov 2020 17:48:20 +0800
Subject: [PATCH] fix: inner 650/659(cherry pick from master #2231/#2243) 
 (#2251)

* fix: inner 650
Add packet number when unpacking

* fix: inner 659
Need to increase the packet number before sending data
---
 src/main/java/com/actiontech/dble/net/mysql/CommandPacket.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/com/actiontech/dble/net/mysql/CommandPacket.java b/src/main/java/com/actiontech/dble/net/mysql/CommandPacket.java
index 7bdc2e844..da33b80ab 100644
--- a/src/main/java/com/actiontech/dble/net/mysql/CommandPacket.java
+++ b/src/main/java/com/actiontech/dble/net/mysql/CommandPacket.java
@@ -130,6 +130,7 @@ public class CommandPacket extends MySQLPacket {
             BufferUtil.writeUB3(buffer, MySQLPacket.MAX_PACKET_SIZE);
             buffer.put(packetId++);
             remain = writeBody(buffer, isFirst, remain);
+            service.getSession().getShardingService().nextPacketId();
             service.writeDirectly(buffer);
             isFirst = false;
         }