We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bff6b55 commit dd160d6Copy full SHA for dd160d6
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XACommitNodesHandler.java
@@ -50,6 +50,12 @@ public XACommitNodesHandler(NonBlockingSession session) {
50
@Override
51
public void commit() {
52
final int initCount = session.getTargetCount();
53
+ if (initCount <= 0) {
54
+ session.getSource().write(session.getOkByteArray());
55
+ session.multiStatementNextSql(session.getIsMultiStatement().get());
56
+ return;
57
+ }
58
+
59
lock.lock();
60
try {
61
reset(initCount);
0 commit comments