From 2f3a48bb44ded1255c6140d67592c5c31f863a27 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B0=91=E5=B9=B4=E6=A2=A6=E4=B8=8E=E7=A0=96?=
 <2847127106@qq.com>
Date: Wed, 4 Sep 2024 18:01:05 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=20=E6=96=B0=E5=A2=9ESQL?=
 =?UTF-8?q?=E8=AF=AD=E5=8F=A5=E6=89=A7=E8=A1=8C=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../source/controller/DataValueController.java   | 13 +++++++++++++
 .../muyu/source/service/DataValueService.java    |  2 ++
 .../service/Impl/DataValueServiceImpl.java       | 16 ++++++++++++++++
 3 files changed, 31 insertions(+)

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 2c21d0d..e7bf9c2 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
@@ -40,6 +40,19 @@ public class DataValueController {
         return Result.success(dataValueList);
     }
 
+    /**
+     * 根据基础表ID和SQL语句查询数据
+     *
+     * @param dataValueModel 基础表ID和sql语句
+     * @return DataValue{kltv}
+     */
+    @PostMapping("/addTableValue")
+    @Operation(summary = "根据基础表ID和SQL语句新增数据", description = "根据基础表ID和SQL语句新增数据")
+    public Result addTableValue(@RequestBody DataValueModel dataValueModel) {
+        Integer i = dataValueService.addTableValue(dataValueModel);
+        return Result.success(i);
+    }
+
     /**
      * 根据基础表ID和表名查询数据
      *
diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/DataValueService.java b/muyu-source-server/src/main/java/com/muyu/source/service/DataValueService.java
index a5d39f5..0721665 100644
--- a/muyu-source-server/src/main/java/com/muyu/source/service/DataValueService.java
+++ b/muyu-source-server/src/main/java/com/muyu/source/service/DataValueService.java
@@ -18,4 +18,6 @@ public interface DataValueService extends IService<DataValue> {
     List<DataValue> findTableValue(DataValueModel dataValueModel);
 
     List<DataValue> findTableValueByTableName(Long basicId, String tableName);
+
+    Integer addTableValue(DataValueModel dataValueModel);
 }
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 24adc33..cab51b1 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
@@ -121,4 +121,20 @@ public class DataValueServiceImpl extends ServiceImpl<DataValueMapper, DataValue
         mysqlPool.closeConn();
         return list;
     }
+
+    @Override
+    public Integer addTableValue(DataValueModel dataValueModel) {
+        MysqlQuery mysqlQuery = new MysqlQuery();
+        mysqlQuery.setDataSourceId(String.valueOf(dataValueModel.getBasicId()));
+        DataSource dataSource = dataSourceService.getById(dataValueModel.getBasicId());
+        MysqlPool mysqlPool = new MysqlPool(dataSource);
+        mysqlPool.init();
+        Connection conn = mysqlPool.getConn();
+        try {
+            PreparedStatement preparedStatement = conn.prepareStatement(dataValueModel.getSql());
+            return preparedStatement.executeUpdate();
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+    }
 }