diff --git a/.idea/sqldialects.xml b/.idea/sqldialects.xml
index b5e3720..a7794c6 100644
--- a/.idea/sqldialects.xml
+++ b/.idea/sqldialects.xml
@@ -1,6 +1,6 @@
-
+
\ No newline at end of file
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index f566458..1c5cb75 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -4,9 +4,15 @@
-
+
+
+
+
+
+
+
@@ -58,7 +64,7 @@
-
+
@@ -303,7 +309,15 @@
1719538688389
-
+
+
+ 1719539540887
+
+
+
+ 1719539540887
+
+
@@ -382,7 +396,8 @@
-
+
+
diff --git a/etl-cleaning/pom.xml b/etl-cleaning/pom.xml
index 2e5c8f5..bddd3b6 100644
--- a/etl-cleaning/pom.xml
+++ b/etl-cleaning/pom.xml
@@ -19,6 +19,12 @@
2.6.13
+
+
+ redis.clients
+ jedis
+ 3.7.0
+
com.anji-plus
spring-boot-starter-captcha
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
index 5bc306b..cee3941 100644
--- 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
@@ -8,7 +8,6 @@ import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
-
import java.util.Date;
/**
@@ -44,7 +43,7 @@ public class DataPlace {
/**
* 链接状态
*/
- private Boolean statue;
+ private Long statue;
/**
* 连接类型
*/
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/InsertPlaceRequest.java b/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/InsertPlaceRequest.java
index 0e6aff7..bb09643 100644
--- a/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/InsertPlaceRequest.java
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/InsertPlaceRequest.java
@@ -36,7 +36,7 @@ public class InsertPlaceRequest {
/**
* 链接状态
*/
- private Boolean statue;
+ private Long statue;
/**
* 用户名
*/
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java b/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java
new file mode 100644
index 0000000..655a7dc
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java
@@ -0,0 +1,39 @@
+package com.etl.cleaning.domian.request;
+
+import lombok.Builder;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+
+/**
+ * redis链接参数
+ */
+@Data
+@Builder
+public class RedisRequest {
+ /**
+ * 用户名
+ */
+ @NotBlank(message = "用户名不能为空")
+ private String itemUsername;
+ /**
+ * 密码
+ */
+ @NotBlank(message = "密码不能为空")
+ private String itemPass;
+ /**
+ * 端口
+ */
+ @NotBlank(message = "端口号不能为空")
+ private String itemPort;
+ /**
+ * 连接数据库名称
+ */
+ @NotBlank(message = "数据库名称不能为空")
+ private String itemName;
+ /**
+ * 连接地址
+ */
+ @NotBlank(message = "链接地址不能为空")
+ private String place;
+}
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/domian/response/PlaceResponse.java b/etl-cleaning/src/main/java/com/etl/cleaning/domian/response/PlaceResponse.java
index 6f6b487..864cecf 100644
--- a/etl-cleaning/src/main/java/com/etl/cleaning/domian/response/PlaceResponse.java
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/domian/response/PlaceResponse.java
@@ -27,7 +27,7 @@ public class PlaceResponse {
/**
* 链接状态
*/
- private Boolean statue;
+ private Long statue;
/**
* 连接类型
*/
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/server/ServerTest.java b/etl-cleaning/src/main/java/com/etl/cleaning/server/MysqlServerTest.java
similarity index 97%
rename from etl-cleaning/src/main/java/com/etl/cleaning/server/ServerTest.java
rename to etl-cleaning/src/main/java/com/etl/cleaning/server/MysqlServerTest.java
index 054a83e..dab12d9 100644
--- a/etl-cleaning/src/main/java/com/etl/cleaning/server/ServerTest.java
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/server/MysqlServerTest.java
@@ -8,7 +8,7 @@ import org.springframework.jdbc.datasource.DriverManagerDataSource;
/**
* mysql测试连接
*/
-public class ServerTest {
+public class MysqlServerTest {
public static String testDatabaseConnection(DatabaseConfig databaseConfig) {
try {
//创建数据源
diff --git a/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java b/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java
new file mode 100644
index 0000000..f18568b
--- /dev/null
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java
@@ -0,0 +1,13 @@
+package com.etl.cleaning.server;
+
+import lombok.Builder;
+import lombok.Data;
+
+/**
+ * redis测试连接
+ */
+public class RedisServerTest {
+ public static String testRedisData(){
+
+ }
+}
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
index 9b14f5d..4712fa8 100644
--- a/etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java
+++ b/etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java
@@ -12,7 +12,7 @@ import com.etl.cleaning.domian.request.PlaceRequest;
import com.etl.cleaning.domian.response.PlaceResponse;
import com.etl.cleaning.enums.EnumMsg;
import com.etl.cleaning.mapper.PlaceMapper;
-import com.etl.cleaning.server.ServerTest;
+import com.etl.cleaning.server.MysqlServerTest;
import com.etl.cleaning.service.PlaceService;
import com.etl.cleaning.service.TypeService;
import org.apache.commons.lang3.StringUtils;
@@ -128,6 +128,6 @@ public class PlaceServiceImpl extends ServiceImpl implem
.username(mysqlRequest.getItemUsername())
.password(mysqlRequest.getItemPass())
.build();
- return ServerTest.testDatabaseConnection(databaseConfig);
+ return MysqlServerTest.testDatabaseConnection(databaseConfig);
}
}