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

测试线程池

master
陈思豪 2024-09-10 15:32:23 +08:00
parent 92edeba812
commit 812c19109e
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -263,9 +263,14 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("sql{}", sql); log.info("sql{}", sql);
log.info("数组为{}，，{}", finalFirstArray, two); log.info("数组为{}，，{}", finalFirstArray, two);
log.info("开始远调"); log.info("开始远调");
mySqlDataSource.setQuery(MySqlQuery.builder().dataSourceId(databaseId).sql(sql).one(finalFirstArray).two(two).build()); MySqlQuery mySqlQuery = new MySqlQuery();
Object query = mySqlDataSource.getQuery(); mySqlQuery.setDataSourceId(databaseId);
log.info("aaaaa",query); mySqlQuery.setSql(sql);
mySqlQuery.setOne(finalFirstArray);
mySqlQuery.setTwo(two);
mySqlDataSource.setQuery(mySqlQuery);
MySqlQuery query = mySqlDataSource.getQuery();
log.info("aaaaa",query.getSql());
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);