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 169317804d7 Add test cases for GlobalRulePersistService (#19355)
169317804d7 is described below
commit 169317804d7876bc395821bbab456bf70a2960c6
Author: Runqi Zhao <[email protected]>
AuthorDate: Tue Jul 19 18:12:13 2022 +0800
Add test cases for GlobalRulePersistService (#19355)
* Add test cases for GlobalRulePersistService
* fix ci
---
.../global/GlobalRulePersistServiceTest.java | 65 ++++++++++++++++++++++
1 file changed, 65 insertions(+)
diff --git
a/shardingsphere-mode/shardingsphere-mode-core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/service/config/global/GlobalRulePersistServiceTest.java
b/shardingsphere-mode/shardingsphere-mode-core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/service/config/global/GlobalRulePersistServiceTest.java
new file mode 100644
index 00000000000..a296698bc77
--- /dev/null
+++
b/shardingsphere-mode/shardingsphere-mode-core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/service/config/global/GlobalRulePersistServiceTest.java
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.shardingsphere.mode.metadata.persist.service.config.global;
+
+import lombok.SneakyThrows;
+import org.apache.shardingsphere.infra.config.RuleConfiguration;
+import org.apache.shardingsphere.infra.metadata.user.ShardingSphereUser;
+import org.apache.shardingsphere.mode.persist.PersistRepository;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mock;
+import org.mockito.junit.MockitoJUnitRunner;
+
+import java.io.IOException;
+import java.net.URISyntaxException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.Collection;
+import java.util.stream.Collectors;
+
+import static org.hamcrest.CoreMatchers.is;
+import static org.junit.Assert.assertThat;
+import static org.mockito.Mockito.when;
+
+@RunWith(MockitoJUnitRunner.class)
+public class GlobalRulePersistServiceTest {
+
+ @Mock
+ private PersistRepository repository;
+
+ @Test
+ public void assertLoad() {
+ when(repository.get("/rules")).thenReturn(readYAML());
+ Collection<RuleConfiguration> actual = new
GlobalRulePersistService(repository).load();
+ assertThat(actual.size(), is(1));
+ }
+
+ @Test
+ public void assertLoadUsers() {
+ when(repository.get("/rules")).thenReturn(readYAML());
+ Collection<ShardingSphereUser> actual = new
GlobalRulePersistService(repository).loadUsers();
+ assertThat(actual.size(), is(2));
+ }
+
+ @SneakyThrows({IOException.class, URISyntaxException.class})
+ private String readYAML() {
+ return
Files.readAllLines(Paths.get(ClassLoader.getSystemResource("yaml/persist/data-global-rule.yaml").toURI()))
+ .stream().map(each -> each +
System.lineSeparator()).collect(Collectors.joining());
+ }
+}
