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 8e4776a..b14e592 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 @@ -49,15 +49,7 @@ public class ProductServiceImpl implements ProductService { try { connection = hikariDataSource.getConnection(); // 遍历外部列表 - for (DataValue[] dataValues : listList) { - log.info("bbbbbb"); - for (DataValue dataValue : dataValues) { - log.info("man{}",dataValue); - } - } - log.info("aaaaaaaaaaaaaaaaaaaaaa"); for (DataValue[] dataValueList : listList) { - log.info("便利化后的外部列表的值是{}",dataValueList.toString()); Connection finalConnection = connection; executorService.submit(() -> { try { @@ -161,37 +153,39 @@ public class ProductServiceImpl implements ProductService { // 循环设置参数并执行插入 - for (DataValue dataValue : dataValueList) { - log.info("循环的值为:"+dataValue.toString()); +// for (DataValue dataValue : dataValueList) { int index = 1; - Object obj = dataValue.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("类型为obj,值{}",obj); + for (DataValue value : dataValueList) { + 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("类型为OOO,值{}",obj); + } } - } - ps.addBatch(); + ps.addBatch(); +// } + // 执行批量插入操作 int[] ints = ps.executeBatch();