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 3f4c11cdb1e Add YamlProxyConfigurationCheckerTest (#37473)
3f4c11cdb1e is described below
commit 3f4c11cdb1e7c044e27d3441083b33dd4e648dd4
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Dec 23 18:25:07 2025 +0800
Add YamlProxyConfigurationCheckerTest (#37473)
---
.../checker/YamlProxyConfigurationCheckerTest.java | 54 ++++++++++++++++++++++
1 file changed, 54 insertions(+)
diff --git
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/config/checker/YamlProxyConfigurationCheckerTest.java
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/config/checker/YamlProxyConfigurationCheckerTest.java
new file mode 100644
index 00000000000..e5eab20128b
--- /dev/null
+++
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/config/checker/YamlProxyConfigurationCheckerTest.java
@@ -0,0 +1,54 @@
+/*
+ * 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.proxy.backend.config.checker;
+
+import
org.apache.shardingsphere.infra.exception.kernel.metadata.resource.storageunit.DuplicateStorageUnitException;
+import
org.apache.shardingsphere.proxy.backend.config.yaml.YamlProxyDataSourceConfiguration;
+import
org.apache.shardingsphere.proxy.backend.config.yaml.YamlProxyDatabaseConfiguration;
+import org.junit.jupiter.api.Test;
+
+import java.util.Collections;
+import java.util.Map;
+
+import static org.hamcrest.CoreMatchers.is;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+final class YamlProxyConfigurationCheckerTest {
+
+ @Test
+ void assertCheckDataSourcesWithoutDuplicates() {
+ Map<String, YamlProxyDataSourceConfiguration> globalDataSources =
Collections.singletonMap("global_ds", new YamlProxyDataSourceConfiguration());
+ YamlProxyDatabaseConfiguration databaseConfig = new
YamlProxyDatabaseConfiguration();
+ databaseConfig.setDatabaseName("foo_db");
+ databaseConfig.setDataSources(Collections.singletonMap("db_ds", new
YamlProxyDataSourceConfiguration()));
+ assertDoesNotThrow(() ->
YamlProxyConfigurationChecker.checkDataSources(globalDataSources,
Collections.singleton(databaseConfig)));
+ }
+
+ @Test
+ void assertCheckDataSourcesWithDuplicates() {
+ Map<String, YamlProxyDataSourceConfiguration> globalDataSources =
Collections.singletonMap("ds_0", new YamlProxyDataSourceConfiguration());
+ YamlProxyDatabaseConfiguration databaseConfig = new
YamlProxyDatabaseConfiguration();
+ databaseConfig.setDatabaseName("foo_db");
+ databaseConfig.setDataSources(Collections.singletonMap("ds_0", new
YamlProxyDataSourceConfiguration()));
+ DuplicateStorageUnitException ex =
assertThrows(DuplicateStorageUnitException.class,
+ () ->
YamlProxyConfigurationChecker.checkDataSources(globalDataSources,
Collections.singleton(databaseConfig)));
+ assertThat(ex.getMessage(), is("Duplicate storage unit names 'ds_0' on
database 'foo_db'."));
+ }
+}
