TreeData
/
cloud-etl-source
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

数据添加更改

master
lwj 2024-09-08 16:55:19 +08:00
parent 150ddb1e70
commit 9d9d421bc0
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java
View File

@ -246,19 +246,20 @@ public class ProductServiceImpl implements ProductService {
log.info("陈思豪是傻逼"+columns); log.info("陈思豪是傻逼"+columns);
// 删除最后一个逗号和空格 // 删除最后一个逗号和空格
columns.delete(columns.length() - 2, columns.length()); columns.delete(columns.length() - 2, columns.length());
int count=0;
// 构建值部分 // 构建值部分
for (DataValue[] dataValueList : batch) { for (DataValue[] dataValueList : batch) {
values.append("("); values.append("(");
for (DataValue dataValue : dataValueList) { for (DataValue dataValue : dataValueList) {
Object value = dataValue.getValue(); Object value = dataValue.getValue();
values.append(formatValue(dataValue.getType(), value)).append(", "); values.append(formatValue(dataValue.getType(), value)).append(", ");
log.info("值{{{{aaaaaa}}}}}}}}}"+value); log.info("值{{{{aaaaaa}}}}}}}}}"+count+"+个数+"+value);
} }
values.delete(values.length() - 2, values.length()); values.delete(values.length() - 2, values.length());
values.append("), "); values.append("), ");
} }
values.delete(values.length() - 2, values.length()); values.delete(values.length() - 2, values.length());
log.info("值++++++++++++++++++++++++++++++++++++++++++++++++++++++++"+values.toString()); log.info("值++++++++++++++++++++++++++++++++++++++++++++++++++++++++"+values.toString());
// 完成 SQL 插入语句 // 完成 SQL 插入语句