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

修改添加

master
lwj 2024-09-08 20:35:10 +08:00
parent de02ef51d2
commit 0aa9df6313
1 changed files with 37 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -421,6 +421,37 @@ public class ProductServiceImpl implements ProductService {
}
private String buildBatchInsertSQL(String tableName, DataValue[][] batch) {
// StringBuilder columns = new StringBuilder("(");
// StringBuilder values = new StringBuilder("VALUES ");
//
// // 构建字段名
// for (DataValue dataValue : batch[0]) {
// String key = dataValue.getKey();
// columns.append(key).append(", ");
// }
//
// // 删除最后一个逗号和空格
// columns.delete(columns.length() - 2, columns.length());
//
// // 构建值部分
// for (DataValue[] dataValueList : batch) {
// values.append("(");
// for (DataValue dataValue : dataValueList) {
// Object value = dataValue.getValue();
// values.append("?, "); // 使用占位符
// }
// values.delete(values.length() - 2, values.length());
// values.append("), ");
// }
//
// values.delete(values.length() - 2, values.length());
// // 完成 SQL 插入语句
// String sql = "INSERT INTO " + tableName + " " + columns.toString() + " )" + values.toString() + ");";
// log.info("执行的sql添加的sql语句: {}", sql);
// return sql;
StringBuilder columns = new StringBuilder("(");
StringBuilder values = new StringBuilder("VALUES ");
@ -436,17 +467,18 @@ public class ProductServiceImpl implements ProductService {
// 构建值部分
for (DataValue[] dataValueList : batch) {
values.append("(");
for (DataValue dataValue : dataValueList) {
Object value = dataValue.getValue();
values.append("?, "); // 使用占位符
for (int i = 0; i < dataValueList.length; i++) {
if (i > 0) {
values.append(", ");
}
values.append("?"); // 使用占位符
}
values.delete(values.length() - 2, values.length());
values.append("), ");
}
values.delete(values.length() - 2, values.length());
// 完成 SQL 插入语句
String sql = "INSERT INTO " + tableName + " " + columns.toString() + " )" + values.toString() + ");";
String sql = "INSERT INTO " + tableName + " " + columns.toString() + " " + values.toString() + ")";
log.info("执行的sql添加的sql语句: {}", sql);
return sql;
}