From ecfa553c9855e78ad88a0ad108525265b3614bad Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=86=B7=E8=B0=83?= <3084898776@qq.com>
Date: Thu, 5 Sep 2024 17:06:45 +0800
Subject: [PATCH] =?UTF-8?q?09051706:=E4=BC=98=E5=8C=96=E8=B5=84=E4=BA=A7?=
 =?UTF-8?q?=E5=B1=95=E7=A4=BA=E7=9A=84=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/inspectionProfiles/Project_Default.xml  |  7 ++++
 .../controller/DataValueController.java       |  1 -
 .../com/muyu/source/mysql/ThreadQuery.java    | 39 +++++++++++++++++++
 .../service/Impl/DataSourceServiceImpl.java   | 23 -----------
 .../service/Impl/DataValueServiceImpl.java    |  2 -
 5 files changed, 46 insertions(+), 26 deletions(-)
 create mode 100644 muyu-source-server/src/main/java/com/muyu/source/mysql/ThreadQuery.java

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 @@
   <profile version="1.0">
     <option name="myName" value="Project Default" />
     <inspection_tool class="AliAccessStaticViaInstance" enabled="true" level="WARNING" enabled_by_default="true" />
+    <inspection_tool class="AliArrayNamingShouldHaveBracket" enabled="true" level="WARNING" enabled_by_default="true" />
+    <inspection_tool class="AliControlFlowStatementWithoutBraces" enabled="true" level="WARNING" enabled_by_default="true" />
     <inspection_tool class="AliDeprecation" enabled="true" level="WARNING" enabled_by_default="true" />
+    <inspection_tool class="AliEqualsAvoidNull" enabled="true" level="WARNING" enabled_by_default="true" />
+    <inspection_tool class="AliLongLiteralsEndingWithLowercaseL" enabled="true" level="WARNING" enabled_by_default="true" />
+    <inspection_tool class="AliMissingOverrideAnnotation" enabled="true" level="WARNING" enabled_by_default="true" />
+    <inspection_tool class="AliWrapperTypeEquality" enabled="true" level="WARNING" enabled_by_default="true" />
     <inspection_tool class="AlibabaAbstractClassShouldStartWithAbstractNaming" enabled="true" level="WARNING" enabled_by_default="true" />
     <inspection_tool class="AlibabaAbstractMethodOrInterfaceMethodMustUseJavadoc" enabled="true" level="WARNING" enabled_by_default="true" />
     <inspection_tool class="AlibabaAvoidApacheBeanUtilsCopy" enabled="true" level="WARNING" enabled_by_default="true" />
@@ -57,5 +63,6 @@
     <inspection_tool class="AlibabaUnsupportedExceptionWithModifyAsList" enabled="true" level="WARNING" enabled_by_default="true" />
     <inspection_tool class="AlibabaUseQuietReferenceNotation" enabled="true" level="WARNING" enabled_by_default="true" />
     <inspection_tool class="AlibabaUseRightCaseForDateFormat" enabled="true" level="WARNING" enabled_by_default="true" />
+    <inspection_tool class="MapOrSetKeyShouldOverrideHashCodeEquals" enabled="true" level="WARNING" enabled_by_default="true" />
   </profile>
 </component>
\ 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<DataValue> 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<List> {
+    //查询条件 根据条件来定义该类的属性
+    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<DataSourceMapper, DataSou
             ps = conn.prepareStatement(SELECTFIELD+"WHERE  \n" +
                     "TABLE_SCHEMA = '" + databaseName + "'   \n" +
                             "AND TABLE_NAME = '" + table.getTableName() + "'");
-//            ps = conn.prepareStatement("    SELECT  " +
-//                    "    COLUMN_NAME , " +
-//                    "    COLUMN_COMMENT  ," +
-//                    "    CASE WHEN COLUMN_KEY = 'PRI' THEN '是' ELSE '否' END ," +
-//                    "    CASE \n" +
-//                    "    WHEN DATA_TYPE = 'int' THEN 'Integer' " +
-//                    "    WHEN DATA_TYPE = 'bigint' THEN 'Long' " +
-//                    "    WHEN DATA_TYPE = 'varchar' THEN 'String' " +
-//                    "    WHEN DATA_TYPE = 'decimal' THEN 'BigDecimal' " +
-//                    "    WHEN DATA_TYPE = 'tinyint' AND COLUMN_TYPE = 'tinyint(1)' THEN 'Boolean'" +
-//                    "    ELSE DATA_TYPE   \n" +
-//                    "    END , " +
-//                    "    DATA_TYPE ,   \n" +
-//                    "    COLUMN_TYPE ,  \n" +
-//                    "    CHARACTER_MAXIMUM_LENGTH ,  \n" +
-//                    "    NUMERIC_SCALE ,  \n" +
-//                    "    IS_NULLABLE ,  \n" +
-//                    "    COLUMN_DEFAULT   \n" +
-//                    "FROM  INFORMATION_SCHEMA.COLUMNS  WHERE  \n" +
-//                    "TABLE_SCHEMA = '" + databaseName + "'   \n" +
-//                    "AND TABLE_NAME = '" + table.getTableName() + "'");
-
-
             ResultSet resultSet = ps.executeQuery();
             while (resultSet.next()) {
                 String columnName = String.valueOf(resultSet.getString(1));
diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataValueServiceImpl.java b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataValueServiceImpl.java
index cab51b1..13afbe4 100644
--- a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataValueServiceImpl.java
+++ b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataValueServiceImpl.java
@@ -57,7 +57,6 @@ public class DataValueServiceImpl extends ServiceImpl<DataValueMapper, DataValue
                     String remarks =null;
                     while (columns.next()){
                         remarks = columns.getString("REMARKS");
-
                     }
                     DataValue build = DataValue.builder()
                             .key(metaData.getColumnName(i))
@@ -66,7 +65,6 @@ public class DataValueServiceImpl extends ServiceImpl<DataValueMapper, DataValue
                             .type(DataType.convertTypeString(columnTypeName))
                             .build();
                     dataValueList.add(build);
-
                 }
             }
         } catch (SQLException e) {