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

寻找报错

master
Cui YongXing 2024-09-05 21:01:54 +08:00
parent de82ad0c00
commit 18084a5839
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -299,6 +299,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
String sqlSelect = " SELECT " + fieName + " FROM " + joint +" limit "+pageNum +","+PAGE_SIZE; String sqlSelect = " SELECT " + fieName + " FROM " + joint +" limit "+pageNum +","+PAGE_SIZE;
log.info(sqlSelect); log.info(sqlSelect);
log.info("执行{}查询的方法",sqlSelect);
Result<DataValue[][]> tableValueResult = datasourceFeign.findTableValueToArray(basicId, sqlSelect); Result<DataValue[][]> tableValueResult = datasourceFeign.findTableValueToArray(basicId, sqlSelect);
DataValue[][] data = tableValueResult.getData(); DataValue[][] data = tableValueResult.getData();
for (DataValue[] datum : data) { for (DataValue[] datum : data) {
@ -308,9 +309,10 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
dataValue.setKey(newKey); dataValue.setKey(newKey);
} }
} }
log.info("查询结束");
log.info("执行{}添加的方法",sqlSelect);
Result result = datasourceFeign.addProduct(newBasicId, tableId, data); Result result = datasourceFeign.addProduct(newBasicId, tableId, data);
log.info(result); log.info("添加结束");
// for (List<DataValue> dataValues : tableValue) { // for (List<DataValue> dataValues : tableValue) {
// for (DataValue dataValue : dataValues) { // for (DataValue dataValue : dataValues) {
// String key = dataValue.getKey(); // String key = dataValue.getKey();