From 3a445b42db8eb8bfa5cd9fb22700731d14d0fd8e Mon Sep 17 00:00:00 2001
From: An Yong Shuai <1539893812@qq.com>
Date: Tue, 25 Jun 2024 08:34:35 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E6=95=B0=E6=8D=AE=E6=BA=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.idea/compiler.xml | 4 +
.idea/dataSources.local.xml | 20 +
.idea/dataSources.xml | 17 +
.../06140e5c-6fdb-4f9a-bb2b-176dc64f7745.xml | 1050 +++++++++++++++++
.../storage_v2/_src_/schema/etl.nYkBAA.meta | 2 +
.idea/encodings.xml | 4 +
.idea/misc.xml | 5 +
.idea/setting.xml | 1 +
.idea/workspace.xml | 49 +-
etl-cleaning/pom.xml | 22 +-
.../etl/cleaning/config/DatabaseConfig.java | 47 +
.../controller/DatabaseController.java | 43 +
.../cleaning/controller/PlaceController.java | 12 +
.../etl/cleaning/domian/pojo/DataPlace.java | 47 +
.../etl/cleaning/domian/pojo/DateType.java | 26 +
.../cleaning/domian/request/PlaceRequest.java | 15 +
.../com/etl/cleaning/mapper/PlaceMapper.java | 10 +
.../etl/cleaning/service/PlaceService.java | 9 +
.../serviceimpl/PlaceServiceImpl.java | 15 +
.../src/main/resources/application.properties | 1 -
etl-common/pom.xml | 6 +-
.../com/etl/common/result/Result.class | Bin 4698 -> 4692 bytes
22 files changed, 1396 insertions(+), 9 deletions(-)
create mode 100644 .idea/dataSources.local.xml
create mode 100644 .idea/dataSources.xml
create mode 100644 .idea/dataSources/06140e5c-6fdb-4f9a-bb2b-176dc64f7745.xml
create mode 100644 .idea/dataSources/06140e5c-6fdb-4f9a-bb2b-176dc64f7745/storage_v2/_src_/schema/etl.nYkBAA.meta
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/config/DatabaseConfig.java
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/controller/DatabaseController.java
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/controller/PlaceController.java
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DataPlace.java
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DateType.java
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/domian/request/PlaceRequest.java
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/mapper/PlaceMapper.java
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/service/PlaceService.java
create mode 100644 etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java
diff --git a/.idea/compiler.xml b/.idea/compiler.xml
index 0c0411e..3168b49 100644
--- a/.idea/compiler.xml
+++ b/.idea/compiler.xml
@@ -11,5 +11,9 @@
+
+
+
+
\ No newline at end of file
diff --git a/.idea/dataSources.local.xml b/.idea/dataSources.local.xml
new file mode 100644
index 0000000..0f3f510
--- /dev/null
+++ b/.idea/dataSources.local.xml
@@ -0,0 +1,20 @@
+
+
+
+
+
+ #@
+ `
+ true
+
+
+ master_key
+ root
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/.idea/dataSources.xml b/.idea/dataSources.xml
new file mode 100644
index 0000000..17a44cb
--- /dev/null
+++ b/.idea/dataSources.xml
@@ -0,0 +1,17 @@
+
+
+
+
+ mysql.8
+ true
+ com.mysql.cj.jdbc.Driver
+ jdbc:mysql://47.101.130.221:3306/etl
+
+
+
+
+
+ $ProjectFileDir$
+
+
+
\ No newline at end of file
diff --git a/.idea/dataSources/06140e5c-6fdb-4f9a-bb2b-176dc64f7745.xml b/.idea/dataSources/06140e5c-6fdb-4f9a-bb2b-176dc64f7745.xml
new file mode 100644
index 0000000..07ca8ee
--- /dev/null
+++ b/.idea/dataSources/06140e5c-6fdb-4f9a-bb2b-176dc64f7745.xml
@@ -0,0 +1,1050 @@
+
+
+
+
+ exact
+ InnoDB
+ InnoDB
+ |root||root||ALTER|G
+|root||root|localhost|ALTER|G
+|root||root||ALTER ROUTINE|G
+|root||root|localhost|ALTER ROUTINE|G
+|root||root||APPLICATION_PASSWORD_ADMIN|G
+|root||root|localhost|APPLICATION_PASSWORD_ADMIN|G
+|root||root||AUDIT_ADMIN|G
+|root||root|localhost|AUDIT_ADMIN|G
+|root||mysql.session|localhost|BACKUP_ADMIN|G
+|root||root||BACKUP_ADMIN|G
+|root||root|localhost|BACKUP_ADMIN|G
+|root||root||BINLOG_ADMIN|G
+|root||root|localhost|BINLOG_ADMIN|G
+|root||root||BINLOG_ENCRYPTION_ADMIN|G
+|root||root|localhost|BINLOG_ENCRYPTION_ADMIN|G
+|root||mysql.session|localhost|CLONE_ADMIN|G
+|root||root||CLONE_ADMIN|G
+|root||root|localhost|CLONE_ADMIN|G
+|root||mysql.session|localhost|CONNECTION_ADMIN|G
+|root||root||CONNECTION_ADMIN|G
+|root||root|localhost|CONNECTION_ADMIN|G
+|root||root||CREATE|G
+|root||root|localhost|CREATE|G
+|root||root||CREATE ROLE|G
+|root||root|localhost|CREATE ROLE|G
+|root||root||CREATE ROUTINE|G
+|root||root|localhost|CREATE ROUTINE|G
+|root||root||CREATE TABLESPACE|G
+|root||root|localhost|CREATE TABLESPACE|G
+|root||root||CREATE TEMPORARY TABLES|G
+|root||root|localhost|CREATE TEMPORARY TABLES|G
+|root||root||CREATE USER|G
+|root||root|localhost|CREATE USER|G
+|root||root||CREATE VIEW|G
+|root||root|localhost|CREATE VIEW|G
+|root||root||DELETE|G
+|root||root|localhost|DELETE|G
+|root||root||DROP|G
+|root||root|localhost|DROP|G
+|root||root||DROP ROLE|G
+|root||root|localhost|DROP ROLE|G
+|root||root||ENCRYPTION_KEY_ADMIN|G
+|root||root|localhost|ENCRYPTION_KEY_ADMIN|G
+|root||root||EVENT|G
+|root||root|localhost|EVENT|G
+|root||root||EXECUTE|G
+|root||root|localhost|EXECUTE|G
+|root||root||FILE|G
+|root||root|localhost|FILE|G
+|root||root||FLUSH_OPTIMIZER_COSTS|G
+|root||root|localhost|FLUSH_OPTIMIZER_COSTS|G
+|root||root||FLUSH_STATUS|G
+|root||root|localhost|FLUSH_STATUS|G
+|root||root||FLUSH_TABLES|G
+|root||root|localhost|FLUSH_TABLES|G
+|root||root||FLUSH_USER_RESOURCES|G
+|root||root|localhost|FLUSH_USER_RESOURCES|G
+|root||root||GROUP_REPLICATION_ADMIN|G
+|root||root|localhost|GROUP_REPLICATION_ADMIN|G
+|root||root||INDEX|G
+|root||root|localhost|INDEX|G
+|root||root||INNODB_REDO_LOG_ARCHIVE|G
+|root||root|localhost|INNODB_REDO_LOG_ARCHIVE|G
+|root||root||INNODB_REDO_LOG_ENABLE|G
+|root||root|localhost|INNODB_REDO_LOG_ENABLE|G
+|root||root||INSERT|G
+|root||root|localhost|INSERT|G
+|root||root||LOCK TABLES|G
+|root||root|localhost|LOCK TABLES|G
+|root||mysql.session|localhost|PERSIST_RO_VARIABLES_ADMIN|G
+|root||root||PERSIST_RO_VARIABLES_ADMIN|G
+|root||root|localhost|PERSIST_RO_VARIABLES_ADMIN|G
+|root||root||PROCESS|G
+|root||root|localhost|PROCESS|G
+|root||root||REFERENCES|G
+|root||root|localhost|REFERENCES|G
+|root||root||RELOAD|G
+|root||root|localhost|RELOAD|G
+|root||root||REPLICATION CLIENT|G
+|root||root|localhost|REPLICATION CLIENT|G
+|root||root||REPLICATION SLAVE|G
+|root||root|localhost|REPLICATION SLAVE|G
+|root||root||REPLICATION_APPLIER|G
+|root||root|localhost|REPLICATION_APPLIER|G
+|root||root||REPLICATION_SLAVE_ADMIN|G
+|root||root|localhost|REPLICATION_SLAVE_ADMIN|G
+|root||root||RESOURCE_GROUP_ADMIN|G
+|root||root|localhost|RESOURCE_GROUP_ADMIN|G
+|root||root||RESOURCE_GROUP_USER|G
+|root||root|localhost|RESOURCE_GROUP_USER|G
+|root||root||ROLE_ADMIN|G
+|root||root|localhost|ROLE_ADMIN|G
+|root||mysql.infoschema|localhost|SELECT|G
+|root||root||SELECT|G
+|root||root|localhost|SELECT|G
+|root||root||SERVICE_CONNECTION_ADMIN|G
+|root||root|localhost|SERVICE_CONNECTION_ADMIN|G
+|root||mysql.session|localhost|SESSION_VARIABLES_ADMIN|G
+|root||root||SESSION_VARIABLES_ADMIN|G
+|root||root|localhost|SESSION_VARIABLES_ADMIN|G
+|root||root||SET_USER_ID|G
+|root||root|localhost|SET_USER_ID|G
+|root||root||SHOW DATABASES|G
+|root||root|localhost|SHOW DATABASES|G
+|root||root||SHOW VIEW|G
+|root||root|localhost|SHOW VIEW|G
+|root||root||SHOW_ROUTINE|G
+|root||root|localhost|SHOW_ROUTINE|G
+|root||mysql.session|localhost|SHUTDOWN|G
+|root||root||SHUTDOWN|G
+|root||root|localhost|SHUTDOWN|G
+|root||mysql.session|localhost|SUPER|G
+|root||root||SUPER|G
+|root||root|localhost|SUPER|G
+|root||mysql.infoschema|localhost|SYSTEM_USER|G
+|root||mysql.session|localhost|SYSTEM_USER|G
+|root||mysql.sys|localhost|SYSTEM_USER|G
+|root||root||SYSTEM_USER|G
+|root||root|localhost|SYSTEM_USER|G
+|root||mysql.session|localhost|SYSTEM_VARIABLES_ADMIN|G
+|root||root||SYSTEM_VARIABLES_ADMIN|G
+|root||root|localhost|SYSTEM_VARIABLES_ADMIN|G
+|root||root||TABLE_ENCRYPTION_ADMIN|G
+|root||root|localhost|TABLE_ENCRYPTION_ADMIN|G
+|root||root||TRIGGER|G
+|root||root|localhost|TRIGGER|G
+|root||root||UPDATE|G
+|root||root|localhost|UPDATE|G
+|root||root||XA_RECOVER_ADMIN|G
+|root||root|localhost|XA_RECOVER_ADMIN|G
+|root||root||grant option|G
+|root||root|localhost|grant option|G
+performance_schema|schema||mysql.session|localhost|SELECT|G
+sys|schema||mysql.sys|localhost|TRIGGER|G
+ 8.0.26
+
+
+ armscii8
+
+
+ armscii8
+ 1
+
+
+ ascii
+
+
+ ascii
+ 1
+
+
+ big5
+
+
+ big5
+ 1
+
+
+ binary
+ 1
+
+
+ cp1250
+
+
+ cp1250
+
+
+ cp1250
+
+
+ cp1250
+ 1
+
+
+ cp1250
+
+
+ cp1251
+
+
+ cp1251
+
+
+ cp1251
+ 1
+
+
+ cp1251
+
+
+ cp1251
+
+
+ cp1256
+
+
+ cp1256
+ 1
+
+
+ cp1257
+
+
+ cp1257
+ 1
+
+
+ cp1257
+
+
+ cp850
+
+
+ cp850
+ 1
+
+
+ cp852
+
+
+ cp852
+ 1
+
+
+ cp866
+
+
+ cp866
+ 1
+
+
+ cp932
+
+
+ cp932
+ 1
+
+
+ dec8
+
+
+ dec8
+ 1
+
+
+ eucjpms
+
+
+ eucjpms
+ 1
+
+
+ euckr
+
+
+ euckr
+ 1
+
+
+ gb18030
+
+
+ gb18030
+ 1
+
+
+ gb18030
+
+
+ gb2312
+
+
+ gb2312
+ 1
+
+
+ gbk
+
+
+ gbk
+ 1
+
+
+ geostd8
+
+
+ geostd8
+ 1
+
+
+ greek
+
+
+ greek
+ 1
+
+
+ hebrew
+
+
+ hebrew
+ 1
+
+
+ hp8
+
+
+ hp8
+ 1
+
+
+ keybcs2
+
+
+ keybcs2
+ 1
+
+
+ koi8r
+
+
+ koi8r
+ 1
+
+
+ koi8u
+
+
+ koi8u
+ 1
+
+
+ latin1
+
+
+ latin1
+
+
+ latin1
+
+
+ latin1
+
+
+ latin1
+
+
+ latin1
+
+
+ latin1
+
+
+ latin1
+ 1
+
+
+ latin2
+
+
+ latin2
+
+
+ latin2
+
+
+ latin2
+ 1
+
+
+ latin2
+
+
+ latin5
+
+
+ latin5
+ 1
+
+
+ latin7
+
+
+ latin7
+
+
+ latin7
+ 1
+
+
+ latin7
+
+
+ macce
+
+
+ macce
+ 1
+
+
+ macroman
+
+
+ macroman
+ 1
+
+
+ sjis
+
+
+ sjis
+ 1
+
+
+ swe7
+
+
+ swe7
+ 1
+
+
+ tis620
+
+
+ tis620
+ 1
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+ 1
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ucs2
+
+
+ ujis
+
+
+ ujis
+ 1
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+ 1
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16
+
+
+ utf16le
+
+
+ utf16le
+ 1
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+ 1
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf32
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+ 1
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8
+
+
+ utf8mb4
+ 1
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ utf8mb4
+
+
+ 1
+ 2024-06-24.08:13:15
+ utf8mb4_0900_ai_ci
+
+
+ utf8_general_ci
+
+
+ utf8mb4_0900_ai_ci
+
+
+ utf8mb4_0900_ai_ci
+
+
+ utf8mb4_0900_ai_ci
+
+
+ utf8mb4_0900_ai_ci
+
+
+ utf8_general_ci
+
+
+ utf8mb4_0900_ai_ci
+
+
+ 0
+ localhost
+ caching_sha2_password
+
+
+ 0
+ localhost
+ caching_sha2_password
+
+
+ 0
+ localhost
+ caching_sha2_password
+
+
+ caching_sha2_password
+
+
+ localhost
+ caching_sha2_password
+
+
+
\ No newline at end of file
diff --git a/.idea/dataSources/06140e5c-6fdb-4f9a-bb2b-176dc64f7745/storage_v2/_src_/schema/etl.nYkBAA.meta b/.idea/dataSources/06140e5c-6fdb-4f9a-bb2b-176dc64f7745/storage_v2/_src_/schema/etl.nYkBAA.meta
new file mode 100644
index 0000000..f8bb948
--- /dev/null
+++ b/.idea/dataSources/06140e5c-6fdb-4f9a-bb2b-176dc64f7745/storage_v2/_src_/schema/etl.nYkBAA.meta
@@ -0,0 +1,2 @@
+#n:etl
+! [0, 0, null, null, -2147483648, -2147483648]
diff --git a/.idea/encodings.xml b/.idea/encodings.xml
index 400a3ad..9889897 100644
--- a/.idea/encodings.xml
+++ b/.idea/encodings.xml
@@ -1,6 +1,10 @@
+
+
+
+
diff --git a/.idea/misc.xml b/.idea/misc.xml
index a63fe37..8cc4f1e 100644
--- a/.idea/misc.xml
+++ b/.idea/misc.xml
@@ -8,6 +8,11 @@
+
diff --git a/.idea/setting.xml b/.idea/setting.xml
index ed05fd8..b805bef 100644
--- a/.idea/setting.xml
+++ b/.idea/setting.xml
@@ -1,6 +1,7 @@
+
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index ae93537..16906c8 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -5,12 +5,25 @@
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
+
+
+
+
@@ -20,6 +33,7 @@
@@ -55,6 +69,7 @@
+
+
+
@@ -137,6 +170,10 @@
+
+
+
+
diff --git a/etl-cleaning/pom.xml b/etl-cleaning/pom.xml
index d9a3e85..4b4e991 100644
--- a/etl-cleaning/pom.xml
+++ b/etl-cleaning/pom.xml
@@ -19,16 +19,36 @@
2.6.13
+
+ org.springframework
+ spring-jdbc
+ 5.3.22
+
+
+ mysql
+ mysql-connector-java
+ 8.0.29
+
org.springframework.boot
spring-boot-starter-web
-
org.springframework.boot
spring-boot-starter-test
test
+
+ com.bwie
+ etl-common
+ 1.0-SNAPSHOT
+
+
+ com.baomidou
+ mybatis-plus-annotation
+ 3.5.7
+ compile
+
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/config/DatabaseConfig.java b/etl-cleaning/src/main/java/com/etl/cleaning/config/DatabaseConfig.java
new file mode 100644
index 0000000..5424368
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/config/DatabaseConfig.java
@@ -0,0 +1,47 @@
+package com.etl.cleaning.config;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+/**
+ * 连接数据源所需参数
+ */
+@Data
+public class DatabaseConfig {
+ /**
+ * 数据源描述
+ */
+ private String driverClassName;
+ /**
+ * 连接地址
+ */
+ private String url;
+ /**
+ * 数据库名称
+ */
+ private String databaseName;
+ /**
+ * 用户名
+ */
+ private String username;
+ /**
+ * 密码
+ */
+ private String password;
+ /**
+ * 端口
+ */
+ private String port;
+ /**
+ * 额外配置
+ */
+ private String extraConfig;
+ /**
+ * 状态
+ */
+ private Boolean status;
+ /**
+ * 备注
+ */
+ private String remark;
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/controller/DatabaseController.java b/etl-cleaning/src/main/java/com/etl/cleaning/controller/DatabaseController.java
new file mode 100644
index 0000000..5aa4280
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/controller/DatabaseController.java
@@ -0,0 +1,43 @@
+package com.etl.cleaning.controller;
+
+import com.etl.cleaning.config.DatabaseConfig;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DriverManagerDataSource;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 动态链接mysql数据源
+ */
+@RestController
+@RequestMapping("/data")
+public class DatabaseController {
+ /**
+ * jdbc连接
+ * @param databaseConfig
+ * @return
+ */
+ @PostMapping("/test-database-connection")
+ public String testDatabaseConnection(@RequestBody DatabaseConfig databaseConfig) {
+ try {
+ //创建数据源
+ DriverManagerDataSource dataSource = new DriverManagerDataSource();
+ //设置数据源的驱动类名,URL,用户名,密码
+ dataSource.setDriverClassName(databaseConfig.getDriverClassName());
+ dataSource.setUrl(databaseConfig.getUrl());
+ dataSource.setUsername(databaseConfig.getUsername());
+ dataSource.setPassword(databaseConfig.getPassword());
+ //创建数据源
+ JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
+ //sql测试
+ jdbcTemplate.execute("select * from user");
+ return "ok";
+ }catch (Exception e){
+ //如果发生异常，打印异常信息
+ e.printStackTrace();
+ return "error";
+ }
+ }
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/controller/PlaceController.java b/etl-cleaning/src/main/java/com/etl/cleaning/controller/PlaceController.java
new file mode 100644
index 0000000..d4f62e0
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/controller/PlaceController.java
@@ -0,0 +1,12 @@
+package com.etl.cleaning.controller;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+/**
+ * 数据源管理
+ */
+@RestController
+@RequestMapping("/place")
+public class PlaceController {
+
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DataPlace.java b/etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DataPlace.java
new file mode 100644
index 0000000..dca8589
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DataPlace.java
@@ -0,0 +1,47 @@
+package com.etl.cleaning.domian.pojo;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * 数据源管理表
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+@TableName("data_place")
+public class DataPlace {
+ /**
+ * id
+ */
+ @TableId(type = IdType.AUTO)
+ private Long id;
+ /**
+ * 数据源描述
+ */
+ private String name;
+ /**
+ * 备注
+ */
+ private String bank;
+ /**
+ * 修改时间
+ */
+ private Date updateTime;
+ /**
+ * 类型ID
+ */
+ private Long typeId;
+ /**
+ * 链接状态
+ */
+ private Boolean statue;
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DateType.java b/etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DateType.java
new file mode 100644
index 0000000..04ba945
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DateType.java
@@ -0,0 +1,26 @@
+package com.etl.cleaning.domian.pojo;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 数据源类型
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+@TableName("date_type")
+public class DateType {
+ /**
+ * id
+ */
+ private Long id;
+ /**
+ * 名称
+ */
+ private String name;
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/PlaceRequest.java b/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/PlaceRequest.java
new file mode 100644
index 0000000..007da5d
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/PlaceRequest.java
@@ -0,0 +1,15 @@
+package com.etl.cleaning.domian.request;
+
+
+import lombok.Data;
+
+/**
+ * 数据源管理查询参数
+ */
+@Data
+public class PlaceRequest {
+ private String bank;
+ private Long typeId;
+ private Integer pageNum;
+ private Integer pageSize;
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/mapper/PlaceMapper.java b/etl-cleaning/src/main/java/com/etl/cleaning/mapper/PlaceMapper.java
new file mode 100644
index 0000000..7fc088b
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/mapper/PlaceMapper.java
@@ -0,0 +1,10 @@
+package com.etl.cleaning.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.etl.cleaning.domian.pojo.DataPlace;
+
+/**
+ * 数据源管理
+ */
+public interface PlaceMapper extends BaseMapper {
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/service/PlaceService.java b/etl-cleaning/src/main/java/com/etl/cleaning/service/PlaceService.java
new file mode 100644
index 0000000..561a282
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/service/PlaceService.java
@@ -0,0 +1,9 @@
+package com.etl.cleaning.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.etl.cleaning.domian.pojo.DataPlace;
+/**
+ * 数据源管理
+ */
+public interface PlaceService extends IService {
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java b/etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java
new file mode 100644
index 0000000..ff047f7
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java
@@ -0,0 +1,15 @@
+package com.etl.cleaning.serviceimpl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.etl.cleaning.domian.pojo.DataPlace;
+import com.etl.cleaning.mapper.PlaceMapper;
+import com.etl.cleaning.service.PlaceService;
+import org.springframework.stereotype.Service;
+
+/**
+ * 数据源管理
+ */
+@Service
+public class PlaceServiceImpl extends ServiceImpl implements PlaceService {
+
+}
diff --git a/etl-cleaning/src/main/resources/application.properties b/etl-cleaning/src/main/resources/application.properties
index e52b498..b372ec4 100644
--- a/etl-cleaning/src/main/resources/application.properties
+++ b/etl-cleaning/src/main/resources/application.properties
@@ -1,3 +1,2 @@
-# 应用服务 WEB 访问端口
server.port=8080
diff --git a/etl-common/pom.xml b/etl-common/pom.xml
index 412ed7b..af9ac0e 100644
--- a/etl-common/pom.xml
+++ b/etl-common/pom.xml
@@ -16,6 +16,11 @@
2.6.13
+
+ com.baomidou
+ mybatis-plus-boot-starter
+ 3.5.7
+
net.sourceforge.tess4j
tess4j
@@ -64,7 +69,6 @@
org.projectlombok
lombok
- 1.18.22
org.springframework
diff --git a/etl-common/target/classes/com/etl/common/result/Result.class b/etl-common/target/classes/com/etl/common/result/Result.class
index cc583af2581a384f6c9847567a73cf2f944ad590..1c3edad6166b3ab26850ba8843558f46697023b0 100644
GIT binary patch
literal 4692
zcmbtXYj+!072PAv=#@$BD6vyDCM0Rn%CZ&FCT*!@ySTPPl-N#cJBFq_GLZ*csVo_3
zRA_kw3Vl!r6x#AAtkrMiOFqz-nni&HU&>nij;6n%A6mjbb7!ovEIUr|^3vS7_uPH=
z+2@>l@BHV#fBgr5@wrm15T-}G)?Tp9U2l`
z!SUfI(^HqMr>tDrsx0NsT)bo#oqQqCHRseym8E?DRNJcSSmwp0ZWFu2AN|BwVJe2*
zYYcAu?b#dGuM2}76TR50Au?R5l$=ow;dK9k45Uolg?)6kZad@EMVlz;f*SgqiT(Jz
z8k(>iOG8fw%F6bji9@)X_=K6RFSVKau5iU8=!xPU4c+a&iz8_h{jMWLGLen}6NAW-
z?TTO~H>x8>ITK&NeI&lRc_N5FJ6XTdruu9SOv)AYz!3h&z
z76!3ptG+COiK3ukZ%Z|$>7$KOdC{&Va1uQ+Ofm8*z0#uKh;+}GID@mKVXdy(l|>EN
zU=aPtY;eH?&I`n>K(Gw@m>HWI#&C{{3?5*lMq>C1og6$M0dYw@E(qt_*7g#LdCI{>>7D5f|`BH#FEIkt0kOgL99~6S+L3t
zW?B>_6PE2-J;uc(zQ`MqXUa%+!rSN$4uJ3$$)gKt$gdiDg
z?X}Nwq65c($7{KJ3)W{h=W)AeJ~P9v)vC2N6}QW0dJ{gMmCUj9?H?N&W;S7Q+gQFP
zaci~YpKbeZmDP7|Y2ZUXwh2dO&}XKpJIf_jo{{c%YcZ0RbX;H!SJ_#0mTiVLCN_uN
zGbiqLd2P2_oiYj4uU-yr?M+4sZs(k16`!28R=u(@&dwI5C%I*+^PGjQ7BLPh%-C?T
z?48w{6jC5xyaHA|Z95j%PRvyswW58ZB>UG66{MrGyWt>Dr6bVrBqF>Atf0bnmHSo*
zt4PT$iS3l!F5EsI&hC?Evisz*OZ%GJuA>KWIB0P0Q|vi}Fn_`O&|A=w@$1;}7rtru
z4u2zjf=9iY`CWJ3)84!joF}7+OmJQ}FfWT|IBqH{Ir{nby>&fxzA5bQyVyVQu+I=X
z#Id+w4|tS<(D%8}y~@agrny`~xLj+IILBIx{E!xxJ38K#Om=Ymfq>(e@gtAiG0*Wh
z1?$Rq(?S8i9}f7fDEVIg*d@?O!4`p_n!2rl@w8
zzeG@n$-oj(xiB)K;1RBZq~iV)B;?BN0bb!#r%md8gdTqnduFoxnz%EYX`(MX*u;UX
zq^1(6mq`y45W^_~oJJB;*o$d*$&3P7%Zrq|xFl=JT|C5DyYN#yM=Z$|l}9NrSJc?^
z98(luU`Fvy&R;2)F+K&!$h?QcZ?X}LS63ij243U>!Hk!l=h>slopl4;JGl2+8{GbF
z!ttWp0WQ-LOV#nAZNl;D>&2tx>^nHx4tLMC;FN|xBR_t=cr2#~FXbJ{?0XmYb{0{^
zB;tuETahGCu(oAP$;mI84afuUBC}oO_Fbce%b0lv;W49l>PyBU4@xV=}nCK=3_$!O~!^IDMM@`A0T-ZJ5xp~;v4CbgnD2%Q#pN7
z5n2mJ13!1qlpb8bFPP^czD?i?f5UhPqxdCTI_7z9{faFE=NbH$*@^@TuHgkxVf>mH
zzv0>kk%-1V!5vYA%umr9#S#9;v`=xTYQ}j2%NL>-@zZ=tE*T*T^-@V{I>f%a$HsJ>lsms-1#yWhfvCW>!^NA9xQ
d=#mOlmlXM6mpwer9VX=M*}umh*cZa<{{wcfrnmqA
literal 4698
zcmbtYTX$PW75YTD86XnOESJL&9l;cS(>lJaU9o0=d03uO`5OE
z!Z)P(rZmrq%C|)Nwn*Qx@ZC5Da6O9eN&mbw-;d&jD1IQ~52Lst{f}Y@;m2{jh@Xh`
zQwuLy_?dy8np-V8r6spoD^|*vbJGTl3kJHUD&<<;Dc6^rQo}WQ7x@_mto-GvshND9
zYB>Ypb7yn2>Ntb*{zo
z#g(#CZ&U?hagj4ttx+hrwVHt=siE0IWi9L0OIh}7m2$S~)*7XHcERfeddfR|-)yn$
z&NtSsy46MJYKd55urXk@W`BDuUiH$}cI+0-x6E{_)k?LE#huzSw}n0bt1+iix!rCh
zEAv}ev1=@!lQ<){uEN&9Ob6HP8kttcob{rQdH7zba(r6_-_FOkxH!Xd*B1Jik?~@=
zSf6Bqr-qi8v-Q;?v)fv6>neLW&2kdqcus0aACt606%qYuuaIn3*eE4tYDgClA2^)K
z$$^oYM(z*t?gu0lEGj7IO&S{6gGfnU3YPnH!zt1Hj+$3k87l_NN`2L30z~DeC%nQK
z^QN@yO{=09SMzFcbbA-2r8ITt>rUaRIcMD~Fnmc^%z0A5DbI*y6jzFQ>B#sb&3#hy2>_zI5ZCe}47d=U=?@!fQ6BF=JyycI$;Z
ze|qlD?b`+h+rZRS^$TI+0v@xmh|4xUg(qw*;gdEp7`E{MvNk?~lQvfH85?t$w{a1d
zY?r
zo8?V#+QHlD?+;+*%5`_et@4oG);;tjL#wF2B$ya83kw$)aFib~$6??EA~=W-;eN^=
z<|jr7DI_IEC@00+-W=WK_4Jt6(`nRy(34N0A2EJvJ;c2q<;*d3u?6DB>o5{sw-Npw
zM+QE|Ho_hl(mOxy?R!}7JI8&p8czrJbp`fiFv@jXX-VL4G`4Bx6i3RcaSwY!V_zh8
zh-)#y9@ZuWp-+0y14>ClQ(Z!o$F&ZLajkX8BsI=-yttW&bh!9Kfs3EPC$w>=^u=Q&
z%uMTTp}@T#4%}Orz!8>|5PB4hW91~}_bJ4sP-(y$?8DSaz76Y%w-BAr9BLw#NjDMCj5M()BcZ7X
z8i0Id=MZJR>c(S8U={~hlO*KQ3S=WLlHTDGtV!?i5O?+B93CZ>#EOceq>dG}cAjg>
z#2h1vHIc2P%USkQf9(tS%cMb%a=jIdGIO3YhLp~`;NC#@tv0yBJA`8q
z?f|#9MV89rV>^UnCD;CFUG@#^YlpjkM{tV6JniF?qOF`Iyrg#|edtYecP3H!B%(=_
zQX~Ns%xzgybn=P13wiiW?AHN)FVmv;HCf{zG0#zAG@SW6
z_9Vmap!X*1OfuZWeqX(B)TBz^Xe4QhPUIaVZlXJBCL_L5Sb{JdsAejr&ntsA+|j^i
zy*H&FPvUco^AJbV_&i(5he^(!B+4S+Er*hcD>#I!lp=wIYiI{5i~=#1dG=Ant?0k8
z*Me)mhXD&;;9t~u5BDiC#&0tD0MQH5PMOIM7!CX{
z!b*vm?im{oPYm{qtqR>wPIx@akSs@ghHt{kG|}(P_l<^SAsN;yQQ@9TgPl1&t?)Ic
zT`Vm{FT_ngQr9Sj(8nNoinew!_z$2&DIBnRTJtBYT|oGKQWqv`hC!nEzlZm^tu+qG
zL_bVl!Pg0Io}wD>&rdGR!aA*xa(DV|46q^}NZi*%Qiy2cV1mV2