(shardingsphere) branch master updated: Refactor MySQLIncrementalDumper (#32537)

[zhonghongsheng]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 23e7fffee4a Refactor MySQLIncrementalDumper (#32537)
23e7fffee4a is described below

commit 23e7fffee4a3035faee5a568af040eb8e5828dc8
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Thu Aug 15 21:18:31 2024 +0800

    Refactor MySQLIncrementalDumper (#32537)
---
 .../data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
index 263d7dd9ac3..41b62f392e5 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java
@@ -169,11 +169,11 @@ public final class MySQLIncrementalDumper extends 
AbstractPipelineLifecycleRunna
             Serializable[] afterValues = event.getAfterRows().get(i);
             DataRecord dataRecord = 
createDataRecord(PipelineSQLOperationType.UPDATE, event, beforeValues.length);
             for (int j = 0; j < beforeValues.length; j++) {
-                Serializable oldValue = beforeValues[j];
-                Serializable newValue = afterValues[j];
-                boolean updated = !Objects.deepEquals(newValue, oldValue);
                 PipelineColumnMetaData columnMetaData = 
tableMetaData.getColumnMetaData(j + 1);
-                dataRecord.addColumn(new Column(columnMetaData.getName(), 
handleValue(columnMetaData, oldValue), handleValue(columnMetaData, newValue), 
updated, columnMetaData.isUniqueKey()));
+                Serializable oldValue = handleValue(columnMetaData, 
beforeValues[j]);
+                Serializable newValue = handleValue(columnMetaData, 
afterValues[j]);
+                boolean updated = !Objects.deepEquals(newValue, oldValue);
+                dataRecord.addColumn(new Column(columnMetaData.getName(), 
oldValue, newValue, updated, columnMetaData.isUniqueKey()));
             }
             result.add(dataRecord);
         }