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

zhangliang 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 b8c959e7286 Rename MySQLBinlogDataTypeHandler (#32542)
b8c959e7286 is described below

commit b8c959e7286ebaaf2178a20a411901de9f399136
Author: Liang Zhang <[email protected]>
AuthorDate: Fri Aug 16 00:49:39 2024 +0800

    Rename MySQLBinlogDataTypeHandler (#32542)
---
 .../pipeline/mysql/ingest/dumper/MySQLIncrementalDumper.java   |  4 ++--
 ...SQLDataTypeHandler.java => MySQLBinlogDataTypeHandler.java} |  4 ++--
 ...igintHandler.java => MySQLBinlogUnsignedBigintHandler.java} |  6 +++---
 ...ignedIntHandler.java => MySQLBinlogUnsignedIntHandler.java} |  6 +++---
 ...ntHandler.java => MySQLBinlogUnsignedMediumintHandler.java} |  6 +++---
 ...intHandler.java => MySQLBinlogUnsignedSmallintHandler.java} |  6 +++---
 ...yintHandler.java => MySQLBinlogUnsignedTinyintHandler.java} |  6 +++---
 ...peline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler} | 10 +++++-----
 .../dumper/type/impl/MySQLUnsignedBigintHandlerTest.java       |  2 +-
 .../ingest/dumper/type/impl/MySQLUnsignedIntHandlerTest.java   |  2 +-
 .../dumper/type/impl/MySQLUnsignedMediumintHandlerTest.java    |  2 +-
 .../dumper/type/impl/MySQLUnsignedSmallintHandlerTest.java     |  2 +-
 .../dumper/type/impl/MySQLUnsignedTinyintHandlerTest.java      |  2 +-
 13 files changed, 29 insertions(+), 29 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 d32dfd8fb8a..1e55688b093 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
@@ -41,7 +41,7 @@ import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.UpdateR
 import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.WriteRowsEvent;
 import org.apache.shardingsphere.data.pipeline.mysql.ingest.client.ConnectInfo;
 import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.client.MySQLBinlogClient;
-import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler;
+import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler;
 import 
org.apache.shardingsphere.db.protocol.mysql.packet.binlog.row.column.value.string.MySQLBinaryString;
 import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
 import 
org.apache.shardingsphere.infra.database.core.connector.ConnectionProperties;
@@ -199,7 +199,7 @@ public final class MySQLIncrementalDumper extends 
AbstractPipelineLifecycleRunna
                     ? ((MySQLBinaryString) value).getBytes()
                     : new String(((MySQLBinaryString) value).getBytes(), 
Charset.defaultCharset());
         }
-        Optional<MySQLDataTypeHandler> dataTypeHandler = 
TypedSPILoader.findService(MySQLDataTypeHandler.class, 
columnMetaData.getDataTypeName());
+        Optional<MySQLBinlogDataTypeHandler> dataTypeHandler = 
TypedSPILoader.findService(MySQLBinlogDataTypeHandler.class, 
columnMetaData.getDataTypeName());
         return dataTypeHandler.isPresent() ? 
dataTypeHandler.get().handle(value) : value;
     }
     
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLDataTypeHandler.java
 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLBinlogDataTypeHandler.java
similarity index 92%
rename from 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLDataTypeHandler.java
rename to 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLBinlogDataTypeHandler.java
index 8197fcb2ea6..a38baffc0e3 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLDataTypeHandler.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/MySQLBinlogDataTypeHandler.java
@@ -23,10 +23,10 @@ import 
org.apache.shardingsphere.infra.spi.type.typed.TypedSPI;
 import java.io.Serializable;
 
 /**
- * MySQL data type handler.
+ * MySQL binlog data type handler.
  */
 @SingletonSPI
-public interface MySQLDataTypeHandler extends TypedSPI {
+public interface MySQLBinlogDataTypeHandler extends TypedSPI {
     
     /**
      * Handle column value.
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedBigintHandler.java
 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedBigintHandler.java
similarity index 89%
rename from 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedBigintHandler.java
rename to 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedBigintHandler.java
index fe823fe8dff..be6b62a1715 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedBigintHandler.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedBigintHandler.java
@@ -17,15 +17,15 @@
 
 package org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl;
 
-import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler;
+import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler;
 
 import java.io.Serializable;
 import java.math.BigInteger;
 
 /**
- * MySQL unsigned bigint handler.
+ * MySQL binlog unsigned bigint data type handler.
  */
-public final class MySQLUnsignedBigintHandler implements MySQLDataTypeHandler {
+public final class MySQLBinlogUnsignedBigintHandler implements 
MySQLBinlogDataTypeHandler {
     
     private static final BigInteger BIGINT_MODULO = new 
BigInteger("18446744073709551616");
     
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedIntHandler.java
 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedIntHandler.java
similarity index 88%
rename from 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedIntHandler.java
rename to 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedIntHandler.java
index d586aca0848..88fa08c06f8 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedIntHandler.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedIntHandler.java
@@ -17,14 +17,14 @@
 
 package org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl;
 
-import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler;
+import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler;
 
 import java.io.Serializable;
 
 /**
- * MySQL unsigned int handler.
+ * MySQL binlog unsigned int data type handler.
  */
-public final class MySQLUnsignedIntHandler implements MySQLDataTypeHandler {
+public final class MySQLBinlogUnsignedIntHandler implements 
MySQLBinlogDataTypeHandler {
     
     private static final long INT_MODULO = 4294967296L;
     
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedMediumintHandler.java
 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedMediumintHandler.java
similarity index 88%
rename from 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedMediumintHandler.java
rename to 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedMediumintHandler.java
index de3875620df..2370c6c4078 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedMediumintHandler.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedMediumintHandler.java
@@ -17,14 +17,14 @@
 
 package org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl;
 
-import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler;
+import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler;
 
 import java.io.Serializable;
 
 /**
- * MySQL unsigned mediumint handler.
+ * MySQL binlog unsigned mediumint data type handler.
  */
-public final class MySQLUnsignedMediumintHandler implements 
MySQLDataTypeHandler {
+public final class MySQLBinlogUnsignedMediumintHandler implements 
MySQLBinlogDataTypeHandler {
     
     private static final int MEDIUMINT_MODULO = 16777216;
     
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedSmallintHandler.java
 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedSmallintHandler.java
similarity index 88%
rename from 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedSmallintHandler.java
rename to 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedSmallintHandler.java
index 0db5d48ace6..b0093a52909 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedSmallintHandler.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedSmallintHandler.java
@@ -17,14 +17,14 @@
 
 package org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl;
 
-import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler;
+import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler;
 
 import java.io.Serializable;
 
 /**
- * MySQL unsigned smallint handler.
+ * MySQL binlog unsigned smallint data type handler.
  */
-public final class MySQLUnsignedSmallintHandler implements 
MySQLDataTypeHandler {
+public final class MySQLBinlogUnsignedSmallintHandler implements 
MySQLBinlogDataTypeHandler {
     
     private static final int SMALLINT_MODULO = 65536;
     
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedTinyintHandler.java
 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedTinyintHandler.java
similarity index 88%
rename from 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedTinyintHandler.java
rename to 
kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedTinyintHandler.java
index 519eac3749e..d7fa713b0ef 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedTinyintHandler.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLBinlogUnsignedTinyintHandler.java
@@ -17,14 +17,14 @@
 
 package org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl;
 
-import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler;
+import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler;
 
 import java.io.Serializable;
 
 /**
- * MySQL unsigned tinyint handler.
+ * MySQL binlog unsigned tinyint data type handler.
  */
-public final class MySQLUnsignedTinyintHandler implements MySQLDataTypeHandler 
{
+public final class MySQLBinlogUnsignedTinyintHandler implements 
MySQLBinlogDataTypeHandler {
     
     private static final int TINYINT_MODULO = 256;
     
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler
 
b/kernel/data-pipeline/dialect/mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler
similarity index 84%
rename from 
kernel/data-pipeline/dialect/mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler
rename to 
kernel/data-pipeline/dialect/mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler
index 905a6ee08c6..b1056236f04 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLDataTypeHandler
+++ 
b/kernel/data-pipeline/dialect/mysql/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.MySQLBinlogDataTypeHandler
@@ -15,8 +15,8 @@
 # limitations under the License.
 #
 
-org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLUnsignedTinyintHandler
-org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLUnsignedSmallintHandler
-org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLUnsignedMediumintHandler
-org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLUnsignedIntHandler
-org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLUnsignedBigintHandler
+org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLBinlogUnsignedTinyintHandler
+org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLBinlogUnsignedSmallintHandler
+org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLBinlogUnsignedMediumintHandler
+org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLBinlogUnsignedIntHandler
+org.apache.shardingsphere.data.pipeline.mysql.ingest.dumper.type.impl.MySQLBinlogUnsignedBigintHandler
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedBigintHandlerTest.java
 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedBigintHandlerTest.java
index 0ecd0b19538..7cb60fea9fb 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedBigintHandlerTest.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedBigintHandlerTest.java
@@ -27,7 +27,7 @@ import static org.hamcrest.MatcherAssert.assertThat;
 
 class MySQLUnsignedBigintHandlerTest {
     
-    private final MySQLUnsignedBigintHandler handler = new 
MySQLUnsignedBigintHandler();
+    private final MySQLBinlogUnsignedBigintHandler handler = new 
MySQLBinlogUnsignedBigintHandler();
     
     @Test
     void assertHandle() {
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedIntHandlerTest.java
 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedIntHandlerTest.java
index 804961413a6..e2e1a9cac14 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedIntHandlerTest.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedIntHandlerTest.java
@@ -26,7 +26,7 @@ import static org.hamcrest.MatcherAssert.assertThat;
 
 class MySQLUnsignedIntHandlerTest {
     
-    private final MySQLUnsignedIntHandler handler = new 
MySQLUnsignedIntHandler();
+    private final MySQLBinlogUnsignedIntHandler handler = new 
MySQLBinlogUnsignedIntHandler();
     
     @Test
     void assertHandle() {
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedMediumintHandlerTest.java
 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedMediumintHandlerTest.java
index b1634e90667..de2b1864803 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedMediumintHandlerTest.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedMediumintHandlerTest.java
@@ -26,7 +26,7 @@ import static org.hamcrest.MatcherAssert.assertThat;
 
 class MySQLUnsignedMediumintHandlerTest {
     
-    private final MySQLUnsignedMediumintHandler handler = new 
MySQLUnsignedMediumintHandler();
+    private final MySQLBinlogUnsignedMediumintHandler handler = new 
MySQLBinlogUnsignedMediumintHandler();
     
     @Test
     void assertHandle() {
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedSmallintHandlerTest.java
 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedSmallintHandlerTest.java
index 124a5a51ec1..e9466ac048d 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedSmallintHandlerTest.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedSmallintHandlerTest.java
@@ -26,7 +26,7 @@ import static org.hamcrest.MatcherAssert.assertThat;
 
 class MySQLUnsignedSmallintHandlerTest {
     
-    private final MySQLUnsignedSmallintHandler handler = new 
MySQLUnsignedSmallintHandler();
+    private final MySQLBinlogUnsignedSmallintHandler handler = new 
MySQLBinlogUnsignedSmallintHandler();
     
     @Test
     void assertHandle() {
diff --git 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedTinyintHandlerTest.java
 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedTinyintHandlerTest.java
index 736917ed1ee..d3ff6ccc56b 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedTinyintHandlerTest.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/dumper/type/impl/MySQLUnsignedTinyintHandlerTest.java
@@ -26,7 +26,7 @@ import static org.hamcrest.MatcherAssert.assertThat;
 
 class MySQLUnsignedTinyintHandlerTest {
     
-    private final MySQLUnsignedTinyintHandler handler = new 
MySQLUnsignedTinyintHandler();
+    private final MySQLBinlogUnsignedTinyintHandler handler = new 
MySQLBinlogUnsignedTinyintHandler();
     
     @Test
     void assertHandle() {

Reply via email to