From 5b61224161b99adeae58fa34803dd78a11f85be7 Mon Sep 17 00:00:00 2001
From: lwj <3529558005@qq.com>
Date: Sun, 8 Sep 2024 11:23:41 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E6=9B=B4=E6=96=B0=E8=BF=94?=
 =?UTF-8?q?=E5=9B=9E=E5=80=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../muyu/cloud/etl/service/impl/ProductServiceImpl.java  | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java
index d73c1bb..d8fb8b5 100644
--- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java
+++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java
@@ -53,7 +53,6 @@ public class ProductServiceImpl implements ProductService {
                 Connection finalConnection = connection;
                 executorService.submit(() -> {
                     try {
-
                         addCount.addAndGet(insertRow(finalConnection, tableName, dataValueList));
                     } catch (SQLException e) {
                         // 记录异常
@@ -160,20 +159,28 @@ public class ProductServiceImpl implements ProductService {
                         Object obj = value.getValue();
                         if (obj instanceof String) {
                             ps.setString(index++, (String) obj);
+                            log.info("类型为String,值{}",obj);
                         } else if (obj instanceof Integer) {
                             ps.setInt(index++, (Integer) obj);
+                            log.info("类型为Integer,值{}",obj);
                         } else if (obj instanceof Double) {
                             ps.setDouble(index++, (Double) obj);
+                            log.info("类型为Double,值{}",obj);
                         } else if (obj instanceof Date) {
                             ps.setDate(index++, new java.sql.Date(((Date) obj).getTime()));
+                            log.info("类型为Date,值{}",obj);
                         } else if (obj instanceof Boolean) {
                             ps.setBoolean(index++, (Boolean) obj);
+                            log.info("类型为Boolean,值{}",obj);
                         } else if (obj instanceof Float) {
                             ps.setFloat(index++, (Float) obj);
+                            log.info("类型为Float,值{}",obj);
                         } else if (obj instanceof Long) {
                             ps.setLong(index++, (Long) obj);
+                            log.info("类型为Long,值{}",obj);
                         } else {
                             ps.setObject(index++, obj);
+                            log.info("类型为Object,值{}",obj);
                         }
                     }
                     ps.addBatch();