(shardingsphere) branch master updated: Add more test cases on StatisticsCollectJobWorkerTest (#38256)

[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 eacdedfef7f Add more test cases on StatisticsCollectJobWorkerTest 
(#38256)
eacdedfef7f is described below

commit eacdedfef7f85761b36d23ae7e1c8fc836701429
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Fri Feb 27 23:50:51 2026 +0800

    Add more test cases on StatisticsCollectJobWorkerTest (#38256)
---
 .../collect/StatisticsCollectJobWorkerTest.java    | 30 +++++++++++++++++++---
 1 file changed, 27 insertions(+), 3 deletions(-)

diff --git 
a/kernel/schedule/core/src/test/java/org/apache/shardingsphere/schedule/core/job/statistics/collect/StatisticsCollectJobWorkerTest.java
 
b/kernel/schedule/core/src/test/java/org/apache/shardingsphere/schedule/core/job/statistics/collect/StatisticsCollectJobWorkerTest.java
index e72a7e8e856..1938784bf27 100644
--- 
a/kernel/schedule/core/src/test/java/org/apache/shardingsphere/schedule/core/job/statistics/collect/StatisticsCollectJobWorkerTest.java
+++ 
b/kernel/schedule/core/src/test/java/org/apache/shardingsphere/schedule/core/job/statistics/collect/StatisticsCollectJobWorkerTest.java
@@ -56,6 +56,7 @@ import static org.mockito.Mockito.doThrow;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.mockConstruction;
 import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.verifyNoInteractions;
 import static org.mockito.Mockito.when;
 
 @ExtendWith(MockitoExtension.class)
@@ -190,24 +191,47 @@ class StatisticsCollectJobWorkerTest {
     }
     
     @Test
-    void assertDestroy() {
-        jobWorker.destroy();
+    void assertDestroyWhenNotInitialized() {
+        ScheduleJobBootstrap scheduleJobBootstrap = 
mock(ScheduleJobBootstrap.class);
+        CoordinatorRegistryCenter registryCenter = 
mock(CoordinatorRegistryCenter.class);
+        setStaticField("scheduleJobBootstrap", scheduleJobBootstrap);
+        setStaticField("registryCenter", registryCenter);
+        setStaticField("contextManager", contextManager);
         jobWorker.destroy();
-        assertNull(getScheduleJobBootstrap());
+        verifyNoInteractions(scheduleJobBootstrap, registryCenter);
+        assertThat(getScheduleJobBootstrap(), is(scheduleJobBootstrap));
+        assertThat(getRegistryCenter(), is(registryCenter));
+        assertThat(getContextManager(), is(contextManager));
     }
     
     @Test
     void assertDestroyWhenInitialized() {
         ScheduleJobBootstrap scheduleJobBootstrap = 
mock(ScheduleJobBootstrap.class);
+        CoordinatorRegistryCenter registryCenter = 
mock(CoordinatorRegistryCenter.class);
         setStaticField("scheduleJobBootstrap", scheduleJobBootstrap);
+        setStaticField("registryCenter", registryCenter);
+        setStaticField("contextManager", contextManager);
         workerInitialized.set(true);
         jobWorker.destroy();
         verify(scheduleJobBootstrap).shutdown();
+        verify(registryCenter).close();
         assertNull(getScheduleJobBootstrap());
+        assertNull(getRegistryCenter());
+        assertNull(getContextManager());
     }
     
     @SneakyThrows(ReflectiveOperationException.class)
     private ScheduleJobBootstrap getScheduleJobBootstrap() {
         return (ScheduleJobBootstrap) 
Plugins.getMemberAccessor().get(StatisticsCollectJobWorker.class.getDeclaredField("scheduleJobBootstrap"),
 StatisticsCollectJobWorker.class);
     }
+    
+    @SneakyThrows(ReflectiveOperationException.class)
+    private CoordinatorRegistryCenter getRegistryCenter() {
+        return (CoordinatorRegistryCenter) 
Plugins.getMemberAccessor().get(StatisticsCollectJobWorker.class.getDeclaredField("registryCenter"),
 StatisticsCollectJobWorker.class);
+    }
+    
+    @SneakyThrows(ReflectiveOperationException.class)
+    private ContextManager getContextManager() {
+        return (ContextManager) 
Plugins.getMemberAccessor().get(StatisticsCollectJobWorker.class.getDeclaredField("contextManager"),
 StatisticsCollectJobWorker.class);
+    }
 }