From a58867b9041d8163909ac2b34938634b8c875c10 Mon Sep 17 00:00:00 2001
From: Yueng <14617246+YuengMeYuuer@user.noreply.gitee.com>
Date: Tue, 10 Sep 2024 17:47:48 +0800
Subject: [PATCH] =?UTF-8?q?fix:()=20=E4=BC=98=E5=8C=96=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E8=B0=83=E5=8A=A8=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../muyu/server/controller/DataLinkController.java    |  6 +++---
 .../java/com/muyu/server/service/DataLinkService.java |  4 ++--
 .../muyu/server/service/impl/DataLinkServiceImpl.java | 11 +++++++++--
 3 files changed, 14 insertions(+), 7 deletions(-)

diff --git a/cloud-property-server/src/main/java/com/muyu/server/controller/DataLinkController.java b/cloud-property-server/src/main/java/com/muyu/server/controller/DataLinkController.java
index b92e0f7..b192cbb 100644
--- a/cloud-property-server/src/main/java/com/muyu/server/controller/DataLinkController.java
+++ b/cloud-property-server/src/main/java/com/muyu/server/controller/DataLinkController.java
@@ -39,15 +39,15 @@ public class DataLinkController {
     /**
      * 查询表数据count
      * @param basicDataName 数据库名称
-     * @param tableName sql语句
+     * @param targetTableName sql语句
      * @param listList sql语句
      * @return 反护试图
      */
     @PostMapping("/addProduct")
-    public Result addProduct(@RequestParam("basicDataName") String basicDataName, @RequestParam("tableName") String tableName, @RequestBody DataValue[][] listList){
+    public Result addProduct(@RequestParam("basicDataName") String basicDataName, @RequestParam("targetTableName") String targetTableName, @RequestBody DataValue[][] listList){
         long begin = System.currentTimeMillis();
 
-        int i = dataLinkService.addProduct(basicDataName,tableName,listList);
+        int i = dataLinkService.addProduct(basicDataName,targetTableName,listList);
 
 
         long end = System.currentTimeMillis();
diff --git a/cloud-property-server/src/main/java/com/muyu/server/service/DataLinkService.java b/cloud-property-server/src/main/java/com/muyu/server/service/DataLinkService.java
index 3a9f59c..47709cf 100644
--- a/cloud-property-server/src/main/java/com/muyu/server/service/DataLinkService.java
+++ b/cloud-property-server/src/main/java/com/muyu/server/service/DataLinkService.java
@@ -62,9 +62,9 @@ public interface DataLinkService {
     /**
      * 查询表数据count
      * @param basicDataName 数据库名称
-     * @param tableName sql语句
+     * @param targetTableName sql语句
      * @param listList sql语句
      * @return 反护试图
      */
-    int addProduct(String basicDataName, String tableName, DataValue[]... listList);
+    int addProduct(String basicDataName, String targetTableName, DataValue[]... listList);
 }
diff --git a/cloud-property-server/src/main/java/com/muyu/server/service/impl/DataLinkServiceImpl.java b/cloud-property-server/src/main/java/com/muyu/server/service/impl/DataLinkServiceImpl.java
index 30a8da4..b83c3ca 100644
--- a/cloud-property-server/src/main/java/com/muyu/server/service/impl/DataLinkServiceImpl.java
+++ b/cloud-property-server/src/main/java/com/muyu/server/service/impl/DataLinkServiceImpl.java
@@ -131,9 +131,16 @@ public class DataLinkServiceImpl implements DataLinkService {
         return tableFieList;
     }
 
+    /**
+     * 添加方法
+     * @param databaseName 数据库名称
+     * @param targetTableName sql语句
+     * @param listList sql语句
+     * @return
+     */
     @Override
     @Log(title = "添加产品数据库", businessType = BusinessType.INSERT)
-    public int addProduct(String databaseName, String tableName, DataValue[]... listList) {
+    public int addProduct(String databaseName, String targetTableName, DataValue[]... listList) {
 
         Connect connect = connectService.selectData(databaseName);
 
@@ -162,7 +169,7 @@ public class DataLinkServiceImpl implements DataLinkService {
             for (DataValue[][] batch : batches) {
                 executorService.submit(() -> {
                     try (Statement stmt = conn.createStatement()) {
-                        String sql = buildBatchInsertSQL(tableName, batch);
+                        String sql = buildBatchInsertSQL(targetTableName, batch);
                         stmt.executeUpdate(sql);
                         addCount.addAndGet(batch.length);
                     } catch (SQLException e) {