From 886e768c368f0970f72550127801e67d3f736668 Mon Sep 17 00:00:00 2001
From: lwj <3529558005@qq.com>
Date: Mon, 9 Sep 2024 02:13:44 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=9F=A5=E8=AF=A2=E8=AF=AD?=
 =?UTF-8?q?=E5=8F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../muyu/cloud/etl/mysql/MySqlDataSource.java  | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
index 9c0cb26..a1d940b 100644
--- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
+++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
@@ -129,10 +129,10 @@ public class MySqlDataSource extends BaseDataAbsSource {
                                 .build();
                         map.put(i,build);
 
-     if (c <= one && i <= columnCount) {
-        dataValues[c - 1][i - 1] = build;
-    }
-//                        dataValues[c][i-1]=build;
+//     if (c <= one && i <= columnCount) {
+//        dataValues[c - 1][i - 1] = build;
+//    }
+                        dataValues[c][i-1]=build;
                     }else {
 
                         DataValue build = DataValue.builder()
@@ -141,16 +141,16 @@ public class MySqlDataSource extends BaseDataAbsSource {
                                 .value(resultSet.getObject(i, map.get(i).getType().getTargetType()))
                                 .type(map.get(i).getType())
                                 .build();
-//                        dataValues[c][i-1]=build;
+                        dataValues[c][i-1]=build;
                               if (c <= one && i <= columnCount) {
                                 dataValues[c - 1][i - 1] = build;
                             }
                     }
                 }
-         if (c <= one) {
-        c++;
-    }
-//                c++;
+//         if (c <= one) {
+//        c++;
+//    }
+                c++;
             }
         } catch (SQLException e) {
             throw new RuntimeException(e);