hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改数据源

This commit is contained in:
lvleigang 2024-05-13 13:56:24 +08:00
parent 3e30cf0b59
commit 43af43dd24
3 changed files with 20 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
service/src/main/java/com/hzya/frame/serviceUtil/DsDataSourceUtil.java
View File

@ -7,6 +7,7 @@ import com.baomidou.dynamic.datasource.exception.CannotFindDataSourceException;
import com.hzya.frame.datasource.DataSourceUtilProperties;
import com.hzya.frame.sys.dataSource.entity.SysDataSourceEntity;
import com.hzya.frame.sysnew.application.entity.SysApplicationDatasourceDto;
import com.hzya.frame.util.AESUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@ -69,13 +70,6 @@ public class DsDataSourceUtil {
}
/****
* @Content:创建数据源，返回DruidDataSource
* @Author 👻👻👻👻👻👻👻👻 gjh
* @Date 2023-06-14 9:11
* @Param [defaultDataSourceProperties]
* @return com.alibaba.druid.pool.DruidDataSource
**/
private DruidDataSource createDefaultDataSource(JSONObject defaultDataSourceProperties) throws RuntimeException {
//根据datasource_code查询数据源配置信息
String datasource_code = String.valueOf(defaultDataSourceProperties.get("datasource_code"));

12
service/src/main/java/com/hzya/frame/sys/dataSource/entity/SysDataSourceEntity.java
View File

@ -113,7 +113,7 @@ public class SysDataSourceEntity extends BaseEntity {
}
public String getSourceUrl() {
StringBuffer sourceUrl = new StringBuffer();
if(sourceType != null) {
if(sourceType != null){
switch (sourceType) {
case "1": //oracle
//jdbc:oracle:thin:@60.204.132.91:1521:ORCL
@ -121,11 +121,15 @@ public class SysDataSourceEntity extends BaseEntity {
break;
case "2": //sqlsever
//jdbc:sqlserver://221.12.175.82:1433;DatabaseName=U8CLOUD;encrypt=false;trustServerCertificate=true
sourceUrl.append("jdbc:sqlserver://").append(sourceIp).append(":").append(sourcePort).append(";DatabaseName=").append(dbName).append(";encrypt=false;trustServerCertificate=true");
sourceUrl.append("jdbc:jtds:sqlserver://").append(sourceIp).append(":").append(sourcePort).append("/").append(dbName).append(";encrypt=false;trustServerCertificate=true");
break;
case "3": //mysql
//jdbc:mysql://hzya.ufyct.com:9096/businesscenter?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull&useSSL=false
sourceUrl.append("jdbc:mysql://").append(sourceIp).append(":").append(sourcePort).append("/").append(dbName).append("?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull&useSSL=false");
//jdbc:mysql://hzya.ufyct.com:9096/businesscenternew?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowLoadLocalInfile=false&autoReconnect=true&failOverReadOnly=false&connectTimeout=30000&socketTimeout=30000&autoReconnectForPools=true
sourceUrl.append("jdbc:mysql://").append(sourceIp).append(":").append(sourcePort).append("/").append(dbName).append("?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT%2B8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowLoadLocalInfile=false&autoReconnect=true&failOverReadOnly=false&connectTimeout=30000&socketTimeout=30000&autoReconnectForPools=true");
break;
case "4": //dm
//jdbc:dm://hzya.ufyct.com:9040?schema=businesscenter&characterEncoding=UTF-8
sourceUrl.append("jdbc:dm://").append(sourceIp).append(":").append(sourcePort).append("?schema=").append(dbName).append("&characterEncoding=UTF-8");
break;
default:
}

11
service/src/main/java/com/hzya/frame/sys/dataSource/service/impl/SysDataSourceServiceImpl.java
View File

@ -9,6 +9,7 @@ import com.hzya.frame.sys.dataSource.entity.SysDataSourceEntity;
import com.hzya.frame.sys.dataSource.dao.ISysDataSourceDao;
import com.hzya.frame.sys.dataSource.entity.SysDataSourceVo;
import com.hzya.frame.sys.dataSource.service.ISysDataSourceService;
import com.hzya.frame.util.AESUtil;
import com.hzya.frame.uuid.UUIDUtils;
import com.hzya.frame.web.entity.BaseResult;
import com.hzya.frame.web.entity.JsonResultEntity;
@ -68,6 +69,11 @@ public class SysDataSourceServiceImpl extends BaseService<SysDataSourceEntity, S
}
PageHelper.startPage(entity.getPageNum(), entity.getPageSize());
List<SysDataSourceVo> sysDataSourceEntities = sysDataSourceDao.queryVoList(entity);
if(sysDataSourceEntities != null && sysDataSourceEntities.size() > 0){
for (int i = 0; i < sysDataSourceEntities.size(); i++) {
sysDataSourceEntities.get(i).setPassword(AESUtil.decrypt(sysDataSourceEntities.get(i).getPassword()));
}
}
PageInfo pageInfo = new PageInfo(sysDataSourceEntities);
return BaseResult.getSuccessMessageEntity("查询数据成功", pageInfo);
}
@ -87,6 +93,7 @@ public class SysDataSourceServiceImpl extends BaseService<SysDataSourceEntity, S
return BaseResult.getFailureMessageEntity("请先传递请求主键");
}
SysDataSourceEntity sysDataSourceEntity = sysDataSourceDao.queryOne(entity);
sysDataSourceEntity.setPassword(AESUtil.decrypt(sysDataSourceEntity.getPassword()));
return BaseResult.getSuccessMessageEntity("查询数据成功", sysDataSourceEntity);
}
@ -124,6 +131,7 @@ public class SysDataSourceServiceImpl extends BaseService<SysDataSourceEntity, S
return BaseResult.getFailureMessageEntity("初始化数据源失败,请检查数据源配置是否正确");
}
}
entity.setPassword(AESUtil.encrypt(entity.getPassword()));
sysDataSourceDao.save(entity);
return BaseResult.getSuccessMessageEntity("保存数据源成功",entity.getId());
}
@ -181,6 +189,9 @@ public class SysDataSourceServiceImpl extends BaseService<SysDataSourceEntity, S
return BaseResult.getSuccessMessageEntity("修改数据源失败");
}
}
if(entity.getPassword() != null ){
entity.setPassword(AESUtil.encrypt(entity.getPassword()));
}
sysDataSourceDao.update(entity);
return BaseResult.getSuccessMessageEntity("修改数据源成功",entity.getId());