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

Reply via email to