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
This commit is contained in:
LUA
2020-11-05 17:48:20 +08:00
committed by GitHub
parent 864a5981d3
commit 984b353718

View File

@@ -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;
}