From d9b49f0afc4f0e3513fde7f6bc558f0628901921 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com>
Date: Tue, 10 Sep 2024 16:04:56 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/muyu/mysql/MySqlDataSource.java      | 7 +++++--
 1 file changed, 5 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 a7c55bd..adc89e8 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
@@ -351,7 +351,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
     //壮法
     @Override
     public DataValue[][] getRows () {
-        log.info("数据源开始调用111");
+        log.info("数据源开始aaazz调用111");
         MySqlQuery query = getQuery();
         log.info("拿到的值query{}",query.getSql());
         Integer one = Math.toIntExact(query.getOne());
@@ -383,12 +383,14 @@ 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();
                         ResultSet columns = metaDataColumns.getColumns(null, null, metaData.getTableName(i), metaData.getColumnName(i));
                         String remarks =null;
 
+
                         while (columns.next()){
                             remarks = columns.getString("REMARKS");
 
@@ -412,9 +414,10 @@ public class MySqlDataSource extends BaseDataAbsSource {
                         dataValues[c][i-1]=build;
                     }
                 }
+                log.info("askldkjjjsk查询完毕啊{}",c);
                 c++;
             }
-
+            log.info("askldk查询完毕");
         } catch (SQLException e) {
             throw new RuntimeException(e);
         }finally {