support drop table

chat2db-server/chat2db-plugins/chat2b-mysql/src/main/java/ai/chat2db/plugin/mysql/MysqlDBManage.java

@@ -51,6 +51,11 @@ public class MysqlDBManage implements DBManage {
 
     @Override
     public void dropTable(String databaseName, String schemaName, String tableName) {
+        String sql = "DROP TABLE "+ format(tableName);
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
+    }
 
+    public static String format(String tableName) {
+        return "`" + tableName + "`";
     }
 }

chat2db-server/chat2db-plugins/chat2db-clickhouse/src/main/java/ai/chat2db/plugin/clickhouse/ClickHouseDBManage.java

@@ -1,6 +1,7 @@
 package ai.chat2db.plugin.clickhouse;
 
 import ai.chat2db.spi.DBManage;
+import ai.chat2db.spi.sql.SQLExecutor;
 
 public class ClickHouseDBManage implements DBManage {
     @Override
@@ -39,6 +40,9 @@ public class ClickHouseDBManage implements DBManage {
 
     @Override
     public void dropTable(String databaseName, String schemaName, String tableName) {
-
+        String sql = "DROP TABLE IF EXISTS " + databaseName + "." + tableName;
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
     }
+
+
 }

chat2db-server/chat2db-plugins/chat2db-db2/src/main/java/ai/chat2db/plugin/db2/DB2DBManage.java

@@ -1,6 +1,7 @@
 package ai.chat2db.plugin.db2;
 
 import ai.chat2db.spi.DBManage;
+import ai.chat2db.spi.sql.SQLExecutor;
 
 public class DB2DBManage implements DBManage {
     @Override
@@ -40,6 +41,7 @@ public class DB2DBManage implements DBManage {
 
     @Override
     public void dropTable(String databaseName, String schemaName, String tableName) {
-
+        String sql = "DROP TABLE " + tableName;
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
     }
 }

chat2db-server/chat2db-plugins/chat2db-dm/src/main/java/ai/chat2db/plugin/dm/DMDBManage.java

@@ -1,6 +1,7 @@
 package ai.chat2db.plugin.dm;
 
 import ai.chat2db.spi.DBManage;
+import ai.chat2db.spi.sql.SQLExecutor;
 
 public class DMDBManage implements DBManage {
     @Override
@@ -40,6 +41,7 @@ public class DMDBManage implements DBManage {
 
     @Override
     public void dropTable(String databaseName, String schemaName, String tableName) {
-
+        String sql = "DROP TABLE IF EXISTS " +tableName;
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
     }
 }

chat2db-server/chat2db-plugins/chat2db-h2/src/main/java/ai/chat2db/plugin/h2/H2DBManage.java

@@ -1,6 +1,7 @@
 package ai.chat2db.plugin.h2;
 
 import ai.chat2db.spi.DBManage;
+import ai.chat2db.spi.sql.SQLExecutor;
 
 public class H2DBManage implements DBManage {
     @Override
@@ -40,6 +41,7 @@ public class H2DBManage implements DBManage {
 
     @Override
     public void dropTable(String databaseName, String schemaName, String tableName) {
-
+        String sql = "DROP TABLE " +tableName;
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
     }
 }

chat2db-server/chat2db-plugins/chat2db-hive/src/main/java/ai/chat2db/plugin/hive/HiveDBManage.java

@@ -1,6 +1,7 @@
 package ai.chat2db.plugin.hive;
 
 import ai.chat2db.spi.DBManage;
+import ai.chat2db.spi.sql.SQLExecutor;
 
 public class HiveDBManage implements DBManage {
     @Override
@@ -40,6 +41,7 @@ public class HiveDBManage implements DBManage {
 
     @Override
     public void dropTable(String databaseName, String schemaName, String tableName) {
-
+        String sql = "drop table if exists " +tableName;
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
     }
 }

chat2db-server/chat2db-plugins/chat2db-kingbase/src/main/java/ai/chat2db/plugin/kingbase/KingBaseDBManage.java

@@ -1,6 +1,7 @@
 package ai.chat2db.plugin.kingbase;
 
 import ai.chat2db.spi.DBManage;
+import ai.chat2db.spi.sql.SQLExecutor;
 
 public class KingBaseDBManage implements DBManage {
     @Override
@@ -40,6 +41,7 @@ public class KingBaseDBManage implements DBManage {
 
     @Override
     public void dropTable(String databaseName, String schemaName, String tableName) {
-
+        String sql = "drop table if exists " +tableName;
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
     }
 }

chat2db-server/chat2db-plugins/chat2db-mariadb/src/main/java/ai/chat2db/plugin/mariadb/MariaDBManage.java

@@ -1,6 +1,7 @@
 package ai.chat2db.plugin.mariadb;
 
 import ai.chat2db.spi.DBManage;
+import ai.chat2db.spi.sql.SQLExecutor;
 
 public class MariaDBManage implements DBManage {
     @Override
@@ -40,6 +41,7 @@ public class MariaDBManage implements DBManage {
 
     @Override
     public void dropTable(String databaseName, String schemaName, String tableName) {
-
+        String sql = "DROP TABLE " +tableName ;
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
     }
 }

chat2db-server/chat2db-server-web/chat2db-server-web-api/src/main/java/ai/chat2db/server/web/api/controller/rdb/vo/TableVO.java

@@ -32,6 +32,8 @@ public class TableVO {
      */
     private List<IndexVO> indexList;
 
-
+    /**
+     * 是否已经被固定
+     */
     private boolean pinned;
 }

chat2db-server/chat2db-spi/src/main/java/ai/chat2db/spi/jdbc/DefaultDBManage.java

@@ -0,0 +1,58 @@
+/**
+ * alibaba.com Inc.
+ * Copyright (c) 2004-2023 All Rights Reserved.
+ */
+package ai.chat2db.spi.jdbc;
+
+import java.sql.SQLException;
+
+import ai.chat2db.spi.DBManage;
+import ai.chat2db.spi.sql.SQLExecutor;
+
+/**
+ * @author jipengfei
+ * @version : DefaultDBManage.java
+ */
+public class DefaultDBManage implements DBManage {
+
+    @Override
+    public void connectDatabase(String database) {
+
+    }
+
+    @Override
+    public void modifyDatabase(String databaseName, String newDatabaseName) {
+
+    }
+
+    @Override
+    public void createDatabase(String databaseName) {
+
+    }
+
+    @Override
+    public void dropDatabase(String databaseName) {
+
+    }
+
+    @Override
+    public void createSchema(String databaseName, String schemaName) {
+
+    }
+
+    @Override
+    public void dropSchema(String databaseName, String schemaName) {
+
+    }
+
+    @Override
+    public void modifySchema(String databaseName, String schemaName, String newSchemaName) {
+
+    }
+
+    @Override
+    public void dropTable(String databaseName, String schemaName, String tableName) {
+        String sql = "DROP TABLE "+ tableName ;
+        SQLExecutor.getInstance().executeSql(sql, resultSet -> null);
+    }
+}