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

测试线程池

master
陈思豪 2024-09-10 16:31:22 +08:00
parent 4bfcadc8ea
commit 3796a03d46
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -253,8 +253,8 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
return "success"; return "success";
} }
// @Resource @Resource
// private MySqlDataSource mySqlDataSource; private MySqlDataSource mySqlDataSource;
@NotNull @NotNull
private void selectAndAdd(Long databaseId, Long basicId, String sql, Long tableId, private void selectAndAdd(Long databaseId, Long basicId, String sql, Long tableId,
@ -268,14 +268,14 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
mySqlQuery.setSql(sql); mySqlQuery.setSql(sql);
mySqlQuery.setOne(finalFirstArray); mySqlQuery.setOne(finalFirstArray);
mySqlQuery.setTwo(two); mySqlQuery.setTwo(two);
// mySqlDataSource.setQuery(MySqlQuery.builder().dataSourceId(basicId).sql(sql).one(finalFirstArray).two(two).build()); mySqlDataSource.setQuery(MySqlQuery.builder().dataSourceId(basicId).sql(sql).one(finalFirstArray).two(two).build());
// log.info("传过去的值是{}",mySqlDataSource.getQuery().toString()); log.info("传过去的值是{}",mySqlDataSource.getQuery().toString());
// DataValue[][] dataValues = mySqlDataSource.getRows(); DataValue[][] dataValues = mySqlDataSource.getRows();
log.info("okl"); log.info("okl");
Result<DataValue[][]> result = dataValueClient.findTableValueToArray(databaseId, sql, finalFirstArray, two); // Result<DataValue[][]> result = dataValueClient.findTableValueToArray(databaseId, sql, finalFirstArray, two);
log.info("调用完毕拿到值"); // log.info("调用完毕拿到值");
DataValue[][] dataValues = result.getData(); // DataValue[][] dataValues = result.getData();
System.out.println("aaa" + dataValues.length); System.out.println("aaa" + dataValues.length);
System.out.println("aaa" + dataValues.length); System.out.println("aaa" + dataValues.length);
System.out.println("aaa" + dataValues.length); System.out.println("aaa" + dataValues.length);