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 cc583af..1c3edad 100644
Binary files a/etl-common/target/classes/com/etl/common/result/Result.class and b/etl-common/target/classes/com/etl/common/result/Result.class differ