This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 10bbd2d6617 Refactor MySQLPacketCodecEngine to use do-while loop for 
adding pending messages (#37224)
10bbd2d6617 is described below

commit 10bbd2d661747dc78be8e3b41f0875482db67dae
Author: Liang Zhang <[email protected]>
AuthorDate: Sun Nov 30 10:28:10 2025 +0800

    Refactor MySQLPacketCodecEngine to use do-while loop for adding pending 
messages (#37224)
---
 .../database/protocol/mysql/codec/MySQLPacketCodecEngine.java        | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/database/protocol/dialect/mysql/src/main/java/org/apache/shardingsphere/database/protocol/mysql/codec/MySQLPacketCodecEngine.java
 
b/database/protocol/dialect/mysql/src/main/java/org/apache/shardingsphere/database/protocol/mysql/codec/MySQLPacketCodecEngine.java
index 08380a61ee3..2d229ca8b4a 100644
--- 
a/database/protocol/dialect/mysql/src/main/java/org/apache/shardingsphere/database/protocol/mysql/codec/MySQLPacketCodecEngine.java
+++ 
b/database/protocol/dialect/mysql/src/main/java/org/apache/shardingsphere/database/protocol/mysql/codec/MySQLPacketCodecEngine.java
@@ -74,10 +74,9 @@ public final class MySQLPacketCodecEngine implements 
DatabasePacketCodecEngine {
         CompositeByteBuf result = 
context.alloc().compositeBuffer(SEQUENCE_LENGTH + pendingMessages.size() + 1);
         result.addComponent(true, lastMessage.readSlice(SEQUENCE_LENGTH));
         Iterator<ByteBuf> pendingMessagesIterator = pendingMessages.iterator();
-        result.addComponent(true, pendingMessagesIterator.next());
-        while (pendingMessagesIterator.hasNext()) {
+        do {
             result.addComponent(true, pendingMessagesIterator.next());
-        }
+        } while (pendingMessagesIterator.hasNext());
         if (lastMessage.readableBytes() > 0) {
             result.addComponent(true, lastMessage);
         }

Reply via email to