You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by me...@apache.org on 2021/09/01 11:11:40 UTC
[shardingsphere] branch master updated: remove
shardingsphere-jdbc-governance-spring module (#12150)
This is an automated email from the ASF dual-hosted git repository.
menghaoran 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 1831d0a remove shardingsphere-jdbc-governance-spring module (#12150)
1831d0a is described below
commit 1831d0ac18fe3d6dea145320571aa65ab6740a7b
Author: zhaojinchao <33...@users.noreply.github.com>
AuthorDate: Wed Sep 1 19:11:06 2021 +0800
remove shardingsphere-jdbc-governance-spring module (#12150)
---
.../shardingsphere-jdbc-spring/pom.xml | 1 -
.../shardingsphere-jdbc-governance-spring/pom.xml | 40 ----
.../pom.xml | 76 --------
.../ShardingSphereGovernanceAutoConfiguration.java | 119 ------------
.../GovernanceSpringBootRootConfiguration.java | 38 ----
.../boot/governance/rule/LocalRulesCondition.java | 38 ----
.../additional-spring-configuration-metadata.json | 210 ---------------------
.../src/main/resources/META-INF/spring.factories | 19 --
.../src/main/resources/META-INF/spring.provides | 18 --
.../type/GovernanceSpringBootEncryptTest.java | 74 --------
...GovernanceSpringBootReadwriteSplittingTest.java | 82 --------
.../GovernanceSpringBootRegistryEncryptTest.java | 100 ----------
...ceSpringBootRegistryReadwriteSplittingTest.java | 90 ---------
.../GovernanceSpringBootRegistryShardingTest.java | 176 -----------------
.../type/GovernanceSpringBootShardingTest.java | 153 ---------------
.../type/SpringBootRawDataSourceTest.java | 45 -----
.../boot/governance/util/EmbedTestingServer.java | 65 -------
.../test/resources/application-encrypt.properties | 39 ----
.../src/test/resources/application-raw.properties | 20 --
.../application-readwrite-splitting.properties | 49 -----
.../application-registry-encrypt.properties | 22 ---
...ication-registry-readwrite-splitting.properties | 22 ---
.../test/resources/application-registry.properties | 22 ---
.../test/resources/application-sharding.properties | 76 --------
.../src/test/resources/logback-test.xml | 33 ----
.../src/test/resources/yaml/data-source.yaml | 22 ---
.../src/test/resources/yaml/encrypt-rule.yaml | 29 ---
.../yaml/readwrite-splitting-databases.yaml | 34 ----
.../resources/yaml/readwrite-splitting-rule.yaml | 28 ---
.../test/resources/yaml/sharding-databases.yaml | 35 ----
.../src/test/resources/yaml/sharding-rule.yaml | 64 -------
31 files changed, 1839 deletions(-)
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/pom.xml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/pom.xml
index 5e426d7..c5ac147 100644
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/pom.xml
+++ b/shardingsphere-jdbc/shardingsphere-jdbc-spring/pom.xml
@@ -30,7 +30,6 @@
<modules>
<module>shardingsphere-jdbc-spring-infra</module>
<module>shardingsphere-jdbc-core-spring</module>
- <module>shardingsphere-jdbc-governance-spring</module>
<module>shardingsphere-jdbc-transaction-spring</module>
</modules>
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/pom.xml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/pom.xml
deleted file mode 100644
index 9343459..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/pom.xml
+++ /dev/null
@@ -1,40 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- ~ 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.
- -->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- <modelVersion>4.0.0</modelVersion>
- <parent>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-jdbc-spring</artifactId>
- <version>5.0.0-RC1-SNAPSHOT</version>
- </parent>
- <artifactId>shardingsphere-jdbc-governance-spring</artifactId>
- <name>${project.artifactId}</name>
- <packaging>pom</packaging>
-
- <modules>
- <module>shardingsphere-jdbc-governance-spring-boot-starter</module>
- </modules>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.curator</groupId>
- <artifactId>curator-test</artifactId>
- </dependency>
- </dependencies>
-</project>
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/pom.xml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/pom.xml
deleted file mode 100644
index 918abe3..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/pom.xml
+++ /dev/null
@@ -1,76 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- ~ 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.
- -->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- <modelVersion>4.0.0</modelVersion>
- <parent>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-jdbc-governance-spring</artifactId>
- <version>5.0.0-RC1-SNAPSHOT</version>
- </parent>
- <artifactId>shardingsphere-jdbc-governance-spring-boot-starter</artifactId>
- <name>${project.artifactId}</name>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-sharding-spring-boot-starter</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-shadow-spring-boot-starter</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-encrypt-spring-boot-starter</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-readwrite-splitting-spring-boot-starter</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-jdbc-spring-boot-starter-infra</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter</artifactId>
- </dependency>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-configuration-processor</artifactId>
- <optional>true</optional>
- </dependency>
- <dependency>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-starter-test</artifactId>
- </dependency>
-
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-cluster-mode-repository-zookeeper-curator</artifactId>
- <version>${project.version}</version>
- <scope>test</scope>
- </dependency>
- </dependencies>
-</project>
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/ShardingSphereGovernanceAutoConfiguration.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/ShardingSphereGovernanceAutoConfi [...]
deleted file mode 100644
index 18cf857..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/ShardingSphereGovernanceAutoConfiguration.java
+++ /dev/null
@@ -1,119 +0,0 @@
-/*
- * 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.spring.boot.governance;
-
-import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource;
-import org.apache.shardingsphere.infra.config.RuleConfiguration;
-import org.apache.shardingsphere.infra.config.mode.ModeConfiguration;
-import org.apache.shardingsphere.infra.yaml.config.swapper.mode.ModeConfigurationYamlSwapper;
-import org.apache.shardingsphere.spring.boot.datasource.DataSourceMapSetter;
-import org.apache.shardingsphere.spring.boot.governance.common.GovernanceSpringBootRootConfiguration;
-import org.apache.shardingsphere.spring.boot.governance.rule.LocalRulesCondition;
-import org.apache.shardingsphere.spring.boot.schema.SchemaNameSetter;
-import org.springframework.beans.factory.ObjectProvider;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.autoconfigure.AutoConfigureBefore;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
-import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.context.EnvironmentAware;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.ComponentScan;
-import org.springframework.context.annotation.Conditional;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.core.env.Environment;
-
-import javax.sql.DataSource;
-import java.sql.SQLException;
-import java.util.Collections;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-
-/**
- * Governance spring boot configuration.
- */
-@Configuration
-@ComponentScan("org.apache.shardingsphere.spring.boot.converter")
-@EnableConfigurationProperties(GovernanceSpringBootRootConfiguration.class)
-@ConditionalOnProperty(prefix = "spring.shardingsphere", name = "enabled", havingValue = "true", matchIfMissing = true)
-@RequiredArgsConstructor
-@AutoConfigureBefore(DataSourceAutoConfiguration.class)
-public class ShardingSphereGovernanceAutoConfiguration implements EnvironmentAware {
-
- private String schemaName;
-
- private final Map<String, DataSource> dataSourceMap = new LinkedHashMap<>();
-
- private final GovernanceSpringBootRootConfiguration root;
-
- /**
- * Get mode configuration.
- *
- * @return mode configuration
- */
- @Bean
- public ModeConfiguration modeConfiguration() {
- return null == root.getMode() ? null : new ModeConfigurationYamlSwapper().swapToObject(root.getMode());
- }
-
- /**
- * Get governance ShardingSphere data source bean by local configuration.
- *
- * @param rules rules configuration
- * @param modeConfig mode configuration
- * @return governance sharding data source bean
- * @throws SQLException SQL exception
- */
- @Bean
- @Conditional(LocalRulesCondition.class)
- @Autowired(required = false)
- public DataSource localShardingSphereDataSource(final ObjectProvider<List<RuleConfiguration>> rules, final ModeConfiguration modeConfig) throws SQLException {
- return createDataSource(modeConfig, Optional.ofNullable(rules.getIfAvailable()).orElse(Collections.emptyList()));
- }
-
- /**
- * Get data source bean from registry center.
- *
- * @param modeConfig mode configuration
- * @return data source bean
- * @throws SQLException SQL Exception
- */
- @Bean
- @ConditionalOnMissingBean(DataSource.class)
- public DataSource dataSource(final ModeConfiguration modeConfig) throws SQLException {
- return createDataSource(modeConfig);
- }
-
- @Override
- public final void setEnvironment(final Environment environment) {
- schemaName = SchemaNameSetter.getSchemaName(environment);
- dataSourceMap.putAll(DataSourceMapSetter.getDataSourceMap(environment));
- }
-
- private DataSource createDataSource(final ModeConfiguration modeConfig, final List<RuleConfiguration> ruleConfigs) throws SQLException {
- return new ShardingSphereDataSource(schemaName, modeConfig, dataSourceMap, ruleConfigs, root.getProps());
- }
-
- private DataSource createDataSource(final ModeConfiguration modeConfig) throws SQLException {
- return new ShardingSphereDataSource(schemaName, modeConfig);
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/common/GovernanceSpringBootRootConfiguration.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/common/GovernanceSpringBootRoo [...]
deleted file mode 100644
index 76dd4d9..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/common/GovernanceSpringBootRootConfiguration.java
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- * 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.spring.boot.governance.common;
-
-import lombok.Getter;
-import lombok.Setter;
-import org.apache.shardingsphere.infra.yaml.config.pojo.mode.YamlModeConfiguration;
-import org.springframework.boot.context.properties.ConfigurationProperties;
-
-import java.util.Properties;
-
-/**
- * Governance spring boot root configuration.
- */
-@ConfigurationProperties(prefix = "spring.shardingsphere")
-@Getter
-@Setter
-public final class GovernanceSpringBootRootConfiguration {
-
- private Properties props = new Properties();
-
- private YamlModeConfiguration mode;
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/rule/LocalRulesCondition.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/rule/LocalRulesCondition.java
deleted file mode 100644
index 08a7916..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/java/org/apache/shardingsphere/spring/boot/governance/rule/LocalRulesCondition.java
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- * 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.spring.boot.governance.rule;
-
-import org.apache.shardingsphere.spring.boot.util.PropertyUtil;
-import org.springframework.boot.autoconfigure.condition.ConditionOutcome;
-import org.springframework.boot.autoconfigure.condition.SpringBootCondition;
-import org.springframework.context.annotation.ConditionContext;
-import org.springframework.core.type.AnnotatedTypeMetadata;
-
-/**
- * Local rules condition.
- */
-public final class LocalRulesCondition extends SpringBootCondition {
-
- private static final String SHARDING_PREFIX = "spring.shardingsphere.rules";
-
- @Override
- public ConditionOutcome getMatchOutcome(final ConditionContext conditionContext, final AnnotatedTypeMetadata annotatedTypeMetadata) {
- return PropertyUtil.containPropertyPrefix(conditionContext.getEnvironment(), SHARDING_PREFIX)
- ? ConditionOutcome.match() : ConditionOutcome.noMatch("Can't find ShardingSphere rule configuration in local file.");
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/additional-spring-configuration-metadata.json b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/additional-spring-configuration-metadata.json
deleted file mode 100644
index 6742a91..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/additional-spring-configuration-metadata.json
+++ /dev/null
@@ -1,210 +0,0 @@
-/*
- * 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.
- */
-
-{
- "groups": [
- {
- "name": "spring.shardingsphere.datasource",
- "type": "org.apache.shardingsphere.spring.boot.governance.ShardingSphereGovernanceAutoConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.complex",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlHintShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.hint",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlHintShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.standard",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.complex",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlHintShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.hint",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlHintShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.standard",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration"
- }
- ],
- "properties": [
- {
- "name": "spring.shardingsphere.enabled",
- "type": "java.lang.Boolean",
- "description": "Whether enable shardingsphere or not.",
- "defaultValue": true
- },
- {
- "name": "spring.shardingsphere.props",
- "type": "java.util.Properties",
- "sourceType": "org.apache.shardingsphere.spring.boot.governance.common.GovernanceSpringBootRootConfiguration",
- "description": "Customize shardingsphere properties."
- },
- {
- "name": "spring.shardingsphere.mode",
- "type": "org.apache.shardingsphere.infra.yaml.config.pojo.mode.YamlModeConfiguration",
- "sourceType": "org.apache.shardingsphere.spring.boot.governance.common.GovernanceSpringBootRootConfiguration"
- },
- {
- "name": "spring.shardingsphere.datasource.names",
- "type": "java.lang.String",
- "sourceType": "org.apache.shardingsphere.spring.boot.governance.ShardingSphereGovernanceAutoConfiguration"
- },
- {
- "name": "spring.shardingsphere.datasource",
- "type": "java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Object>>",
- "sourceType": "org.apache.shardingsphere.spring.boot.util.DataSourceUtil"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.complex",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.complex.algorithm-class-name",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.complex.sharding-columns",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.hint",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlHintShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlHintShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.hint.algorithm-class-name",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.none",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlNoneShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.standard",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.standard.precise-algorithm-class-name",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.standard.range-algorithm-class-name",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-database-strategy.standard.sharding-column",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.complex",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.complex.algorithm-class-name",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlComplexShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.complex.sharding-columns",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.hint",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlHintShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlHintShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.hint.algorithm-class-name",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.none",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlNoneShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.standard",
- "type": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.standard.precise-algorithm-class-name",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.standard.range-algorithm-class-name",
- "type": "java.lang.String"
- },
- {
- "sourceType": "org.apache.shardingsphere.sharding.yaml.config.strategy.sharding.YamlStandardShardingStrategyConfiguration",
- "name": "spring.shardingsphere.sharding.default-table-strategy.standard.sharding-column",
- "type": "java.lang.String"
- }
- ],
- "hints": [
- {
- "name": "spring.shardingsphere.datasource.keys",
- "values": []
- },
- {
- "name": "spring.shardingsphere.datasource.values",
- "values": [
- ],
- "providers": [
- {
- "name": "any"
- }
- ]
- }
- ]
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/spring.factories b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/spring.factories
deleted file mode 100644
index e7d22fc..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/spring.factories
+++ /dev/null
@@ -1,19 +0,0 @@
-#
-# 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.
-#
-
-org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
-org.apache.shardingsphere.spring.boot.governance.ShardingSphereGovernanceAutoConfiguration
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/spring.provides b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/spring.provides
deleted file mode 100644
index e369fd6..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/main/resources/META-INF/spring.provides
+++ /dev/null
@@ -1,18 +0,0 @@
-#
-# 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.
-#
-
-provides: shardingsphere-jdbc-governance-spring-boot-starter
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootEncryptTest.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootEncryptTest.java
deleted file mode 100644
index 1683c0c..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootEncryptTest.java
+++ /dev/null
@@ -1,74 +0,0 @@
-/*
- * 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.spring.boot.governance.type;
-
-import org.apache.commons.dbcp2.BasicDataSource;
-import org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource;
-import org.apache.shardingsphere.encrypt.api.config.EncryptRuleConfiguration;
-import org.apache.shardingsphere.infra.config.algorithm.ShardingSphereAlgorithmConfiguration;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.infra.database.DefaultSchema;
-import org.apache.shardingsphere.spring.boot.governance.util.EmbedTestingServer;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-import javax.annotation.Resource;
-import javax.sql.DataSource;
-import java.lang.reflect.Field;
-
-import static org.hamcrest.CoreMatchers.is;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringBootTest(classes = GovernanceSpringBootEncryptTest.class)
-@SpringBootApplication
-@ActiveProfiles("encrypt")
-public class GovernanceSpringBootEncryptTest {
-
- @Resource
- private DataSource dataSource;
-
- @BeforeClass
- public static void init() {
- EmbedTestingServer.start();
- }
-
- @Test
- public void assertWithEncryptDataSource() throws NoSuchFieldException, IllegalAccessException {
- assertTrue(dataSource instanceof ShardingSphereDataSource);
- Field field = ShardingSphereDataSource.class.getDeclaredField("contextManager");
- field.setAccessible(true);
- ContextManager contextManager = (ContextManager) field.get(dataSource);
- BasicDataSource embedDataSource = (BasicDataSource) contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getResource().getDataSources().values().iterator().next();
- assertThat(embedDataSource.getMaxTotal(), is(100));
- assertThat(embedDataSource.getUsername(), is("sa"));
- EncryptRuleConfiguration config =
- (EncryptRuleConfiguration) contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getConfigurations().iterator().next();
- assertThat(config.getEncryptors().size(), is(1));
- ShardingSphereAlgorithmConfiguration encryptAlgorithm = config.getEncryptors().get("order_encrypt");
- assertThat(encryptAlgorithm.getType(), is("AES"));
- assertThat(config.getTables().size(), is(1));
- assertThat(config.getTables().iterator().next().getColumns().iterator().next().getCipherColumn(), is("cipher_order_id"));
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootReadwriteSplittingTest.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRe [...]
deleted file mode 100644
index 97b406c..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootReadwriteSplittingTest.java
+++ /dev/null
@@ -1,82 +0,0 @@
-/*
- * 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.spring.boot.governance.type;
-
-import org.apache.commons.dbcp2.BasicDataSource;
-import org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.infra.database.DefaultSchema;
-import org.apache.shardingsphere.readwritesplitting.rule.ReadwriteSplittingDataSourceRule;
-import org.apache.shardingsphere.readwritesplitting.rule.ReadwriteSplittingRule;
-import org.apache.shardingsphere.spring.boot.governance.util.EmbedTestingServer;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-import javax.annotation.Resource;
-import javax.sql.DataSource;
-import java.lang.reflect.Field;
-import java.util.Optional;
-
-import static org.hamcrest.CoreMatchers.is;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringBootTest(classes = GovernanceSpringBootReadwriteSplittingTest.class)
-@SpringBootApplication
-@ActiveProfiles("readwrite-splitting")
-public class GovernanceSpringBootReadwriteSplittingTest {
-
- @Resource
- private DataSource dataSource;
-
- @BeforeClass
- public static void init() {
- EmbedTestingServer.start();
- }
-
- @Test
- public void assertDataSource() throws NoSuchFieldException, IllegalAccessException {
- assertTrue(dataSource instanceof ShardingSphereDataSource);
- Field field = ShardingSphereDataSource.class.getDeclaredField("contextManager");
- field.setAccessible(true);
- ContextManager contextManager = (ContextManager) field.get(dataSource);
- for (DataSource each : contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getResource().getDataSources().values()) {
- assertThat(((BasicDataSource) each).getMaxTotal(), is(16));
- assertThat(((BasicDataSource) each).getUsername(), is("sa"));
- }
- Optional<ReadwriteSplittingRule> rule = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().stream().filter(each
- -> each instanceof ReadwriteSplittingRule).map(each -> (ReadwriteSplittingRule) each).findFirst();
- assertTrue(rule.isPresent());
- assertReadwriteSplittingRule(rule.get());
- }
-
- private void assertReadwriteSplittingRule(final ReadwriteSplittingRule rule) {
- ReadwriteSplittingDataSourceRule dataSourceRule = rule.getSingleDataSourceRule();
- assertThat(dataSourceRule.getName(), is("pr_ds"));
- assertThat(dataSourceRule.getWriteDataSourceName(), is("write_ds"));
- assertThat(dataSourceRule.getReadDataSourceNames().size(), is(2));
- assertThat(dataSourceRule.getReadDataSourceNames().get(0), is("read_ds_0"));
- assertThat(dataSourceRule.getReadDataSourceNames().get(1), is("read_ds_1"));
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRegistryEncryptTest.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRegis [...]
deleted file mode 100644
index 34426f8..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRegistryEncryptTest.java
+++ /dev/null
@@ -1,100 +0,0 @@
-/*
- * 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.spring.boot.governance.type;
-
-import lombok.SneakyThrows;
-import org.apache.commons.dbcp2.BasicDataSource;
-import org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource;
-import org.apache.shardingsphere.encrypt.api.config.EncryptRuleConfiguration;
-import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration;
-import org.apache.shardingsphere.mode.repository.cluster.zookeeper.CuratorZookeeperRepository;
-import org.apache.shardingsphere.infra.config.algorithm.ShardingSphereAlgorithmConfiguration;
-import org.apache.shardingsphere.infra.config.properties.ConfigurationPropertyKey;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.infra.database.DefaultSchema;
-import org.apache.shardingsphere.spring.boot.governance.util.EmbedTestingServer;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-import javax.annotation.Resource;
-import javax.sql.DataSource;
-import java.io.IOException;
-import java.lang.reflect.Field;
-import java.net.URISyntaxException;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.util.Properties;
-import java.util.stream.Collectors;
-
-import static org.hamcrest.CoreMatchers.instanceOf;
-import static org.hamcrest.CoreMatchers.is;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringBootTest(classes = GovernanceSpringBootRegistryEncryptTest.class)
-@SpringBootApplication
-@ActiveProfiles("registry-encrypt")
-public class GovernanceSpringBootRegistryEncryptTest {
-
- private static final String DATA_SOURCE_FILE = "yaml/data-source.yaml";
-
- private static final String ENCRYPT_RULE_FILE = "yaml/encrypt-rule.yaml";
-
- @Resource
- private DataSource dataSource;
-
- @BeforeClass
- public static void init() {
- EmbedTestingServer.start();
- String dataSource = readYAML(DATA_SOURCE_FILE);
- String encryptRule = readYAML(ENCRYPT_RULE_FILE);
- CuratorZookeeperRepository repository = new CuratorZookeeperRepository();
- repository.init(new ClusterPersistRepositoryConfiguration("ZooKeeper", "governance-spring-boot-registry-encrypt-test", "localhost:3183", new Properties()));
- repository.persist("/metadata/logic_db/dataSources", dataSource);
- repository.persist("/metadata/logic_db/rules", encryptRule);
- repository.persist("/props", ConfigurationPropertyKey.SQL_SHOW.getKey() + ": 'true'\n");
- repository.persist("/states/datanodes", "");
- }
-
- @Test
- public void assertWithEncryptDataSource() throws NoSuchFieldException, IllegalAccessException {
- assertTrue(dataSource instanceof ShardingSphereDataSource);
- Field field = ShardingSphereDataSource.class.getDeclaredField("contextManager");
- field.setAccessible(true);
- ContextManager contextManager = (ContextManager) field.get(dataSource);
- BasicDataSource embedDataSource = (BasicDataSource) contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getResource().getDataSources().values().iterator().next();
- assertThat(embedDataSource.getMaxTotal(), is(100));
- assertThat(embedDataSource.getUsername(), is("sa"));
- EncryptRuleConfiguration config = (EncryptRuleConfiguration) contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getConfigurations().iterator().next();
- assertThat(config.getEncryptors().size(), is(1));
- ShardingSphereAlgorithmConfiguration encryptAlgorithmConfig = config.getEncryptors().get("order_encrypt");
- assertThat(encryptAlgorithmConfig, instanceOf(ShardingSphereAlgorithmConfiguration.class));
- assertThat(encryptAlgorithmConfig.getType(), is("AES"));
- }
-
- @SneakyThrows({IOException.class, URISyntaxException.class})
- private static String readYAML(final String yamlFile) {
- return Files.readAllLines(Paths.get(ClassLoader.getSystemResource(yamlFile).toURI())).stream().map(each -> each + System.lineSeparator()).collect(Collectors.joining());
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRegistryReadwriteSplittingTest.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpri [...]
deleted file mode 100644
index 04ae36d..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRegistryReadwriteSplittingTest.java
+++ /dev/null
@@ -1,90 +0,0 @@
-/*
- * 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.spring.boot.governance.type;
-
-import lombok.SneakyThrows;
-import org.apache.commons.dbcp2.BasicDataSource;
-import org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource;
-import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration;
-import org.apache.shardingsphere.mode.repository.cluster.zookeeper.CuratorZookeeperRepository;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.infra.database.DefaultSchema;
-import org.apache.shardingsphere.spring.boot.governance.util.EmbedTestingServer;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-import javax.annotation.Resource;
-import javax.sql.DataSource;
-import java.io.IOException;
-import java.lang.reflect.Field;
-import java.net.URISyntaxException;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.util.Properties;
-import java.util.stream.Collectors;
-
-import static org.hamcrest.CoreMatchers.is;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringBootTest(classes = GovernanceSpringBootRegistryReadwriteSplittingTest.class)
-@SpringBootApplication
-@ActiveProfiles("registry-readwrite-splitting")
-public class GovernanceSpringBootRegistryReadwriteSplittingTest {
-
- private static final String DATA_SOURCE_FILE = "yaml/readwrite-splitting-databases.yaml";
-
- private static final String RULE_FILE = "yaml/readwrite-splitting-rule.yaml";
-
- @Resource
- private DataSource dataSource;
-
- @BeforeClass
- public static void init() {
- EmbedTestingServer.start();
- CuratorZookeeperRepository repository = new CuratorZookeeperRepository();
- repository.init(new ClusterPersistRepositoryConfiguration("ZooKeeper", "governance-spring-boot-registry-readwrite-splitting-test", "localhost:3183", new Properties()));
- repository.persist("/metadata/logic_db/dataSources", readYAML(DATA_SOURCE_FILE));
- repository.persist("/metadata/logic_db/rules", readYAML(RULE_FILE));
- repository.persist("/props", "{}\n");
- repository.persist("/states/datanodes", "");
- }
-
- @Test
- public void assertWithReadwriteSplittingDataSource() throws NoSuchFieldException, IllegalAccessException {
- assertTrue(dataSource instanceof ShardingSphereDataSource);
- Field field = ShardingSphereDataSource.class.getDeclaredField("contextManager");
- field.setAccessible(true);
- ContextManager contextManager = (ContextManager) field.get(dataSource);
- for (DataSource each : contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getResource().getDataSources().values()) {
- assertThat(((BasicDataSource) each).getMaxTotal(), is(16));
- assertThat(((BasicDataSource) each).getUsername(), is("sa"));
- }
- }
-
- @SneakyThrows({URISyntaxException.class, IOException.class})
- private static String readYAML(final String yamlFile) {
- return Files.readAllLines(Paths.get(ClassLoader.getSystemResource(yamlFile).toURI())).stream().map(each -> each + System.lineSeparator()).collect(Collectors.joining());
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRegistryShardingTest.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRegi [...]
deleted file mode 100644
index 3adb8a8..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootRegistryShardingTest.java
+++ /dev/null
@@ -1,176 +0,0 @@
-/*
- * 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.spring.boot.governance.type;
-
-import lombok.SneakyThrows;
-import org.apache.commons.dbcp2.BasicDataSource;
-import org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource;
-import org.apache.shardingsphere.infra.config.properties.ConfigurationPropertyKey;
-import org.apache.shardingsphere.infra.database.DefaultSchema;
-import org.apache.shardingsphere.infra.datanode.DataNode;
-import org.apache.shardingsphere.infra.rule.ShardingSphereRule;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepositoryConfiguration;
-import org.apache.shardingsphere.mode.repository.cluster.zookeeper.CuratorZookeeperRepository;
-import org.apache.shardingsphere.sharding.rule.ShardingRule;
-import org.apache.shardingsphere.sharding.rule.TableRule;
-import org.apache.shardingsphere.spring.boot.governance.util.EmbedTestingServer;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-import javax.annotation.Resource;
-import javax.sql.DataSource;
-import java.io.IOException;
-import java.lang.reflect.Field;
-import java.net.URISyntaxException;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.util.Iterator;
-import java.util.Properties;
-import java.util.stream.Collectors;
-
-import static org.hamcrest.CoreMatchers.is;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringBootTest(classes = GovernanceSpringBootRegistryShardingTest.class)
-@SpringBootApplication
-@ActiveProfiles("registry")
-public class GovernanceSpringBootRegistryShardingTest {
-
- private static final String SHARDING_DATABASES_FILE = "yaml/sharding-databases.yaml";
-
- private static final String SHARDING_RULE_FILE = "yaml/sharding-rule.yaml";
-
- @Resource
- private DataSource dataSource;
-
- @BeforeClass
- public static void init() {
- EmbedTestingServer.start();
- String shardingDatabases = readYAML(SHARDING_DATABASES_FILE);
- String shardingRule = readYAML(SHARDING_RULE_FILE);
- CuratorZookeeperRepository repository = new CuratorZookeeperRepository();
- repository.init(new ClusterPersistRepositoryConfiguration("ZooKeeper", "governance-spring-boot-test", "localhost:3183", new Properties()));
- repository.persist("/metadata/logic_db/dataSources", shardingDatabases);
- repository.persist("/metadata/logic_db/rules", shardingRule);
- repository.persist("/props", ConfigurationPropertyKey.EXECUTOR_SIZE.getKey() + ": '100'\n" + ConfigurationPropertyKey.SQL_SHOW.getKey() + ": 'true'\n");
- repository.persist("/states/datanodes", "");
- }
-
- @Test
- public void assertWithShardingSphereDataSource() {
- assertTrue(dataSource instanceof ShardingSphereDataSource);
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- for (DataSource each : contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getResource().getDataSources().values()) {
- assertThat(((BasicDataSource) each).getMaxTotal(), is(16));
- }
- assertTrue(contextManager.getMetaDataContexts().getProps().<Boolean>getValue(ConfigurationPropertyKey.SQL_SHOW));
- assertTrue(contextManager.getMetaDataContexts().getProps().getValue(ConfigurationPropertyKey.SQL_SHOW));
- }
-
- @Test
- public void assertWithShardingSphereDataSourceNames() {
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- Iterator<ShardingSphereRule> iterator = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().iterator();
- ShardingRule shardingRule = (ShardingRule) iterator.next();
- assertThat(shardingRule.getDataSourceNames().size(), is(2));
- assertTrue(shardingRule.getDataSourceNames().contains("ds_0"));
- assertTrue(shardingRule.getDataSourceNames().contains("ds_1"));
- }
-
- @Test
- public void assertWithTableRules() {
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- Iterator<ShardingSphereRule> iterator = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().iterator();
- ShardingRule shardingRule = (ShardingRule) iterator.next();
- assertThat(shardingRule.getTableRules().size(), is(2));
- TableRule orderRule = shardingRule.getTableRule("t_order");
- assertThat(orderRule.getLogicTable(), is("t_order"));
- assertThat(orderRule.getActualDataNodes().size(), is(4));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_0")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_1")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_0")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_1")));
- assertTrue(orderRule.getGenerateKeyColumn().isPresent());
- assertThat(orderRule.getGenerateKeyColumn().get(), is("order_id"));
- TableRule itemRule = shardingRule.getTableRule("t_order_item");
- assertThat(itemRule.getLogicTable(), is("t_order_item"));
- assertThat(itemRule.getActualDataNodes().size(), is(4));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_item_0")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_item_1")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_item_0")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_item_1")));
- assertTrue(itemRule.getGenerateKeyColumn().isPresent());
- assertThat(itemRule.getGenerateKeyColumn().get(), is("order_item_id"));
- }
-
- @Test
- public void assertWithBindingTableRules() {
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- Iterator<ShardingSphereRule> iterator = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().iterator();
- ShardingRule shardingRule = (ShardingRule) iterator.next();
- assertThat(shardingRule.getBindingTableRules().size(), is(2));
- TableRule orderRule = shardingRule.getTableRule("t_order");
- assertThat(orderRule.getLogicTable(), is("t_order"));
- assertThat(orderRule.getActualDataNodes().size(), is(4));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_0")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_1")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_0")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_1")));
- TableRule itemRule = shardingRule.getTableRule("t_order_item");
- assertThat(itemRule.getLogicTable(), is("t_order_item"));
- assertThat(itemRule.getActualDataNodes().size(), is(4));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_item_0")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_item_1")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_item_0")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_item_1")));
- assertTrue(itemRule.getGenerateKeyColumn().isPresent());
- assertThat(itemRule.getGenerateKeyColumn().get(), is("order_item_id"));
- assertTrue(orderRule.getGenerateKeyColumn().isPresent());
- assertThat(orderRule.getGenerateKeyColumn().get(), is("order_id"));
- }
-
- @Test
- public void assertWithBroadcastTables() {
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- Iterator<ShardingSphereRule> iterator = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().iterator();
- ShardingRule shardingRule = (ShardingRule) iterator.next();
- assertThat(shardingRule.getBroadcastTables().size(), is(1));
- assertThat(shardingRule.getBroadcastTables().iterator().next(), is("t_config"));
- }
-
- @SuppressWarnings("unchecked")
- @SneakyThrows(ReflectiveOperationException.class)
- private <T> T getFieldValue(final String fieldName, final Class<?> fieldClass, final Object target) {
- Field field = fieldClass.getDeclaredField(fieldName);
- field.setAccessible(true);
- return (T) field.get(target);
- }
-
- @SneakyThrows({URISyntaxException.class, IOException.class})
- private static String readYAML(final String yamlFile) {
- return Files.readAllLines(Paths.get(ClassLoader.getSystemResource(yamlFile).toURI())).stream().map(each -> each + System.lineSeparator()).collect(Collectors.joining());
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootShardingTest.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootShardingTest.java
deleted file mode 100644
index 008c1a8..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/GovernanceSpringBootShardingTest.java
+++ /dev/null
@@ -1,153 +0,0 @@
-/*
- * 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.spring.boot.governance.type;
-
-import lombok.SneakyThrows;
-import org.apache.commons.dbcp2.BasicDataSource;
-import org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource;
-import org.apache.shardingsphere.infra.config.properties.ConfigurationPropertyKey;
-import org.apache.shardingsphere.mode.manager.ContextManager;
-import org.apache.shardingsphere.infra.database.DefaultSchema;
-import org.apache.shardingsphere.infra.datanode.DataNode;
-import org.apache.shardingsphere.infra.rule.ShardingSphereRule;
-import org.apache.shardingsphere.sharding.rule.ShardingRule;
-import org.apache.shardingsphere.sharding.rule.TableRule;
-import org.apache.shardingsphere.spring.boot.governance.util.EmbedTestingServer;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-import javax.annotation.Resource;
-import javax.sql.DataSource;
-import java.lang.reflect.Field;
-import java.util.Iterator;
-
-import static org.hamcrest.CoreMatchers.is;
-import static org.junit.Assert.assertThat;
-import static org.junit.Assert.assertTrue;
-
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringBootTest(classes = GovernanceSpringBootShardingTest.class)
-@SpringBootApplication
-@ActiveProfiles("sharding")
-public class GovernanceSpringBootShardingTest {
-
- @Resource
- private DataSource dataSource;
-
- @BeforeClass
- public static void init() {
- EmbedTestingServer.start();
- }
-
- @Test
- public void assertWithShardingSphereDataSource() {
- assertTrue(dataSource instanceof ShardingSphereDataSource);
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- for (DataSource each : contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getResource().getDataSources().values()) {
- assertThat(((BasicDataSource) each).getMaxTotal(), is(16));
- }
- assertTrue(contextManager.getMetaDataContexts().getProps().<Boolean>getValue(ConfigurationPropertyKey.SQL_SHOW));
- assertTrue(contextManager.getMetaDataContexts().getProps().getValue(ConfigurationPropertyKey.SQL_SHOW));
- assertThat(contextManager.getMetaDataContexts().getProps().getValue(ConfigurationPropertyKey.EXECUTOR_SIZE), is(100));
- }
-
- @Test
- public void assertWithShardingSphereDataSourceNames() {
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- Iterator<ShardingSphereRule> iterator = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().iterator();
- ShardingRule shardingRule = (ShardingRule) iterator.next();
- assertThat(shardingRule.getDataSourceNames().size(), is(2));
- assertTrue(shardingRule.getDataSourceNames().contains("ds_0"));
- assertTrue(shardingRule.getDataSourceNames().contains("ds_1"));
- }
-
- @Test
- public void assertWithTableRules() {
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- Iterator<ShardingSphereRule> iterator = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().iterator();
- ShardingRule shardingRule = (ShardingRule) iterator.next();
- assertThat(shardingRule.getTableRules().size(), is(2));
- TableRule orderRule = shardingRule.getTableRule("t_order");
- assertThat(orderRule.getLogicTable(), is("t_order"));
- assertThat(orderRule.getActualDataNodes().size(), is(4));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_0")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_1")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_0")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_1")));
- assertTrue(orderRule.getGenerateKeyColumn().isPresent());
- assertThat(orderRule.getGenerateKeyColumn().get(), is("order_id"));
- TableRule itemRule = shardingRule.getTableRule("t_order_item");
- assertThat(itemRule.getLogicTable(), is("t_order_item"));
- assertThat(itemRule.getActualDataNodes().size(), is(4));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_item_0")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_item_1")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_item_0")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_item_1")));
- assertTrue(itemRule.getGenerateKeyColumn().isPresent());
- assertThat(itemRule.getGenerateKeyColumn().get(), is("order_item_id"));
-
- }
-
- @Test
- public void assertWithBindingTableRules() {
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- Iterator<ShardingSphereRule> iterator = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().iterator();
- ShardingRule shardingRule = (ShardingRule) iterator.next();
- assertThat(shardingRule.getBindingTableRules().size(), is(2));
- TableRule orderRule = shardingRule.getTableRule("t_order");
- assertThat(orderRule.getLogicTable(), is("t_order"));
- assertThat(orderRule.getActualDataNodes().size(), is(4));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_0")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_1")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_0")));
- assertTrue(orderRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_1")));
- TableRule itemRule = shardingRule.getTableRule("t_order_item");
- assertThat(itemRule.getLogicTable(), is("t_order_item"));
- assertThat(itemRule.getActualDataNodes().size(), is(4));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_item_0")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_0", "t_order_item_1")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_item_0")));
- assertTrue(itemRule.getActualDataNodes().contains(new DataNode("ds_1", "t_order_item_1")));
- assertTrue(itemRule.getGenerateKeyColumn().isPresent());
- assertThat(itemRule.getGenerateKeyColumn().get(), is("order_item_id"));
- assertTrue(orderRule.getGenerateKeyColumn().isPresent());
- assertThat(orderRule.getGenerateKeyColumn().get(), is("order_id"));
- }
-
- @Test
- public void assertWithBroadcastTables() {
- ContextManager contextManager = getFieldValue("contextManager", ShardingSphereDataSource.class, dataSource);
- Iterator<ShardingSphereRule> iterator = contextManager.getMetaDataContexts().getMetaData(DefaultSchema.LOGIC_NAME).getRuleMetaData().getRules().iterator();
- ShardingRule shardingRule = (ShardingRule) iterator.next();
- assertThat(shardingRule.getBroadcastTables().size(), is(1));
- assertThat(shardingRule.getBroadcastTables().iterator().next(), is("t_config"));
- }
-
- @SuppressWarnings("unchecked")
- @SneakyThrows(ReflectiveOperationException.class)
- private <T> T getFieldValue(final String fieldName, final Class<?> fieldClass, final Object target) {
- Field field = fieldClass.getDeclaredField(fieldName);
- field.setAccessible(true);
- return (T) field.get(target);
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/SpringBootRawDataSourceTest.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/SpringBootRawDataSourceTest.java
deleted file mode 100644
index b755fa1..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/type/SpringBootRawDataSourceTest.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- * 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.spring.boot.governance.type;
-
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.beans.factory.NoSuchBeanDefinitionException;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.context.ApplicationContext;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-
-import javax.annotation.Resource;
-import javax.sql.DataSource;
-
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringBootTest(classes = SpringBootRawDataSourceTest.class)
-@ActiveProfiles("raw")
-@SpringBootApplication
-public class SpringBootRawDataSourceTest {
-
- @Resource
- private ApplicationContext context;
-
- @Test(expected = NoSuchBeanDefinitionException.class)
- public void assertDataSource() {
- context.getBean(DataSource.class);
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/util/EmbedTestingServer.java b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/util/EmbedTestingServer.java
deleted file mode 100644
index ed338d9..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/java/org/apache/shardingsphere/spring/boot/governance/util/EmbedTestingServer.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- * 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.spring.boot.governance.util;
-
-import lombok.AccessLevel;
-import lombok.NoArgsConstructor;
-import org.apache.curator.test.TestingServer;
-import org.apache.zookeeper.KeeperException.ConnectionLossException;
-import org.apache.zookeeper.KeeperException.NoNodeException;
-import org.apache.zookeeper.KeeperException.NodeExistsException;
-
-import java.io.File;
-import java.io.IOException;
-
-@NoArgsConstructor(access = AccessLevel.PRIVATE)
-public final class EmbedTestingServer {
-
- private static final int PORT = 3183;
-
- private static volatile TestingServer testingServer;
-
- /**
- * Start embed zookeeper server.
- */
- public static void start() {
- if (null != testingServer) {
- return;
- }
- try {
- testingServer = new TestingServer(PORT, new File(String.format("target/test_zk_data/%s/", System.nanoTime())));
- // CHECKSTYLE:OFF
- } catch (final Exception ex) {
- // CHECKSTYLE:ON
- if (!isIgnoredException(ex)) {
- throw new RuntimeException(ex);
- }
- } finally {
- Runtime.getRuntime().addShutdownHook(new Thread(() -> {
- try {
- testingServer.close();
- } catch (final IOException ignored) {
- }
- }));
- }
- }
-
- private static boolean isIgnoredException(final Throwable cause) {
- return cause instanceof ConnectionLossException || cause instanceof NoNodeException || cause instanceof NodeExistsException;
- }
-}
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-encrypt.properties b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-encrypt.properties
deleted file mode 100644
index df1c17f..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-encrypt.properties
+++ /dev/null
@@ -1,39 +0,0 @@
-#
-# 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.
-#
-
-spring.shardingsphere.datasource.name=ds
-
-spring.shardingsphere.datasource.ds.type=org.apache.commons.dbcp2.BasicDataSource
-spring.shardingsphere.datasource.ds.driver-class-name=org.h2.Driver
-spring.shardingsphere.datasource.ds.url=jdbc:h2:mem:ds;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
-spring.shardingsphere.datasource.ds.username=sa
-spring.shardingsphere.datasource.ds.password=
-spring.shardingsphere.datasource.ds.max-total=100
-
-spring.shardingsphere.rules.encrypt.encryptors.order_encrypt.type=AES
-spring.shardingsphere.rules.encrypt.encryptors.order_encrypt.props.aes-key-value=123456
-spring.shardingsphere.rules.encrypt.tables.t_order.columns.order_id.cipher-column=cipher_order_id
-spring.shardingsphere.rules.encrypt.tables.t_order.columns.order_id.plain-column=plain_order_id
-spring.shardingsphere.rules.encrypt.tables.t_order.columns.order_id.encryptor-name=order_encrypt
-
-spring.shardingsphere.props.sql-show=true
-
-spring.shardingsphere.mode.type=Cluster
-spring.shardingsphere.mode.repository.type=ZooKeeper
-spring.shardingsphere.mode.repository.props.namespace=governance-spring-boot-encrypt-test
-spring.shardingsphere.mode.repository.props.serverLists=localhost:3183
-spring.shardingsphere.mode.overwrite=true
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-raw.properties b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-raw.properties
deleted file mode 100644
index 36a8bd3..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-raw.properties
+++ /dev/null
@@ -1,20 +0,0 @@
-#
-# 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.
-#
-
-spring.application.name=none.sharding.test
-spring.datasource.type=com.zaxxer.hikari.HikariDataSource
-spring.shardingsphere.enabled=false
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-readwrite-splitting.properties b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-readwrite-splitting.properties
deleted file mode 100644
index b88b136..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-readwrite-splitting.properties
+++ /dev/null
@@ -1,49 +0,0 @@
-#
-# 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.
-#
-
-spring.example.datasource.name=write_ds
-spring.shardingsphere.datasource.names=${spring.example.datasource.name},read_ds_${0..1}
-
-spring.shardingsphere.datasource.write_ds.type=org.apache.commons.dbcp2.BasicDataSource
-spring.shardingsphere.datasource.write_ds.driver-class-name=org.h2.Driver
-spring.shardingsphere.datasource.write_ds.url=jdbc:h2:mem:write_ds;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
-spring.shardingsphere.datasource.write_ds.username=sa
-spring.shardingsphere.datasource.write_ds.password=
-spring.shardingsphere.datasource.write_ds.max-total=16
-
-spring.shardingsphere.datasource.read_ds_0.type=org.apache.commons.dbcp2.BasicDataSource
-spring.shardingsphere.datasource.read_ds_0.driver-class-name=org.h2.Driver
-spring.shardingsphere.datasource.read_ds_0.url=jdbc:h2:mem:demo_read_ds_0;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
-spring.shardingsphere.datasource.read_ds_0.username=sa
-spring.shardingsphere.datasource.read_ds_0.password=
-spring.shardingsphere.datasource.read_ds_0.max-total=16
-
-spring.shardingsphere.datasource.read_ds_1.type=org.apache.commons.dbcp2.BasicDataSource
-spring.shardingsphere.datasource.read_ds_1.driver-class-name=org.h2.Driver
-spring.shardingsphere.datasource.read_ds_1.url=jdbc:h2:mem:demo_read_ds_1;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
-spring.shardingsphere.datasource.read_ds_1.username=sa
-spring.shardingsphere.datasource.read_ds_1.password=
-spring.shardingsphere.datasource.read_ds_1.max-total=16
-
-spring.shardingsphere.rules.readwrite-splitting.data-sources.pr_ds.write-data-source-name=write_ds
-spring.shardingsphere.rules.readwrite-splitting.data-sources.pr_ds.read-data-source-names=read_ds_0,read_ds_1
-
-spring.shardingsphere.mode.type=Cluster
-spring.shardingsphere.mode.repository.type=ZooKeeper
-spring.shardingsphere.mode.repository.props.namespace=governance-spring-boot-read-query-test
-spring.shardingsphere.mode.repository.props.serverLists=localhost:3183
-spring.shardingsphere.mode.overwrite=true
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry-encrypt.properties b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry-encrypt.properties
deleted file mode 100644
index 55a3a5b..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry-encrypt.properties
+++ /dev/null
@@ -1,22 +0,0 @@
-#
-# 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.
-#
-
-spring.shardingsphere.mode.type=Cluster
-spring.shardingsphere.mode.repository.type=ZooKeeper
-spring.shardingsphere.mode.repository.props.namespace=governance-spring-boot-registry-encrypt-test
-spring.shardingsphere.mode.repository.props.serverLists=localhost:3183
-spring.shardingsphere.mode.overwrite=true
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry-readwrite-splitting.properties b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry-readwrite-splitting.properties
deleted file mode 100644
index d6b3d18..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry-readwrite-splitting.properties
+++ /dev/null
@@ -1,22 +0,0 @@
-#
-# 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.
-#
-
-spring.shardingsphere.mode.type=Cluster
-spring.shardingsphere.mode.repository.type=ZooKeeper
-spring.shardingsphere.mode.repository.props.namespace=governance-spring-boot-registry-readwrite-splitting-test
-spring.shardingsphere.mode.repository.props.serverLists=localhost:3183
-spring.shardingsphere.mode.overwrite=true
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry.properties b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry.properties
deleted file mode 100644
index f80e31f..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-registry.properties
+++ /dev/null
@@ -1,22 +0,0 @@
-#
-# 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.
-#
-
-spring.shardingsphere.mode.type=Cluster
-spring.shardingsphere.mode.repository.type=ZooKeeper
-spring.shardingsphere.mode.repository.props.namespace=governance-spring-boot-test
-spring.shardingsphere.mode.repository.props.serverLists=localhost:3183
-spring.shardingsphere.mode.overwrite=true
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-sharding.properties b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-sharding.properties
deleted file mode 100644
index 7f962b7..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/application-sharding.properties
+++ /dev/null
@@ -1,76 +0,0 @@
-#
-# 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.
-#
-
-spring.shardingsphere.datasource.names=ds,ds_${0..1}
-spring.shardingsphere.datasource.ds.type=org.apache.commons.dbcp2.BasicDataSource
-spring.shardingsphere.datasource.ds.driver-class-name=org.h2.Driver
-spring.shardingsphere.datasource.ds.url=jdbc:h2:mem:ds;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
-spring.shardingsphere.datasource.ds.username=sa
-spring.shardingsphere.datasource.ds.password=
-spring.shardingsphere.datasource.ds.max-total=16
-
-spring.shardingsphere.datasource.ds_0.type=org.apache.commons.dbcp2.BasicDataSource
-spring.shardingsphere.datasource.ds_0.driver-class-name=org.h2.Driver
-spring.shardingsphere.datasource.ds_0.url=jdbc:h2:mem:ds_0;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
-spring.shardingsphere.datasource.ds_0.username=sa
-spring.shardingsphere.datasource.ds_0.password=
-spring.shardingsphere.datasource.ds_0.max-total=16
-
-spring.shardingsphere.datasource.ds_1.type=org.apache.commons.dbcp2.BasicDataSource
-spring.shardingsphere.datasource.ds_1.driver-class-name=org.h2.Driver
-spring.shardingsphere.datasource.ds_1.url=jdbc:h2:mem:ds_1;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
-spring.shardingsphere.datasource.ds_1.username=sa
-spring.shardingsphere.datasource.ds_1.password=
-spring.shardingsphere.datasource.ds_1.max-total=16
-
-spring.shardingsphere.rules.sharding.default-database-strategy.standard.sharding-column=user_id
-spring.shardingsphere.rules.sharding.default-database-strategy.standard.sharding-algorithm-name=database_inline
-spring.shardingsphere.rules.sharding.tables.t_order.actual-data-nodes=ds_${0..1}.t_order_${0..1}
-spring.shardingsphere.rules.sharding.tables.t_order.table-strategy.standard.sharding-column=order_id
-spring.shardingsphere.rules.sharding.tables.t_order.table-strategy.standard.sharding-algorithm-name=t_order_inline
-
-spring.shardingsphere.rules.sharding.tables.t_order.key-generate-strategy.column=order_id
-spring.shardingsphere.rules.sharding.tables.t_order.key-generate-strategy.key-generator-name=snowflake
-
-spring.shardingsphere.rules.sharding.tables.t_order_item.actual-data-nodes=ds_${0..1}.t_order_item_${0..1}
-spring.shardingsphere.rules.sharding.tables.t_order_item.table-strategy.standard.sharding-column=order_id
-spring.shardingsphere.rules.sharding.tables.t_order_item.table-strategy.standard.sharding-algorithm-name=t_order_item_inline
-
-spring.shardingsphere.rules.sharding.tables.t_order_item.key-generate-strategy.column=order_item_id
-spring.shardingsphere.rules.sharding.tables.t_order_item.key-generate-strategy.key-generator-name=snowflake
-
-spring.shardingsphere.rules.sharding.binding-tables=t_order,t_order_item
-spring.shardingsphere.rules.sharding.broadcast-tables=t_config
-
-spring.shardingsphere.rules.sharding.sharding-algorithms.database_inline.type=INLINE
-spring.shardingsphere.rules.sharding.sharding-algorithms.database_inline.props.algorithm-expression=ds_$->{user_id % 2}
-spring.shardingsphere.rules.sharding.sharding-algorithms.t_order_inline.type=INLINE
-spring.shardingsphere.rules.sharding.sharding-algorithms.t_order_inline.props.algorithm-expression=t_order_$->{order_id % 2}
-spring.shardingsphere.rules.sharding.sharding-algorithms.t_order_item_inline.type=INLINE
-spring.shardingsphere.rules.sharding.sharding-algorithms.t_order_item_inline.props.algorithm-expression=t_order_item_$->{order_id % 2}
-
-spring.shardingsphere.rules.sharding.key-generators.snowflake.type=SNOWFLAKE
-spring.shardingsphere.rules.sharding.key-generators.snowflake.props.worker-id=123
-
-spring.shardingsphere.props.sql-show=true
-spring.shardingsphere.props.executor-size=100
-
-spring.shardingsphere.mode.type=Cluster
-spring.shardingsphere.mode.repository.type=ZooKeeper
-spring.shardingsphere.mode.repository.props.namespace=governance-spring-boot-sharding-test
-spring.shardingsphere.mode.repository.props.serverLists=localhost:3183
-spring.shardingsphere.mode.overwrite=true
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/logback-test.xml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/logback-test.xml
deleted file mode 100644
index d90fc4a..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/logback-test.xml
+++ /dev/null
@@ -1,33 +0,0 @@
-<?xml version="1.0"?>
-<!--
- ~ 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.
- -->
-
-<configuration>
- <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
- <encoder>
- <pattern>[%-5level] %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %logger{36} - %msg%n</pattern>
- </encoder>
- </appender>
- <logger name="org.apache.shardingsphere" level="warn" additivity="false">
- <appender-ref ref="console" />
- </logger>
-
- <root>
- <level value="error" />
- <appender-ref ref="console" />
- </root>
-</configuration>
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/data-source.yaml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/data-source.yaml
deleted file mode 100644
index 74a3d0d..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/data-source.yaml
+++ /dev/null
@@ -1,22 +0,0 @@
-#
-# 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.
-#
-dataSource:
- dataSourceClassName: org.apache.commons.dbcp2.BasicDataSource
- url: jdbc:h2:mem:ds;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
- maxTotal: 100
- password: ''
- username: sa
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/encrypt-rule.yaml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/encrypt-rule.yaml
deleted file mode 100644
index 1a7780c..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/encrypt-rule.yaml
+++ /dev/null
@@ -1,29 +0,0 @@
-#
-# 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.
-#
-
-- !ENCRYPT
- encryptors:
- order_encrypt:
- props:
- aes-key-value: '123456'
- type: AES
- tables:
- t_order:
- columns:
- user_id:
- cipherColumn: user_id
- encryptorName: order_encrypt
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/readwrite-splitting-databases.yaml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/readwrite-splitting-databases.yaml
deleted file mode 100644
index a41d4aa..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/readwrite-splitting-databases.yaml
+++ /dev/null
@@ -1,34 +0,0 @@
-#
-# 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.
-#
-write_ds:
- dataSourceClassName: org.apache.commons.dbcp2.BasicDataSource
- url: jdbc:h2:mem:write_ds;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
- maxTotal: 16
- password:
- username: sa
-read_ds_0:
- dataSourceClassName: org.apache.commons.dbcp2.BasicDataSource
- url: jdbc:h2:mem:demo_read_ds_0;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
- maxTotal: 16
- password:
- username: sa
-read_ds_1:
- dataSourceClassName: org.apache.commons.dbcp2.BasicDataSource
- url: jdbc:h2:mem:demo_read_ds_1;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
- maxTotal: 16
- password:
- username: sa
\ No newline at end of file
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/readwrite-splitting-rule.yaml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/readwrite-splitting-rule.yaml
deleted file mode 100644
index 198bbe1..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/readwrite-splitting-rule.yaml
+++ /dev/null
@@ -1,28 +0,0 @@
-#
-# 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.
-#
-
-- !READWRITE_SPLITTING
- loadBalancers:
- roundRobin:
- type: ROUND_ROBIN
- dataSources:
- pr_ds:
- loadBalancerName: roundRobin
- writeDataSourceName: write_ds
- readDataSourceNames:
- - read_ds_0
- - read_ds_1
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/sharding-databases.yaml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/sharding-databases.yaml
deleted file mode 100644
index c983dc2..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/sharding-databases.yaml
+++ /dev/null
@@ -1,35 +0,0 @@
-#
-# 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.
-#
-
-ds:
- dataSourceClassName: org.apache.commons.dbcp2.BasicDataSource
- url: jdbc:h2:mem:ds;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
- maxTotal: 16
- password: ''
- username: sa
-ds_0:
- dataSourceClassName: org.apache.commons.dbcp2.BasicDataSource
- url: jdbc:h2:mem:ds_0;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
- maxTotal: 16
- password: ''
- username: sa
-ds_1:
- dataSourceClassName: org.apache.commons.dbcp2.BasicDataSource
- url: jdbc:h2:mem:ds_1;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MYSQL
- maxTotal: 16
- password: ''
- username: sa
diff --git a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/sharding-rule.yaml b/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/sharding-rule.yaml
deleted file mode 100644
index dd142e2..0000000
--- a/shardingsphere-jdbc/shardingsphere-jdbc-spring/shardingsphere-jdbc-governance-spring/shardingsphere-jdbc-governance-spring-boot-starter/src/test/resources/yaml/sharding-rule.yaml
+++ /dev/null
@@ -1,64 +0,0 @@
-#
-# 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.
-#
-
-- !SHARDING
- bindingTables:
- - t_order
- - t_order_item
- broadcastTables:
- - t_config
- defaultDatabaseStrategy:
- standard:
- shardingAlgorithmName: database_inline
- shardingColumn: user_id
- tables:
- t_order:
- actualDataNodes: ds_${0..1}.t_order_${0..1}
- keyGenerateStrategy:
- column: order_id
- keyGeneratorName: snowflake
- logicTable: t_order
- tableStrategy:
- standard:
- shardingAlgorithmName: t_order_inline
- shardingColumn: order_id
- t_order_item:
- actualDataNodes: ds_${0..1}.t_order_item_${0..1}
- keyGenerateStrategy:
- column: order_item_id
- keyGeneratorName: snowflake
- logicTable: t_order_item
- tableStrategy:
- standard:
- shardingAlgorithmName: t_order_item_inline
- shardingColumn: order_id
- shardingAlgorithms:
- database_inline:
- type: INLINE
- props:
- algorithm-expression: ds_${user_id % 2}
- t_order_inline:
- type: INLINE
- props:
- algorithm-expression: t_order_${order_id % 2}
- t_order_item_inline:
- type: INLINE
- props:
- algorithm-expression: t_order_item_${order_id % 2}
- keyGenerators:
- snowflake:
- type: SNOWFLAKE