[shardingsphere] branch master updated: fix 18744 (#18878)

[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 0101e7b6fc5 fix 18744 (#18878)
0101e7b6fc5 is described below

commit 0101e7b6fc597c30456c3cbc2d41a172f64a3f4a
Author: Da Xiang Huang <localhos...@foxmail.com>
AuthorDate: Wed Jul 6 14:07:23 2022 +0800

    fix 18744 (#18878)
---
 .../database/ShardingSphereDatabaseTest.java       | 31 ++++++++++++++++++----
 1 file changed, 26 insertions(+), 5 deletions(-)

diff --git 
a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/database/ShardingSphereDatabaseTest.java
 
b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/database/ShardingSphereDatabaseTest.java
index 17bfe39e042..c48aa11efdb 100644
--- 
a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/database/ShardingSphereDatabaseTest.java
+++ 
b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/database/ShardingSphereDatabaseTest.java
@@ -17,20 +17,29 @@
 
 package org.apache.shardingsphere.infra.metadata.database;
 
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.mock;
+import java.util.Collection;
+import java.util.Collections;
+import org.apache.shardingsphere.infra.config.mode.ModeConfiguration;
 import org.apache.shardingsphere.infra.database.type.DatabaseType;
+import org.apache.shardingsphere.infra.instance.ComputeNodeInstance;
+import org.apache.shardingsphere.infra.instance.InstanceContext;
+import 
org.apache.shardingsphere.infra.instance.fixture.WorkerIdGeneratorFixture;
+import org.apache.shardingsphere.infra.instance.metadata.InstanceMetaData;
+import org.apache.shardingsphere.infra.lock.LockContext;
 import 
org.apache.shardingsphere.infra.metadata.database.resource.ShardingSphereResource;
 import 
org.apache.shardingsphere.infra.metadata.database.rule.ShardingSphereRuleMetaData;
 import org.apache.shardingsphere.infra.rule.ShardingSphereRule;
 import org.apache.shardingsphere.test.mock.MockedDataSource;
 import org.junit.Test;
 
-import java.util.Collections;
+public final class ShardingSphereDatabaseTest {
 
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-import static org.mockito.Mockito.mock;
+    private final ModeConfiguration modeConfig = new 
ModeConfiguration("Memory", null, false);
 
-public final class ShardingSphereDatabaseTest {
+    private final LockContext lockContext = mock(LockContext.class);
     
     @Test
     public void assertIsComplete() {
@@ -52,4 +61,16 @@ public final class ShardingSphereDatabaseTest {
         ShardingSphereRuleMetaData ruleMetaData = new 
ShardingSphereRuleMetaData(Collections.singleton(mock(ShardingSphereRule.class)));
         assertFalse(new ShardingSphereDatabase("foo_db", 
mock(DatabaseType.class), resource, ruleMetaData, 
Collections.emptyMap()).isComplete());
     }
+
+    @Test
+    public void assertReloadRules() {
+        ShardingSphereResource resource = new 
ShardingSphereResource(Collections.singletonMap("ds", new MockedDataSource()));
+        ShardingSphereRuleMetaData ruleMetaData = new 
ShardingSphereRuleMetaData(Collections.emptyList());
+        InstanceContext context = new InstanceContext(new 
ComputeNodeInstance(mock(InstanceMetaData.class)), new 
WorkerIdGeneratorFixture(Long.MIN_VALUE), modeConfig, lockContext);
+        ShardingSphereDatabase sphereDatabase = new 
ShardingSphereDatabase("foo_db", mock(DatabaseType.class), resource, 
ruleMetaData, Collections.emptyMap());
+        Collection<ShardingSphereRule> rules = 
sphereDatabase.getRuleMetaData().getRules();
+        assertTrue(rules.isEmpty());
+        sphereDatabase.reloadRules(context);
+        assertFalse(rules.isEmpty());
+    }
 }