From dd160d6138a16228617b75a20d284dd117f5b138 Mon Sep 17 00:00:00 2001 From: Baofengqi <838800176@qq.com> Date: Tue, 10 Sep 2019 16:11:18 +0800 Subject: [PATCH] import from 1380 (#1389) (#1390) (cherry picked from commit e54eae5f9077f20bdd485dbb8fabb80efcb1dd93) --- .../nio/handler/transaction/xa/XACommitNodesHandler.java | 6 ++++++ 1 file changed, 6 insertions(+) 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);