(shardingsphere) branch master updated: Add more test cases on ConsistencyCheckJobExecutorCallbackTest (#37100)

[zhangliang]

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 75bacda9532 Add more test cases on 
ConsistencyCheckJobExecutorCallbackTest (#37100)
75bacda9532 is described below

commit 75bacda95322f4bcbee8404a9256c2241ec5ac07
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Fri Nov 14 19:02:45 2025 +0800

    Add more test cases on ConsistencyCheckJobExecutorCallbackTest (#37100)
---
 .../ConsistencyCheckJobExecutorCallbackTest.java   | 22 ++++++++++++++++++++++
 1 file changed, 22 insertions(+)

diff --git 
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/ConsistencyCheckJobExecutorCallbackTest.java
 
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/ConsistencyCheckJobExecutorCallbackTest.java
index 32c4db66fd4..1cf7ce12d18 100644
--- 
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/ConsistencyCheckJobExecutorCallbackTest.java
+++ 
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/ConsistencyCheckJobExecutorCallbackTest.java
@@ -27,11 +27,15 @@ import 
org.apache.shardingsphere.data.pipeline.core.job.id.PipelineJobIdUtils;
 import 
org.apache.shardingsphere.data.pipeline.core.job.progress.ConsistencyCheckJobItemProgress;
 import 
org.apache.shardingsphere.data.pipeline.core.job.progress.yaml.config.YamlConsistencyCheckJobItemProgress;
 import 
org.apache.shardingsphere.data.pipeline.core.job.service.PipelineJobItemManager;
+import 
org.apache.shardingsphere.data.pipeline.core.task.runner.PipelineTasksRunner;
 import 
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.config.ConsistencyCheckJobConfiguration;
 import 
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.config.yaml.config.YamlConsistencyCheckJobConfiguration;
 import 
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.config.yaml.swapper.YamlConsistencyCheckJobConfigurationSwapper;
 import 
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.context.ConsistencyCheckJobItemContext;
+import 
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.task.ConsistencyCheckTasksRunner;
+import org.apache.shardingsphere.database.connector.core.type.DatabaseType;
 import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
+import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
 import 
org.apache.shardingsphere.test.it.data.pipeline.core.util.JobConfigurationBuilder;
 import 
org.apache.shardingsphere.test.it.data.pipeline.core.util.PipelineContextUtils;
@@ -41,13 +45,19 @@ import org.junit.jupiter.api.Test;
 import java.util.Collections;
 import java.util.List;
 import java.util.Optional;
+import java.util.Properties;
 import java.util.stream.Collectors;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.is;
+import static org.hamcrest.Matchers.instanceOf;
+import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.mockito.Mockito.mock;
 
 class ConsistencyCheckJobExecutorCallbackTest {
     
+    private final DatabaseType databaseType = 
TypedSPILoader.getService(DatabaseType.class, "Fixture");
+    
     @BeforeAll
     static void beforeClass() {
         PipelineContextUtils.initPipelineContextManager();
@@ -74,6 +84,18 @@ class ConsistencyCheckJobExecutorCallbackTest {
         }
     }
     
+    @Test
+    void assertBuildTasksRunner() {
+        ConsistencyCheckJobConfiguration jobConfig = new 
ConsistencyCheckJobConfiguration("check_job", "parent_job", "DATA_MATCH", new 
Properties(), databaseType);
+        PipelineTasksRunner actual = new 
ConsistencyCheckJobExecutorCallback().buildTasksRunner(new 
ConsistencyCheckJobItemContext(jobConfig, 0, JobStatus.RUNNING, null));
+        assertThat(actual, instanceOf(ConsistencyCheckTasksRunner.class));
+    }
+    
+    @Test
+    void assertPrepare() {
+        assertDoesNotThrow(() -> new 
ConsistencyCheckJobExecutorCallback().prepare(mock()));
+    }
+    
     private YamlTableCheckRangePosition createYamlTableCheckRangePosition() {
         YamlTableCheckRangePosition result = new YamlTableCheckRangePosition();
         result.setSplittingItem(0);