yimeng
/
ETL
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

redsi数据源添加并测试无误

ays
An Yong Shuai 2024-06-28 10:33:17 +08:00
parent eb0bfc5ed6
commit 1a92ed6566
4 changed files with 26 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
.idea/workspace.xml
View File

File diff suppressed because one or more lines are too long

3
etl-cleaning/src/main/java/com/etl/cleaning/domian/request/InsertPlaceRequest.java
View File

@ -40,12 +40,10 @@ public class InsertPlaceRequest {
/**
* 用户名
*/
@NotBlank(message = "用户名不能为空")
private String username;
/**
* 密码
*/
@NotBlank(message = "密码不能为空")
private String password;
/**
* 端口
@ -55,7 +53,6 @@ public class InsertPlaceRequest {
/**
* 数据库名称
*/
@NotBlank(message = "数据库不能为空")
private String dataName;
/**
* 额外配置

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

@ -12,11 +12,6 @@ import javax.validation.constraints.NotNull;
@Data
@Builder
public class RedisRequest {
/**
* 用户名
*/
@NotBlank(message = "用户名不能为空")
private String itemUsername;
/**
* 密码
*/

10
etl-cleaning/src/main/java/com/etl/cleaning/serviceimpl/PlaceServiceImpl.java
View File

@ -9,10 +9,12 @@ import com.etl.cleaning.domian.pojo.DateType;
import com.etl.cleaning.domian.request.InsertPlaceRequest;
import com.etl.cleaning.domian.request.MysqlRequest;
import com.etl.cleaning.domian.request.PlaceRequest;
import com.etl.cleaning.domian.request.RedisRequest;
import com.etl.cleaning.domian.response.PlaceResponse;
import com.etl.cleaning.enums.EnumMsg;
import com.etl.cleaning.mapper.PlaceMapper;
import com.etl.cleaning.server.MysqlServerTest;
import com.etl.cleaning.server.RedisServerTest;
import com.etl.cleaning.service.PlaceService;
import com.etl.cleaning.service.TypeService;
import org.apache.commons.lang3.StringUtils;
@ -97,6 +99,14 @@ public class PlaceServiceImpl extends ServiceImpl<PlaceMapper, DataPlace> implem
.build();
return this.insertItem(mysqlRequest);
}
if(dataPlace.getTypeId() == 2){
RedisRequest redisRequest = RedisRequest.builder()
.itemPass(dataPlace.getPassword())
.host(dataPlace.getDataUrl())
.port(Integer.valueOf(dataPlace.getPort()))
.build();
return RedisServerTest.testRedisData(redisRequest);
}
return "redis连接数据源失败";
}