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 5a048e1..d79e5ec 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 @@ -229,7 +229,7 @@ public class ProductServiceImpl implements ProductService { private String buildBatchInsertSQL(String tableName, DataValue[][] batch) { - log.info("陈思豪是傻逼"+tableName); + StringBuilder columns = new StringBuilder("("); StringBuilder values = new StringBuilder("VALUES "); // 构建字段名 @@ -237,6 +237,7 @@ public class ProductServiceImpl implements ProductService { String key = dataValue.getKey(); columns.append(key).append(", "); } + log.info("陈思豪是傻逼"+columns); // 删除最后一个逗号和空格 columns.delete(columns.length() - 2, columns.length()); @@ -245,12 +246,15 @@ public class ProductServiceImpl implements ProductService { values.append("("); for (DataValue dataValue : dataValueList) { Object value = dataValue.getValue(); + log.info("值{{{{{{{{{{}}}}}}}}}}"+value); values.append(formatValue(dataValue.getType(), value)).append(", "); } values.delete(values.length() - 2, values.length()); values.append("), "); } + values.delete(values.length() - 2, values.length()); + log.info("值++++++++++++++++++++++++++++++++++++++++++++++++++++++++"+values.toString()); // 完成 SQL 插入语句 String sql = "INSERT INTO " + tableName + " " + columns.toString() + ") " + values.toString(); log.info("执行的sql添加的sql语句"+sql);