From 21b8d7483c9f176b4fdc411fd1c2a0f957f38030 Mon Sep 17 00:00:00 2001
From: lwj <3529558005@qq.com>
Date: Tue, 10 Sep 2024 16:42:39 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/muyu/mysql/MySqlDataSource.java    | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java b/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java
index 9e6bf5a..d507e9d 100644
--- a/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java
+++ b/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java
@@ -355,9 +355,13 @@ public class MySqlDataSource extends BaseDataAbsSource {
         MySqlQuery query = getQuery();
         log.info("拿到的值query{}",query.getSql());
         Integer one = Math.toIntExact(query.getOne());
+        log.info("参数一"+one);
         Integer two = query.getTwo();
+        log.info("参数二"+two);
         String sql = query.getSql();
+        log.info("sql值"+sql);
         Long dataSourceId = query.getDataSourceId();
+        log.info("获取值"+dataSourceId);
         ConcurrentHashMap<Integer, DataValue> map = new ConcurrentHashMap<>();
         System.out.println("aaaaaaaaaaaaa-----------");
         Source dataSources = sourceRemote.findSourceById(dataSourceId);
@@ -383,7 +387,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
             int c = 0;
             while (resultSet.next()){
                 for (int i = 1; i <= columnCount; i++) {
-//                    log.info("反复循环的次数为：{}",i);
+
                     if (resultSet.isFirst()){
                         String columnTypeName = metaData.getColumnTypeName(i);
                         DatabaseMetaData metaDataColumns = conn.getMetaData();
@@ -414,9 +418,10 @@ public class MySqlDataSource extends BaseDataAbsSource {
                         dataValues[c][i-1]=build;
 
                     }
+                    log.info("反复循环的次数为：{}",i);
                 }
-                log.info("askldkjjjsk查询完毕啊{}",c);
                 c++;
+                log.info("askldkjjjsk查询完毕啊{}",c);
             }
             log.info("askldk查询完毕");
         } catch (SQLException e) {