You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2024/08/15 13:18:38 UTC
(shardingsphere) branch master updated: Refactor MySQLIncrementalDumper (#32537)
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 <zh...@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);
}