Merge branch 'master' of https://gitea.qinmian.online/2112A-ONE/muyu-source

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和表名查询数据
      *

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);
 }

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);
+        }
+    }
 }