Skip to content

Commit 7ad4881

Browse files
committed
Refactor DatabaseRulePersistService
1 parent 9ee9b17 commit 7ad4881

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/version/MetaDataVersionPersistServiceTest.java

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717

1818
package org.apache.shardingsphere.mode.metadata.persist.version;
1919

20-
import org.apache.shardingsphere.infra.metadata.version.MetaDataVersion;
2120
import org.apache.shardingsphere.mode.spi.repository.PersistRepository;
2221
import org.junit.jupiter.api.BeforeEach;
2322
import org.junit.jupiter.api.Test;
@@ -30,6 +29,8 @@
3029

3130
import static org.hamcrest.CoreMatchers.is;
3231
import static org.hamcrest.MatcherAssert.assertThat;
32+
import static org.mockito.ArgumentMatchers.any;
33+
import static org.mockito.Mockito.times;
3334
import static org.mockito.Mockito.verify;
3435
import static org.mockito.Mockito.when;
3536

@@ -47,9 +48,16 @@ void setUp() {
4748
}
4849

4950
@Test
50-
void assertSwitchActiveVersion() {
51+
void assertSwitchActiveVersionWithCreate() {
52+
persistService.switchActiveVersion("foo_db", 0);
53+
verify(repository).persist("foo_db/active_version", "0");
54+
verify(repository, times(0)).delete(any());
55+
}
56+
57+
@Test
58+
void assertSwitchActiveVersionWithAlter() {
5159
when(repository.getChildrenKeys("foo_db/versions")).thenReturn(Arrays.asList("1", "0"));
52-
persistService.switchActiveVersion(Arrays.asList(new MetaDataVersion("foo_db", 0, 1), new MetaDataVersion("bar_db", 2, 2)));
60+
persistService.switchActiveVersion("foo_db", 1);
5361
verify(repository).persist("foo_db/active_version", "1");
5462
verify(repository).delete("foo_db/versions/0");
5563
}

0 commit comments

Comments
 (0)