TreeData
/
cloud-etl-source
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改返回值操作

master
lwj 2024-08-30 09:37:05 +08:00
parent db933679ac
commit dc073bf778
3 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/DataValueController.java
View File

@ -25,7 +25,7 @@ public class DataValueController {
//获取字段值
@PostMapping("/findTableValueList")
public Result findTableValueList(@RequestParam("basicId") Long basicId,@RequestParam("tableName") String tableName ) {
List<List<DataValue>> list= dataValueService.findTableValueList(basicId,tableName);
List<DataValue> list= dataValueService.findTableValueList(basicId,tableName);
return Result.success(list);
}
}

2
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/DataValueService.java
View File

@ -7,5 +7,5 @@ import java.util.List;
public interface DataValueService {
List< List<DataValue> >findTableValue(Long basicId, String sql);
List<List<DataValue>> findTableValueList(Long basicId, String tableName);
List<DataValue> findTableValueList(Long basicId, String tableName);
}

11
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/DataValueServiceImpl.java
View File

@ -77,7 +77,7 @@ public class DataValueServiceImpl implements DataValueService {
}
@Override
public List<List<DataValue>> findTableValueList(Long basicId, String tableName) {
public List<DataValue> findTableValueList(Long basicId, String tableName) {
Source source = sourceService.getInfo(basicId);
String host = source.getHost();
String port = source.getPort();
@ -86,11 +86,10 @@ public class DataValueServiceImpl implements DataValueService {
String url = "jdbc:" + databaseType + "://" + host + ":" + port + "/" + databaseName + "?" + source.getConnectionParams();
String user = source.getUsername();
String password = source.getPassword();
List<List<DataValue>> list = new ArrayList<>();
Connection conn=null;
try {
ArrayList<DataValue> dataValues = new ArrayList<>();
try {
conn = DriverManager.getConnection(url, user, password);
try {
PreparedStatement preparedStatement = conn.prepareStatement("SELECT * FROM " + tableName);
@ -120,7 +119,7 @@ public class DataValueServiceImpl implements DataValueService {
.build();
dataValues.add(build);
}
list.add(dataValues);
}
} catch (SQLException e) {
throw new RuntimeException(e);
@ -130,6 +129,6 @@ public class DataValueServiceImpl implements DataValueService {
}
return list;
return dataValues;
}
}