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();