alter/drop add if exist flag

MyCATApache · May 12, 2022 · 75de667 · 75de667
1 parent 17d839f
commit 75de667
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/mycat2/src/main/java/io/mycat/sqlhandler/ddl/CreateIndexSQLHandler.java b/mycat2/src/main/java/io/mycat/sqlhandler/ddl/CreateIndexSQLHandler.java
@@ -43,6 +43,7 @@ protected Future<Void> onExecute(SQLRequest<SQLCreateIndexStatement> request, My
         return lockService.lock(DDL_LOCK, () -> {
             try {
                 SQLCreateIndexStatement sqlCreateIndexStatement = request.getAst();
+                sqlCreateIndexStatement.setIfNotExists(true);
                 SQLExprTableSource table = (SQLExprTableSource) sqlCreateIndexStatement.getTable();
                 resolveSQLExprTableSource(table, dataContext);
 

diff --git a/mycat2/src/main/java/io/mycat/sqlhandler/ddl/DropTableSQLHandler.java b/mycat2/src/main/java/io/mycat/sqlhandler/ddl/DropTableSQLHandler.java
@@ -62,13 +62,12 @@ public Future<Void> get() {
                     TableHandler tableHandler = metadataManager.getTable(schema, tableName);
                     if (tableHandler != null) {
                         Set<Partition> dataNodes = new HashSet<>(getDataNodes(tableHandler));
-
                         try (MycatRouterConfigOps ops = ConfigUpdater.getOps()) {
                             ops.removeTable(schema, tableName);
                             ops.commit();
-                            JdbcConnectionManager jdbcConnectionManager = MetaClusterCurrent.wrapper(JdbcConnectionManager.class);
-                            executeOnDataNodes(ast, jdbcConnectionManager, dataNodes, tableSource);
                         }
+                        JdbcConnectionManager jdbcConnectionManager = MetaClusterCurrent.wrapper(JdbcConnectionManager.class);
+                        executeOnDataNodes(ast, jdbcConnectionManager, dataNodes, tableSource);
                     }
                     return response.sendOk();
                 } catch (Throwable throwable) {

diff --git a/mycat2/src/main/java/io/mycat/sqlhandler/dml/TruncateSQLHandler.java b/mycat2/src/main/java/io/mycat/sqlhandler/dml/TruncateSQLHandler.java
@@ -33,7 +33,7 @@ public class TruncateSQLHandler extends AbstractSQLHandler<SQLTruncateStatement>
     @Override
     protected Future<Void> onExecute(SQLRequest<SQLTruncateStatement> request, MycatDataContext dataContext, Response response)  {
         SQLTruncateStatement truncateStatement = request.getAst();
-
+        truncateStatement.setIfExists(true);
         MetadataManager metadataManager = MetaClusterCurrent.wrapper(MetadataManager.class);
         JdbcConnectionManager jdbcConnectionManager = MetaClusterCurrent.wrapper(JdbcConnectionManager.class);