admin/mybatis-flex
1
0
Fork 0
mirror of https://gitee.com/mybatis-flex/mybatis-flex.git synced 2025-12-07 00:58:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed CommonsDialectImpl.java

Browse Source
This commit is contained in:
开源海哥 2023-03-15 14:10:05 +08:00
parent 8f359c9399
commit 73b29a2093
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
mybatis-flex-core/src/main/java/com/mybatisflex/core/dialect/CommonsDialectImpl.java
View File

@ -354,7 +354,6 @@ public class CommonsDialectImpl implements IDialect {
StringBuilder sql = new StringBuilder(); StringBuilder sql = new StringBuilder();
sql.append("INSERT INTO ").append(wrap(tableInfo.getTableName())); sql.append("INSERT INTO ").append(wrap(tableInfo.getTableName()));
String[] insertColumns = tableInfo.obtainInsertColumns(); String[] insertColumns = tableInfo.obtainInsertColumns();
Map<String, String> onInsertColumns = tableInfo.getOnInsertColumns(); Map<String, String> onInsertColumns = tableInfo.getOnInsertColumns();
@ -380,17 +379,19 @@ public class CommonsDialectImpl implements IDialect {
StringBuilder sql = new StringBuilder(); StringBuilder sql = new StringBuilder();
sql.append("INSERT INTO ").append(wrap(tableInfo.getTableName())); sql.append("INSERT INTO ").append(wrap(tableInfo.getTableName()));
String[] insertColumns = tableInfo.obtainInsertColumns(); String[] insertColumns = tableInfo.obtainInsertColumns();
String[] warpedInsertColumns = new String[insertColumns.length];
for (int i = 0; i < insertColumns.length; i++) { for (int i = 0; i < insertColumns.length; i++) {
insertColumns[i] = wrap(insertColumns[i]); warpedInsertColumns[i] = wrap(insertColumns[i]);
} }
sql.append("(").append(StringUtil.join(", ", insertColumns)).append(")"); sql.append("(").append(StringUtil.join(", ", warpedInsertColumns)).append(")");
sql.append(" VALUES "); sql.append(" VALUES ");
Map<String, String> onInsertColumns = tableInfo.getOnInsertColumns(); Map<String, String> onInsertColumns = tableInfo.getOnInsertColumns();
for (int i = 0; i < entities.size(); i++) { for (int i = 0; i < entities.size(); i++) {
StringJoiner stringJoiner = new StringJoiner(", ", "(", ")"); StringJoiner stringJoiner = new StringJoiner(", ", "(", ")");
for (String insertColumn : insertColumns) { for (String insertColumn : warpedInsertColumns) {
if (onInsertColumns != null && onInsertColumns.containsKey(insertColumn)) { if (onInsertColumns != null && onInsertColumns.containsKey(insertColumn)) {
//直接读取 onInsert 配置的值，而不用 "?" 代替
stringJoiner.add(onInsertColumns.get(insertColumn)); stringJoiner.add(onInsertColumns.get(insertColumn));
} else { } else {
stringJoiner.add("?"); stringJoiner.add("?");