This is an automated email from the ASF dual-hosted git repository.
menghaoranss 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 0a3ca50776f Correct version persistence logic for standalone mode
(#39244)
0a3ca50776f is described below
commit 0a3ca50776f1afb0fdea663d7543c36101677fcc
Author: Haoran Meng <[email protected]>
AuthorDate: Mon Jul 27 15:30:17 2026 +0800
Correct version persistence logic for standalone mode (#39244)
---
.../metadata/persist/config/database/DatabaseRulePersistService.java | 2 +-
.../persist/config/database/DatabaseRulePersistServiceTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/config/database/DatabaseRulePersistService.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/config/database/DatabaseRulePersistService.java
index 39641d8b6a8..6557b2a8b6a 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/config/database/DatabaseRulePersistService.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/config/database/DatabaseRulePersistService.java
@@ -114,7 +114,7 @@ public final class DatabaseRulePersistService {
private Collection<MetaDataVersion> persistTuples(final
Collection<RuleNodeTuple> tuples) {
return tuples.stream().map(each -> new
MetaDataVersion(each.getNodePath(),
- Math.max(MetaDataVersion.INIT_VERSION,
versionPersistService.persist(new VersionNodePath(each.getNodePath()),
each.getContent()) - 1))).collect(Collectors.toList());
+ versionPersistService.persist(new
VersionNodePath(each.getNodePath()),
each.getContent()))).collect(Collectors.toList());
}
/**
diff --git
a/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/config/database/DatabaseRulePersistServiceTest.java
b/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/config/database/DatabaseRulePersistServiceTest.java
index 4275549bbe0..4475389c3d4 100644
---
a/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/config/database/DatabaseRulePersistServiceTest.java
+++
b/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/config/database/DatabaseRulePersistServiceTest.java
@@ -82,7 +82,7 @@ class DatabaseRulePersistServiceTest {
when(repository.getChildrenKeys("/metadata/foo_db/rules/fixture/unique/versions")).thenReturn(Collections.singletonList("10"));
Collection<MetaDataVersion> actual = persistService.persist("foo_db",
Collections.singleton(new MockedRuleConfiguration("test")));
assertThat(actual.size(), is(1));
- assertThat(actual.iterator().next().getActiveVersion(), is(10));
+ assertThat(actual.iterator().next().getActiveVersion(), is(11));
}
@Test