fix:增加api mysql等数据类型

pom.xml

@@ -138,6 +138,13 @@
             <groupId>com.zaxxer</groupId>
             <artifactId>HikariCP</artifactId>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>8.0.33</version>
+        </dependency>
+
     </dependencies>
 
     <build>

src/main/java/com/lqkj/cmlcp/module/api/domain/ApiInfo.java

@@ -1,5 +1,6 @@
 package com.lqkj.cmlcp.module.api.domain;
 
+import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
 import io.hypersistence.utils.hibernate.type.json.JsonType;
 import io.swagger.v3.oas.annotations.media.Schema;
@@ -47,10 +48,10 @@ public class ApiInfo {
     @Type(JsonType.class)
     @Column(name = "data", columnDefinition = "jsonb")
     @Schema(description = "请求体")
-    private JSONObject data;
+    private JSONArray data;
 
     @Column(name = "type")
-    @Schema(description = "api类型, 1 rest; 2 static")
+    @Schema(description = "api类型, 1 rest; 2 static; 3 直接查询数据库")
     private Integer type;
 
 }

src/main/java/com/lqkj/cmlcp/module/api/service/impl/ApiInfoServiceImpl.java

@@ -1,5 +1,7 @@
 package com.lqkj.cmlcp.module.api.service.impl;
 
+import com.alibaba.fastjson2.JSONArray;
+import com.alibaba.fastjson2.JSONObject;
 import com.lqkj.cmlcp.module.api.domain.ApiInfo;
 import com.lqkj.cmlcp.module.api.repository.ApiInfoRepository;
 import com.lqkj.cmlcp.module.api.service.ApiInfoService;
@@ -8,6 +10,10 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.Statement;
 import java.util.List;
 
 @Service
@@ -20,6 +26,7 @@ public class ApiInfoServiceImpl implements ApiInfoService {
     @Override
     @Transactional
     public void saveApi(ApiInfo apiInfo) {
+        if (apiInfo.getType().equals(3)) apiInfo.setData(null);
         apiInfoRepository.save(apiInfo);
     }
 
@@ -35,6 +42,46 @@ public class ApiInfoServiceImpl implements ApiInfoService {
 
     @Override
     public ApiInfo findById(Integer id) {
-        return apiInfoRepository.findById(id).get();
+        ApiInfo apiInfo = apiInfoRepository.findById(id).get();
+        switch (apiInfo.getType()) {
+            case 3 -> encapsuLationDbData(apiInfo);
+            case 4 -> System.out.println("暂不支持该类型");
+        }
+        return apiInfo;
+    }
+
+    private void encapsuLationDbData(ApiInfo apiInfo) {
+        if (apiInfo.getData() != null) return;
+        JSONObject params = apiInfo.getParams();
+        String url = params.get("url").toString();
+        String user = params.get("user").toString();
+        String password = params.get("password").toString();
+        try {
+            // 建立数据库连接
+            Class.forName(params.get("driver").toString());
+            Connection conn = DriverManager.getConnection(url, user, password);
+            // 创建Statement对象来执行SQL语句
+            Statement stmt = conn.createStatement();
+            // 执行查询并获取结果
+            ResultSet rs = stmt.executeQuery(params.get("sql").toString());
+            // 遍历结果集
+            JSONArray objects = new JSONArray();
+            while (rs.next()) {
+                JSONObject jsonObject = new JSONObject();
+                for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
+                    String key = rs.getMetaData().getColumnName(i);
+                    jsonObject.put(key, rs.getObject(key));
+                }
+                objects.add(jsonObject);
+            }
+            apiInfo.setData(objects);
+            // 关闭结果集、Statement和连接
+            rs.close();
+            stmt.close();
+            conn.close();
+            apiInfoRepository.save(apiInfo);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
     }
 }

src/main/resources/application-install.yml

@@ -12,22 +12,22 @@ server:
     max-swallow-size: 1000MB
     max-http-form-post-size: 1000MB
 spring:
-  data:
-    redis:
-      host: 127.0.0.1
-      database: 0
-      port: 6379
-      connect-timeout: 10s
-      lettuce:
-        pool:
-          # 连接池最大连接数
-          max-active: 200
-          # 连接池最大阻塞等待时间（使用负值表示没有限制）
-          max-wait: -1ms
-          # 连接池中的最大空闲连接
-          max-idle: 10
-          # 连接池中的最小空闲连接
-          min-idle: 0
+#  data:
+#    redis:
+#      host: 127.0.0.1
+#      database: 0
+#      port: 6379
+#      connect-timeout: 10s
+#      lettuce:
+#        pool:
+#          # 连接池最大连接数
+#          max-active: 200
+#          # 连接池最大阻塞等待时间（使用负值表示没有限制）
+#          max-wait: -1ms
+#          # 连接池中的最大空闲连接
+#          max-idle: 10
+#          # 连接池中的最小空闲连接
+#          min-idle: 0
   application:
     name: CMLCP-SERVER
   servlet: