diff --git a/.idea/inspectionProfiles/Project_Default.xml b/.idea/inspectionProfiles/Project_Default.xml index 5db292a..ee9f695 100644 --- a/.idea/inspectionProfiles/Project_Default.xml +++ b/.idea/inspectionProfiles/Project_Default.xml @@ -2,7 +2,13 @@ \ No newline at end of file diff --git a/muyu-source-server/src/main/java/com/muyu/source/controller/DataValueController.java b/muyu-source-server/src/main/java/com/muyu/source/controller/DataValueController.java index e7bf9c2..0ae149b 100644 --- a/muyu-source-server/src/main/java/com/muyu/source/controller/DataValueController.java +++ b/muyu-source-server/src/main/java/com/muyu/source/controller/DataValueController.java @@ -66,5 +66,4 @@ public class DataValueController { List dataValueList = dataValueService.findTableValueByTableName(basicId, tableName); return Result.success(dataValueList); } - } diff --git a/muyu-source-server/src/main/java/com/muyu/source/mysql/ThreadQuery.java b/muyu-source-server/src/main/java/com/muyu/source/mysql/ThreadQuery.java new file mode 100644 index 0000000..57470df --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/mysql/ThreadQuery.java @@ -0,0 +1,39 @@ +package com.muyu.source.mysql; + + +import java.util.List; +import java.util.concurrent.Callable; + +/** + * @author Lenovo + * @ Tool:IntelliJ IDEA + * @ Author:CHX + * @ Date:2024-09-05-15:09 + * @ Version:1.0 + * @ Description:线程 Callable 创建任务 + */ +public class ThreadQuery implements Callable { + //查询条件 根据条件来定义该类的属性 + private String search; + //当前页数 + private int pageNum; + //每页查询多少条 + private int pageSize; + //要查询的表名,也可以写死,也可以从前面传 + private String table; + //每次分页查出来的数据 + private List page; + + public ThreadQuery(int pageNum, int pageSize, String table){ + this.pageNum = pageNum; + this.pageSize = pageSize; + this.table = table; + //分页查询数据库数据 查出对应的数据 + page = null; + + } + @Override + public List call() throws Exception { + return page; + } +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java index 0b08b2f..50ec25b 100644 --- a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java +++ b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java @@ -248,29 +248,6 @@ public class DataSourceServiceImpl extends ServiceImpl