From 829813df38aea15d67b33f8b8e10f81f2dac39e4 Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Wed, 3 Jan 2024 11:23:17 +0800 Subject: [PATCH] =?UTF-8?q?refactor(info-query):=20=E7=A7=BB=E9=99=A4?= =?UTF-8?q?=E6=97=A0=E7=94=A8=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/lanyuanxiaoyao/service/info/InfoQueryApplication.java | 1 - .../lanyuanxiaoyao/service/info/service/FlinkJobService.java | 2 +- .../com/lanyuanxiaoyao/service/info/service/InfoService.java | 2 +- .../lanyuanxiaoyao/service/info/service/TableMetaService.java | 2 +- 4 files changed, 3 insertions(+), 4 deletions(-) diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/InfoQueryApplication.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/InfoQueryApplication.java index 468cf58..6701274 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/InfoQueryApplication.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/InfoQueryApplication.java @@ -21,7 +21,6 @@ import org.springframework.scheduling.annotation.EnableScheduling; @SpringBootApplication( scanBasePackages = { "com.lanyuanxiaoyao.service", - "com.eshore.odcp.hudi.connector.utils.database" }, exclude = {GsonAutoConfiguration.class} ) diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/FlinkJobService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/FlinkJobService.java index 7b06773..ac82e09 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/FlinkJobService.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/FlinkJobService.java @@ -33,7 +33,7 @@ public class FlinkJobService extends BaseService { private static final Logger logger = LoggerFactory.getLogger(FlinkJobService.class); private final JdbcTemplate mysqlJdbcTemplate; - public FlinkJobService(JdbcTemplate mysqlJdbcTemplate, TransactionTemplate mysqlTransactionTemplate, SQLLoggerProvider.SQLLogger sqlLogger) { + public FlinkJobService(JdbcTemplate mysqlJdbcTemplate) { this.mysqlJdbcTemplate = mysqlJdbcTemplate; } diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java index f287eca..837913c 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java @@ -37,7 +37,7 @@ public class InfoService extends BaseService { private final FlinkJobService flinkJobService; private final TableMetaService tableMetaService; - public InfoService(JdbcTemplate mysqlJdbcTemplate, TransactionTemplate mysqlTransactionTemplate, SQLLoggerProvider.SQLLogger sqlLogger, FlinkJobService flinkJobService, TableMetaService tableMetaService) { + public InfoService(JdbcTemplate mysqlJdbcTemplate, TransactionTemplate mysqlTransactionTemplate, FlinkJobService flinkJobService, TableMetaService tableMetaService) { this.mysqlJdbcTemplate = mysqlJdbcTemplate; this.mysqlTransactionTemplate = mysqlTransactionTemplate; this.flinkJobService = flinkJobService; diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java index b758671..c4f9f4e 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java @@ -44,7 +44,7 @@ public class TableMetaService extends BaseService { private final JdbcTemplate mysqlJdbcTemplate; private final FlinkJobService flinkJobService; - public TableMetaService(JdbcTemplate mysqlJdbcTemplate, TransactionTemplate mysqlTransactionTemplate, SQLLoggerProvider.SQLLogger sqlLogger, FlinkJobService flinkJobService) { + public TableMetaService(JdbcTemplate mysqlJdbcTemplate, FlinkJobService flinkJobService) { this.mysqlJdbcTemplate = mysqlJdbcTemplate; this.flinkJobService = flinkJobService; }