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

测试线程池

master
陈思豪 2024-09-10 14:38:57 +08:00
parent 15737e4452
commit 92edeba812
4 changed files with 64 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cloud-task-common/pom.xml
View File

@ -33,15 +33,16 @@
<dependency> <dependency>
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId> <artifactId>cloud-etl-common</artifactId>
<version>1.0.0</version> <version>1.0.1</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId> <artifactId>cloud-common-etl</artifactId>
<version>1.0.1</version> <version>1.0.0</version>
</dependency> </dependency>
</dependencies> </dependencies>
</project> </project>

7
cloud-task-remote/pom.xml
View File

@ -23,6 +23,13 @@
<artifactId>cloud-task-common</artifactId> <artifactId>cloud-task-common</artifactId>
<version>1.0.0</version> <version>1.0.0</version>
</dependency> </dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-etl</artifactId>
<version>1.0.0</version>
<scope>compile</scope>
</dependency>
</dependencies> </dependencies>
</project> </project>

42
cloud-task-server/pom.xml
View File

@ -78,6 +78,18 @@
<version>1.0.0</version> <version>1.0.0</version>
</dependency> </dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-client</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-etl</artifactId>
<version>1.0.0</version>
</dependency>
<!-- XllJob定时任务 --> <!-- XllJob定时任务 -->
@ -86,6 +98,36 @@
<artifactId>cloud-common-xxl</artifactId> <artifactId>cloud-common-xxl</artifactId>
<version>3.6.3</version> <version>3.6.3</version>
</dependency> </dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.1</version>
<scope>compile</scope>
</dependency>
</dependencies> </dependencies>
<build> <build>

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

@ -7,6 +7,8 @@ import com.muyu.common.core.utils.StringUtils;
import com.muyu.domain.*; import com.muyu.domain.*;
import com.muyu.domain.req.TaskInfoReq; import com.muyu.domain.req.TaskInfoReq;
import com.muyu.mapper.TaskMapper; import com.muyu.mapper.TaskMapper;
import com.muyu.mysql.MySqlDataSource;
import com.muyu.mysql.MySqlQuery;
import com.muyu.service.*; import com.muyu.service.*;
import com.muyu.task.PriorityThreadPool; import com.muyu.task.PriorityThreadPool;
import com.muyu.task.feign.DataValueClient; import com.muyu.task.feign.DataValueClient;
@ -251,8 +253,8 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
return "success"; return "success";
} }
// @Resource @Resource
// private Mysql 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,
@ -261,11 +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()); mySqlDataSource.setQuery(MySqlQuery.builder().dataSourceId(databaseId).sql(sql).one(finalFirstArray).two(two).build());
// com.muyu.access.data.base.DataValue[][] rows = mySqlDataSource.getRows(); Object query = mySqlDataSource.getQuery();
Result<DataValue[][]> result = dataValueClient.findTableValueToArray(databaseId, sql, finalFirstArray, two); log.info("aaaaa",query);
DataValue[][] dataValues = mySqlDataSource.getRows();
log.info("okl");
// 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);