Skip to content

Commit 7cab43c

Browse files
committed
atk-1275 (#2050)
1 parent a7f1e1b commit 7cab43c

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ protected boolean canResponse() {
143143
return false;
144144
}
145145

146-
protected void tryErrorFinished(boolean allEnd) {
146+
void tryErrorFinished(boolean allEnd) {
147147
if (allEnd && !session.closed()) {
148148
// clear session resources,release all
149149
if (LOGGER.isDebugEnabled()) {

src/main/java/com/actiontech/dble/server/handler/SetInnerHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,10 +115,10 @@ public static boolean execSetAutoCommit(String stmt, ServerConnection c, boolean
115115
if (!c.isAutocommit() && c.getSession2().getTargetCount() > 0) {
116116
c.getSession2().implicitCommit(() -> {
117117
boolean multiStatementFlag = c.getSession2().getIsMultiStatement().get();
118+
c.setAutocommit(true);
118119
c.write(c.writeToBuffer(c.getSession2().getOkByteArray(), c.allocate()));
119120
c.getSession2().multiStatementNextSql(multiStatementFlag);
120121
});
121-
c.setAutocommit(true);
122122
return true;
123123
}
124124
c.setAutocommit(true);

0 commit comments

Comments
 (0)