diff --git a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XACommitNodesHandler.java b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XACommitNodesHandler.java index 22e1ecfe58..cd44c86db5 100644 --- a/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XACommitNodesHandler.java +++ b/src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XACommitNodesHandler.java @@ -50,6 +50,12 @@ public XACommitNodesHandler(NonBlockingSession session) { @Override public void commit() { final int initCount = session.getTargetCount(); + if (initCount <= 0) { + session.getSource().write(session.getOkByteArray()); + session.multiStatementNextSql(session.getIsMultiStatement().get()); + return; + } + lock.lock(); try { reset(initCount);