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 16:49:45 UTC
(shardingsphere) branch master updated: Rename MySQLBinlogDataTypeHandler (#32542)
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 <zh...@apache.org>
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() {