import from 1380 (actiontech#1389)

CsongSY · Sep 10, 2019 · e54eae5 · e54eae5
1 parent 83b87f4
commit e54eae5
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...va/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XACommitNodesHandler.java b/...va/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);