opt

apache · Feb 7, 2023 · 4ea0066 · 4ea0066
1 parent 34f3ee6
commit 4ea0066
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/rm-datasource/src/main/java/io/seata/rm/datasource/exec/UpdateExecutor.java b/rm-datasource/src/main/java/io/seata/rm/datasource/exec/UpdateExecutor.java
@@ -124,23 +124,23 @@ private String buildAfterImageSQL(TableMeta tableMeta, TableRecords beforeImage)
         return selectSQLJoiner.toString();
     }
 
-    protected List<String> getNeedUpdateColumns(String table, String tableAlias, List<String> originUpdateColumns) {
+    protected List<String> getNeedUpdateColumns(String table, String tableAlias, List<String> unescapeUpdateColumns) {
         List<String> needUpdateColumns = new ArrayList<>();
         TableMeta tableMeta = getTableMeta(table);
         if (ONLY_CARE_UPDATE_COLUMNS) {
-            if (!containsPK(table, originUpdateColumns)) {
+            if (!containsPK(table, unescapeUpdateColumns)) {
                 List<String> pkNameList = tableMeta.getEscapePkNameList(getDbType());
                 if (CollectionUtils.isNotEmpty(pkNameList)) {
                     needUpdateColumns.add(getColumnNamesWithTablePrefix(table,tableAlias,pkNameList));
                 }
             }
-            needUpdateColumns.addAll(originUpdateColumns.parallelStream()
+            needUpdateColumns.addAll(unescapeUpdateColumns.parallelStream()
                 .map(originUpdateColumn -> ColumnUtils.addEscape(originUpdateColumn, getDbType()))
                 .collect(Collectors.toList()));
 
             // The on update xxx columns will be auto update by db, so it's also the actually updated columns
             List<String> onUpdateColumns = tableMeta.getOnUpdateColumnsOnlyName();
-            onUpdateColumns.removeAll(originUpdateColumns);
+            onUpdateColumns.removeAll(unescapeUpdateColumns);
             needUpdateColumns.addAll(onUpdateColumns.parallelStream()
                 .map(onUpdateColumn -> ColumnUtils.addEscape(onUpdateColumn, getDbType()))
                 .collect(Collectors.toList()));