From 1ef8729cb6d72612ce58311e3821a53d88011060 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=80=E6=BA=90=E6=B5=B7=E5=93=A5?= Date: Sun, 30 Jul 2023 10:31:57 +0800 Subject: [PATCH] feat: updateByQuery add dynamic table support --- .../mybatisflex/core/dialect/impl/CommonsDialectImpl.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/mybatis-flex-core/src/main/java/com/mybatisflex/core/dialect/impl/CommonsDialectImpl.java b/mybatis-flex-core/src/main/java/com/mybatisflex/core/dialect/impl/CommonsDialectImpl.java index 15604172..2d7864ec 100644 --- a/mybatis-flex-core/src/main/java/com/mybatisflex/core/dialect/impl/CommonsDialectImpl.java +++ b/mybatis-flex-core/src/main/java/com/mybatisflex/core/dialect/impl/CommonsDialectImpl.java @@ -782,8 +782,12 @@ public class CommonsDialectImpl implements IDialect { Set updateColumns = tableInfo.obtainUpdateColumns(entity, ignoreNulls, true); Map rawValueMap = tableInfo.obtainUpdateRawValueMap(entity); - sql.append(UPDATE).append(forHint(CPI.getHint(queryWrapper))) - .append(tableInfo.getWrapSchemaAndTableName(this)).append(SET); + sql.append(UPDATE).append(forHint(CPI.getHint(queryWrapper))); + if (StringUtil.isNotBlank(tableInfo.getSchema())) { + sql.append(wrap(getRealSchema(tableInfo.getSchema()))).append(REFERENCE); + } + + sql.append(wrap(getRealTable(tableInfo.getTableName()))).append(SET); StringJoiner stringJoiner = new StringJoiner(DELIMITER);