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

fix: not need to bring 'set autocommit = 0' before executing DDL

Browse Source
This commit is contained in:
wd2365151147
2022-01-14 15:24:41 +08:00
committed by Huqing Yan
parent c25605dcf0
commit e54cfdca8a
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/ddl/BaseDDLHandler.java
+1 -1
View File
@@ -135,7 +135,7 @@ public abstract class BaseDDLHandler implements ResponseHandler, ExecutableHandl
DDLTraceHelper.log(session.getShardingService(), d -> d.infoByNode(node.getName(), stage, DDLTraceHelper.Status.get_conn, "Get " + conn.toString()));
conn.getBackendService().setResponseHandler(this);
conn.getBackendService().setSession(session);
conn.getBackendService().execute(node, session.getShardingService(), session.getShardingService().isAutocommit() && !session.getShardingService().isTxStart());
conn.getBackendService().execute(node, session.getShardingService(), sessionAutocommit && !session.getShardingService().isTxStart());
}
@Override
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/ddl/MultiNodeDDLExecuteHandler.java
+1 -1
View File
@@ -25,6 +25,6 @@ public class MultiNodeDDLExecuteHandler extends BaseDDLHandler {
}
DDLTraceHelper.log(session.getShardingService(), d -> d.infoByNode(node.getName(), stage, DDLTraceHelper.Status.get_conn, "Get " + conn.toString()));
conn.getBackendService().setSession(session);
conn.getBackendService().executeMultiNode(node, session.getShardingService(), sessionAutocommit && !session.getShardingService().isTxStart() && !node.isModifySQL());
conn.getBackendService().executeMultiNode(node, session.getShardingService(), sessionAutocommit && !session.getShardingService().isTxStart());
}
}
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/ddl/MultiNodeDdlPrepareHandler.java
+1 -1
View File
@@ -44,7 +44,7 @@ public class MultiNodeDdlPrepareHandler extends BaseDDLHandler {
conn.getBackendService().setSession(session);
conn.getBackendService().setTesting(true);
conn.getBackendService().setComplexQuery(true);
conn.getBackendService().execute(node, session.getShardingService(), session.getShardingService().isAutocommit() && !session.getShardingService().isTxStart());
conn.getBackendService().execute(node, session.getShardingService(), sessionAutocommit && !session.getShardingService().isTxStart());
}
@Override