Add unit test in GovernanceRepositoryAPIImplTest (#28747)

* Add unit test in GovernanceRepositoryAPIImplTest for persistJobOffsetInfo and getJobOffsetInfo * Fix style check
apache · Oct 15, 2023 · b8427b8 · b8427b8
1 parent 3e03fd6
commit b8427b8
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...hardingsphere/test/it/data/pipeline/core/job/service/GovernanceRepositoryAPIImplTest.java b/...hardingsphere/test/it/data/pipeline/core/job/service/GovernanceRepositoryAPIImplTest.java
@@ -147,6 +147,15 @@ void assertGetShardingItems() {
         assertThat(shardingItems.get(0), is(jobItemContext.getShardingItem()));
     }
 
+    @Test
+    void assertPersistJobOffsetInfo() {
+        assertFalse(governanceRepositoryAPI.getJobOffsetInfo("1").isPresent());
+        governanceRepositoryAPI.persistJobOffsetInfo("1", "testValue");
+        Optional<String> actual = governanceRepositoryAPI.getJobOffsetInfo("1");
+        assertTrue(actual.isPresent());
+        assertThat(actual.get(), is("testValue"));
+    }
+
     private MigrationJobItemContext mockJobItemContext() {
         MigrationJobItemContext result = PipelineContextUtils.mockMigrationJobItemContext(JobConfigurationBuilder.createJobConfiguration());
         MigrationTaskConfiguration taskConfig = result.getTaskConfig();