(shardingsphere) branch master updated: Refactor MySQLIncrementalDumperTest (#28947)

[panjuan]

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

panjuan 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 0d9880a242a Refactor MySQLIncrementalDumperTest (#28947)
0d9880a242a is described below

commit 0d9880a242af7ae11505e82b9fd2b265f54a310a
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sun Nov 5 21:28:24 2023 +0800

    Refactor MySQLIncrementalDumperTest (#28947)
---
 .../data/pipeline/mysql/ingest/MySQLIncrementalDumperTest.java | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/MySQLIncrementalDumperTest.java
 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/MySQLIncrementalDumperTest.java
index 5ed2365d713..c83e3ede6d3 100644
--- 
a/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/MySQLIncrementalDumperTest.java
+++ 
b/kernel/data-pipeline/dialect/mysql/src/test/java/org/apache/shardingsphere/data/pipeline/mysql/ingest/MySQLIncrementalDumperTest.java
@@ -41,6 +41,8 @@ import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.DeleteR
 import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.PlaceholderEvent;
 import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.UpdateRowsEvent;
 import 
org.apache.shardingsphere.data.pipeline.mysql.ingest.binlog.event.WriteRowsEvent;
+import org.apache.shardingsphere.test.fixture.jdbc.MockedDriver;
+import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
@@ -78,11 +80,15 @@ class MySQLIncrementalDumperTest {
     
     private PipelineTableMetaData pipelineTableMetaData;
     
+    @BeforeAll
+    static void init() throws ClassNotFoundException {
+        Class.forName(MockedDriver.class.getName());
+    }
+    
     @BeforeEach
     void setUp() throws SQLException {
         IncrementalDumperContext dumperContext = createDumperContext();
         initTableData(dumperContext);
-        dumperContext.getCommonContext().setDataSourceConfig(new 
StandardPipelineDataSourceConfiguration("jdbc:mock://127.0.0.1:3306/test", 
"root", "root"));
         PipelineTableMetaDataLoader metaDataLoader = 
mock(PipelineTableMetaDataLoader.class);
         SimpleMemoryPipelineChannel channel = new 
SimpleMemoryPipelineChannel(10000, new EmptyAckCallback());
         incrementalDumper = new MySQLIncrementalDumper(dumperContext, new 
BinlogPosition("binlog-000001", 4L, 0L), channel, metaDataLoader);
@@ -92,7 +98,7 @@ class MySQLIncrementalDumperTest {
     
     private IncrementalDumperContext createDumperContext() {
         DumperCommonContext commonContext = new DumperCommonContext();
-        commonContext.setDataSourceConfig(new 
StandardPipelineDataSourceConfiguration("jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MySQL",
 "root", "root"));
+        commonContext.setDataSourceConfig(new 
StandardPipelineDataSourceConfiguration("jdbc:mock://127.0.0.1:3306/test", 
"root", "root"));
         commonContext.setTableNameMapper(new 
ActualAndLogicTableNameMapper(Collections.singletonMap(new 
ActualTableName("t_order"), new LogicTableName("t_order"))));
         commonContext.setTableAndSchemaNameMapper(new 
TableAndSchemaNameMapper(Collections.emptyMap()));
         return new IncrementalDumperContext(commonContext);