a_bazu
/
cloud-property
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fine:()类型转换

master
Yueng 2024-08-31 01:19:37 +08:00
parent 1f780b3626
commit 541c95ed82
5 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cloud-property-server/src/main/java/com/muyu/server/controller/DataRunNameController.java
View File

@ -66,8 +66,8 @@ public class DataRunNameController {
*/
@PostMapping("/findTableValue")
@Operation(summary = "获取数据库名",description = "返回所有数据库以及所有表的结果集")
public Result<List<DataValue>> findTableValue(@RequestParam(name = "basicId") String basicId){
public Result<List<DataValue>> findTableValue(@RequestParam(name = "basicId") String basicId,@RequestParam(name = "dataName") String dataName){
return Result.success(dataRunNameService.findTableValue(basicId));
return Result.success(dataRunNameService.findTableValue(basicId,dataName));
}
}

2
cloud-property-server/src/main/java/com/muyu/server/service/DataRunNameService.java
View File

@ -38,5 +38,5 @@ public interface DataRunNameService {
* @param basicId 数据类型转换ID
* @return 返回结果
*/
List<DataValue> findTableValue(String basicId);
List<DataValue> findTableValue(String basicId, String dataName);
}

3
cloud-property-server/src/main/java/com/muyu/server/service/impl/DataNameServiceImpl.java
View File

@ -39,7 +39,8 @@ public class DataNameServiceImpl
public List<DataName> extractDataName() {
String sql = null;
DruidDataSource druidDataSource = JdbcHelper.getConnRs();
String dataName= "core_data_warehouse";
DruidDataSource druidDataSource = JdbcHelper.getConnRs(dataName);
sql = "SHOW DATABASES;";
try {
assert druidDataSource != null;

4
cloud-property-server/src/main/java/com/muyu/server/service/impl/DataRunNameServiceImpl.java
View File

@ -153,11 +153,11 @@ public class DataRunNameServiceImpl implements DataRunNameService {
* @return 返回结果
*/
@Override
public List<DataValue> findTableValue(String basicId) {
public List<DataValue> findTableValue(String basicId, String dataName) {
MySqlQuery mySqlQuery = new MySqlQuery();
mySqlQuery.setDataSourceId(String.valueOf(basicId));
DruidDataSource connRs1 = JdbcHelper.getConnRs();
DruidDataSource connRs1 = JdbcHelper.getConnRs(dataName);
DruidPooledConnection conn = null;
try {
conn = connRs1.getConnection();

4
cloud-property-server/src/main/java/com/muyu/server/util/JdbcHelper.java
View File

@ -54,11 +54,11 @@ public class JdbcHelper {
* 查询服务器上说有数据库名 连接池
* @return
*/
public static DruidDataSource getConnRs() {
public static DruidDataSource getConnRs(String dataName) {
try {
DruidDataSource druidDataSource = new DruidDataSource();
druidDataSource.setUrl("jdbc:mysql://21.12.0.10:3306/core_data_warehouse?useUnicode=true&characterEncoding" +
druidDataSource.setUrl("jdbc:mysql://21.12.0.10:3306/"+dataName+"?useUnicode=true&characterEncoding" +
"=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8");
druidDataSource.setUsername("root");
druidDataSource.setPassword("Bwie-8666");