mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-05 20:30:40 -06:00
Code Issues Packages Projects Releases Wiki Activity

inner 1970 - handle multi-statement error when sql contains ddl (#3459)

Browse Source 
* inner 1970 - handle multi-statement error when sql contains ddl

* inner 1970 - handle multi node

* inner 1970 - fix case that ddl fails to execute
This commit is contained in:
Collapsar
2022-11-03 17:55:46 +08:00
committed by GitHub
parent 3619497345
commit b3d389d4ca
2 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/MultiNodeDDLExecuteHandler.java
View File

@@ -198,10 +198,9 @@ public class MultiNodeDDLExecuteHandler extends MultiNodeQueryHandler {
ok.setMessage(null);
ok.setAffectedRows(0);
ok.setServerStatus(source.isAutocommit() ? 2 : 1);
boolean multiStatementFlag = session.multiStatementPacket(ok, packetId);
session.multiStatementPacket(ok, packetId);
doSqlStat();
handleEndPacket(ok.toBytes(), true);
session.multiStatementNextSql(multiStatementFlag);
}
}
} finally {

4
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/SingleNodeDDLHandler.java
View File

@@ -96,11 +96,9 @@ public class SingleNodeDDLHandler extends SingleNodeHandler {
session.releaseConnectionIfSafe(conn, false);
session.setResponseTime(true);
session.multiStatementPacket(ok, packetId);
boolean multiStatementFlag = session.getIsMultiStatement().get();
if (writeToClient.compareAndSet(false, true)) {
handleEndPacket(ok.toBytes(), true);
}
session.multiStatementNextSql(multiStatementFlag);
}
}
}
@@ -117,12 +115,10 @@ public class SingleNodeDDLHandler extends SingleNodeHandler {
session.releaseConnectionIfSafe(conn, false);
session.setResponseTime(false);
session.multiStatementPacket(errPacket, packetId);
boolean multiStatementFlag = session.getIsMultiStatement().get();
doSqlStat();
if (writeToClient.compareAndSet(false, true)) {
handleEndPacket(errPacket.toBytes(), false);
}
session.multiStatementNextSql(multiStatementFlag);
}
@Override