redis链接代码

.idea/workspace.xml

@@ -4,15 +4,10 @@
     <option name="autoReloadType" value="SELECTIVE" />
   </component>
   <component name="ChangeListManager">
-    <list default="true" id="e53020f6-f301-415a-a26a-d22b9ac05907" name="更改" comment="测试连接成功">
+    <list default="true" id="e53020f6-f301-415a-a26a-d22b9ac05907" name="更改" comment="redis连接参数设置">
-      <change afterPath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/.idea/sqldialects.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/sqldialects.xml" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DataPlace.java" beforeDir="false" afterPath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/domian/pojo/DataPlace.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java" beforeDir="false" afterPath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/InsertPlaceRequest.java" beforeDir="false" afterPath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/domian/request/InsertPlaceRequest.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java" beforeDir="false" afterPath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/domian/response/PlaceResponse.java" beforeDir="false" afterPath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/domian/response/PlaceResponse.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/server/ServerTest.java" beforeDir="false" afterPath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/server/MysqlServerTest.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java" beforeDir="false" afterPath="$PROJECT_DIR$/etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -109,6 +104,9 @@
     <key name="MoveFile.RECENT_KEYS">
       <recent name="D:\workspace\ETL\etl-cleaning\src\main\resources\images\jigsaw" />
     </key>
+    <key name="CopyClassDialog.RECENTS_KEY">
+      <recent name="com.etl.cleaning.domian.request" />
+    </key>
   </component>
   <component name="RunAnythingCache">
     <myKeys>
@@ -203,7 +201,7 @@
       <workItem from="1719316378874" duration="2751000" />
       <workItem from="1719362671659" duration="17607000" />
       <workItem from="1719448230070" duration="12317000" />
-      <workItem from="1719534377253" duration="5937000" />
+      <workItem from="1719534377253" duration="6553000" />
     </task>
     <task id="LOCAL-00001" summary="安勇帅提交测试">
       <option name="closed" value="true" />
@@ -317,7 +315,23 @@
       <option name="project" value="LOCAL" />
       <updated>1719539540887</updated>
     </task>
-    <option name="localTasksCounter" value="15" />
+    <task id="LOCAL-00015" summary="redis连接参数设置">
+      <option name="closed" value="true" />
+      <created>1719540603770</created>
+      <option name="number" value="00015" />
+      <option name="presentableId" value="LOCAL-00015" />
+      <option name="project" value="LOCAL" />
+      <updated>1719540603770</updated>
+    </task>
+    <task id="LOCAL-00016" summary="redis连接参数设置">
+      <option name="closed" value="true" />
+      <created>1719540643218</created>
+      <option name="number" value="00016" />
+      <option name="presentableId" value="LOCAL-00016" />
+      <option name="project" value="LOCAL" />
+      <updated>1719540643218</updated>
+    </task>
+    <option name="localTasksCounter" value="17" />
     <servers />
   </component>
   <component name="TypeScriptGeneratedFilesManager">
@@ -397,7 +411,8 @@
     <MESSAGE value="数据源详情架构搭建" />
     <MESSAGE value="添加数据源参数类" />
     <MESSAGE value="测试连接成功" />
-    <option name="LAST_COMMIT_MESSAGE" value="测试连接成功" />
+    <MESSAGE value="redis连接参数设置" />
+    <option name="LAST_COMMIT_MESSAGE" value="redis连接参数设置" />
   </component>
   <component name="XSLT-Support.FileAssociations.UIState">
     <expand />

etl-cleaning/src/main/java/com/etl/cleaning/domian/request/RedisRequest.java

@@ -4,6 +4,7 @@ import lombok.Builder;
 import lombok.Data;
 
 import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
 
 /**
  * redis链接参数
@@ -24,16 +25,11 @@ public class RedisRequest {
     /**
      * 端口
      */
-    @NotBlank(message = "端口号不能为空")
+    @NotNull(message = "端口号不能为空")
-    private String itemPort;
+    private Integer port;
-    /**
-     * 连接数据库名称
-     */
-    @NotBlank(message = "数据库名称不能为空")
-    private String itemName;
     /**
      * 连接地址
      */
     @NotBlank(message = "链接地址不能为空")
-    private String place;
+    private String host;
 }

etl-cleaning/src/main/java/com/etl/cleaning/server/RedisServerTest.java

@@ -1,11 +1,35 @@
 package com.etl.cleaning.server;
 
+import com.etl.cleaning.domian.request.RedisRequest;
 import lombok.Builder;
 import lombok.Data;
+import redis.clients.jedis.Jedis;
 
 /**
  * redis测试连接
  */
 public class RedisServerTest {
+    public static String testRedisData(RedisRequest redisRequest){
+        try {
+            // 创建Jedis对象（Redis客户端）
+            Jedis jedis = new Jedis(redisRequest.getHost(), redisRequest.getPort());
+            // 如果设置了密码，则进行认证
+            if (redisRequest.getItemPass() != null && !redisRequest.getItemPass().isEmpty()) {
+                jedis.auth(redisRequest.getItemPass());
+            }
+            // 测试连接是否成功，可以执行一个简单的命令，如ping
+            String response = jedis.ping();
+            if ("PONG".equals(response)) {
+                // 连接成功
+                return "ok";
+            } else {
+                // 连接失败或其他错误
+                return "error";
+            }
+        } catch (Exception e){
+            e.printStackTrace();
+            return "error";
+        }
 
+    }
 }