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

测试线程池

master
陈思豪 2024-09-09 01:43:07 +08:00
parent 5c27bea894
commit 07212c55e1
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
View File

@ -190,7 +190,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("当前页为{}", i);
int pageNum = i * totalSegments;
long finalFirstArray = Math.min(pageSize, count - pageNum);
String limit = " limit " + i * pageSize + "," + pageSize;
String limit = " limit " + i + "," + pageSize;
String limitSelect = sql + limit;
Long finalDatabaseId = databaseId;
String finalSql = sql;
@ -236,10 +236,10 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
}
private void selectAndAdd(Long databaseId,Long basicId,String sql,Long tableId,
HashMap<String,String> newAndOldMap,Long firstArray ,Integer two) {
HashMap<String,String> newAndOldMap,Long finalFirstArray ,Integer two) {
log.info("开始查询数据");
log.info("数组为{}，，{}",firstArray ,two);
DataValue[][] tableValue = dataValueClient.findTableValueToArray(databaseId, sql, firstArray,two);
log.info("数组为{}，，{}",finalFirstArray ,two);
DataValue[][] tableValue = dataValueClient.findTableValueToArray(databaseId, sql, finalFirstArray,two);
log.info("远程调用完毕,调用数量{}",tableValue.length);
for (DataValue[] dataValues : tableValue) {
for (DataValue dataValue : dataValues) {