Skip to content

Commit dd160d6

Browse files
PanternBaoyanhuqing666
authored andcommitted
import from 1380 (#1389) (#1390)
(cherry picked from commit e54eae5)
1 parent bff6b55 commit dd160d6

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/xa/XACommitNodesHandler.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,12 @@ public XACommitNodesHandler(NonBlockingSession session) {
5050
@Override
5151
public void commit() {
5252
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+
5359
lock.lock();
5460
try {
5561
reset(initCount);

0 commit comments

Comments
 (0)