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

数据添加更改

master
lwj 2024-09-08 16:45:14 +08:00
parent af270c644b
commit f66e715855
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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