delete drop dp, drop table, drop column

apache · May 7, 2022 · 7d1f510 · 7d1f510
1 parent 96cafe0
commit 7d1f510
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 156 deletions.
diff --git a/...rc/main/java/org/apache/inlong/manager/service/core/impl/ClickHouseSourceServiceImpl.java b/...rc/main/java/org/apache/inlong/manager/service/core/impl/ClickHouseSourceServiceImpl.java
@@ -30,9 +30,6 @@
 import org.apache.inlong.manager.service.resource.ck.builder.ClickHouseAddColumnSqlBuilder;
 import org.apache.inlong.manager.service.resource.ck.builder.ClickHouseCreateDbSqlBuilder;
 import org.apache.inlong.manager.service.resource.ck.builder.ClickHouseCreateTableSqlBuilder;
-import org.apache.inlong.manager.service.resource.ck.builder.ClickHouseDropColumnSqlBuilder;
-import org.apache.inlong.manager.service.resource.ck.builder.ClickHouseDropDbSqlBuilder;
-import org.apache.inlong.manager.service.resource.ck.builder.ClickHouseDropTableSqlBuilder;
 import org.apache.inlong.manager.service.resource.ck.builder.ClickHouseModifyColumnSqlBuilder;
 import org.apache.inlong.manager.service.resource.ck.builder.ClickHouseQueryTableSqlBuilder;
 import org.slf4j.Logger;
@@ -67,11 +64,6 @@ public void createDb(ClickHouseTableQueryBean bean) throws Exception {
 
     @Override
     public void dropDb(DatabaseQueryBean queryBean) throws Exception {
-        ClickHouseDropDbSqlBuilder builder = new ClickHouseDropDbSqlBuilder();
-        String dropDbSql = builder.buildDDL(queryBean);
-        LOGGER.info("drop database sql={}", dropDbSql);
-        clickHouseServerDao.executeDDL(dropDbSql, queryBean.getJdbcUrl(),
-                queryBean.getUserName(), queryBean.getPassword());
     }
 
     @Override
@@ -85,11 +77,6 @@ public void createTable(ClickHouseTableQueryBean bean) throws Exception {
 
     @Override
     public void dropTable(ClickHouseTableQueryBean queryBean) throws Exception {
-        ClickHouseDropTableSqlBuilder builder = new ClickHouseDropTableSqlBuilder();
-        String dropTableSql = builder.buildDDL(queryBean);
-        LOGGER.info("drop table sql={}", dropTableSql);
-        clickHouseServerDao.executeDDL(dropTableSql, queryBean.getJdbcUrl(),
-                queryBean.getUsername(), queryBean.getPassword());
     }
 
     @Override
@@ -141,19 +128,7 @@ public void updateColumn(ClickHouseTableQueryBean queryBean) throws Exception {
 
     @Override
     public void dropColumn(ClickHouseTableQueryBean queryBean) throws Exception {
-        if (queryBean == null) {
-            LOGGER.warn("update table column failed: change info is null");
-            return;
-        }
 
-        ClickHouseDropColumnSqlBuilder builder = new ClickHouseDropColumnSqlBuilder();
-        String dropColumnSql = builder.buildDDL(queryBean);
-        LOGGER.info("update table Column sql={}", dropColumnSql);
-        String[] dropColumnInfo = dropColumnSql.split("|");
-        for (String columnInfo : dropColumnInfo) {
-            clickHouseServerDao.executeDDL(columnInfo, queryBean.getJdbcUrl(),
-                    queryBean.getUsername(), queryBean.getPassword());
-        }
     }
 
     @Override

diff --git a/...org/apache/inlong/manager/service/resource/ck/builder/ClickHouseDropColumnSqlBuilder.java b/...org/apache/inlong/manager/service/resource/ck/builder/ClickHouseDropColumnSqlBuilder.java
diff --git a/...ava/org/apache/inlong/manager/service/resource/ck/builder/ClickHouseDropDbSqlBuilder.java b/...ava/org/apache/inlong/manager/service/resource/ck/builder/ClickHouseDropDbSqlBuilder.java
diff --git a/.../org/apache/inlong/manager/service/resource/ck/builder/ClickHouseDropTableSqlBuilder.java b/.../org/apache/inlong/manager/service/resource/ck/builder/ClickHouseDropTableSqlBuilder.java