This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang 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 8e7e896 Refactor for checkstyle (#10652)
8e7e896 is described below
commit 8e7e896bf5489eb875ab980be744781782c9285d
Author: Haoran Meng <[email protected]>
AuthorDate: Fri Jun 4 17:31:59 2021 +0800
Refactor for checkstyle (#10652)
---
.../distsql/rdl/impl/AlterDatabaseDiscoveryRuleBackendHandler.java | 4 ++--
.../backend/text/distsql/rdl/impl/AlterEncryptRuleBackendHandler.java | 4 ++--
.../distsql/rdl/impl/AlterReadwriteSplittingRuleBackendHandler.java | 4 ++--
.../rdl/impl/AlterShardingBindingTableRulesBackendHandler.java | 4 ++--
.../rdl/impl/AlterShardingBroadcastTableRulesBackendHandler.java | 4 ++--
.../text/distsql/rdl/impl/AlterShardingTableRuleBackendHandler.java | 4 ++--
.../distsql/rdl/impl/CreateDatabaseDiscoveryRuleBackendHandler.java | 4 ++--
.../text/distsql/rdl/impl/CreateEncryptRuleBackendHandler.java | 4 ++--
.../distsql/rdl/impl/CreateReadwriteSplittingRuleBackendHandler.java | 4 ++--
.../rdl/impl/CreateShardingBindingTableRulesBackendHandler.java | 4 ++--
.../rdl/impl/CreateShardingBroadcastTableRulesBackendHandler.java | 4 ++--
.../text/distsql/rdl/impl/CreateShardingTableRuleBackendHandler.java | 4 ++--
.../distsql/rdl/impl/DropDatabaseDiscoveryRuleBackendHandler.java | 4 ++--
.../backend/text/distsql/rdl/impl/DropEncryptRuleBackendHandler.java | 4 ++--
.../distsql/rdl/impl/DropReadwriteSplittingRuleBackendHandler.java | 4 ++--
.../distsql/rdl/impl/DropShardingBindingTableRulesBackendHandler.java | 4 ++--
.../rdl/impl/DropShardingBroadcastTableRulesBackendHandler.java | 4 ++--
.../text/distsql/rdl/impl/DropShardingTableRuleBackendHandler.java | 4 ++--
18 files changed, 36 insertions(+), 36 deletions(-)
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterDatabaseDiscoveryRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterDatabaseDiscoveryRuleBackendHandler.java
index 6a845fa..c6e0897 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterDatabaseDiscoveryRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterDatabaseDiscoveryRuleBackendHandler.java
@@ -53,7 +53,7 @@ public final class AlterDatabaseDiscoveryRuleBackendHandler
extends RDLBackendHa
}
@Override
- protected void before(final String schemaName, final
AlterDatabaseDiscoveryRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
AlterDatabaseDiscoveryRuleStatement sqlStatement) {
Optional<DatabaseDiscoveryRuleConfiguration> ruleConfig =
getDatabaseDiscoveryRuleConfiguration(schemaName);
if (!ruleConfig.isPresent()) {
throw new DatabaseDiscoveryRulesNotExistedException(schemaName,
getAlteredRuleNames(sqlStatement));
@@ -62,7 +62,7 @@ public final class AlterDatabaseDiscoveryRuleBackendHandler
extends RDLBackendHa
}
@Override
- protected void doExecute(final String schemaName, final
AlterDatabaseDiscoveryRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
AlterDatabaseDiscoveryRuleStatement sqlStatement) {
DatabaseDiscoveryRuleConfiguration databaseDiscoveryRuleConfiguration
= getDatabaseDiscoveryRuleConfiguration(schemaName).get();
DatabaseDiscoveryRuleConfiguration
alteredDatabaseDiscoveryRuleConfiguration = new
YamlRuleConfigurationSwapperEngine()
.swapToRuleConfigurations(Collections.singletonList(DatabaseDiscoveryRuleStatementConverter.convert(sqlStatement.getDatabaseDiscoveryRules()))).stream()
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterEncryptRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterEncryptRuleBackendHandler.java
index 37850e2..06c7b65 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterEncryptRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterEncryptRuleBackendHandler.java
@@ -51,7 +51,7 @@ public final class AlterEncryptRuleBackendHandler extends
RDLBackendHandler<Alte
}
@Override
- protected void before(final String schemaName, final
AlterEncryptRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
AlterEncryptRuleStatement sqlStatement) {
Optional<EncryptRuleConfiguration> ruleConfig =
getEncryptRuleConfiguration(schemaName);
if (!ruleConfig.isPresent()) {
throw new EncryptRulesNotExistedException(schemaName,
getAlteredRuleNames(sqlStatement));
@@ -60,7 +60,7 @@ public final class AlterEncryptRuleBackendHandler extends
RDLBackendHandler<Alte
}
@Override
- protected void doExecute(final String schemaName, final
AlterEncryptRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
AlterEncryptRuleStatement sqlStatement) {
EncryptRuleConfiguration encryptRuleConfiguration =
getEncryptRuleConfiguration(schemaName).get();
EncryptRuleConfiguration alteredEncryptRuleConfiguration = new
YamlRuleConfigurationSwapperEngine()
.swapToRuleConfigurations(Collections.singletonList(EncryptRuleStatementConverter.convert(sqlStatement.getEncryptRules()))).stream()
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterReadwriteSplittingRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterReadwriteSplittingRuleBackendHandler.java
index 1d3a557..65aae7a 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterReadwriteSplittingRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterReadwriteSplittingRuleBackendHandler.java
@@ -54,7 +54,7 @@ public final class AlterReadwriteSplittingRuleBackendHandler
extends RDLBackendH
}
@Override
- protected void before(final String schemaName, final
AlterReadwriteSplittingRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
AlterReadwriteSplittingRuleStatement sqlStatement) {
Optional<ReadwriteSplittingRuleConfiguration> ruleConfig =
getReadwriteSplittingRuleConfiguration(schemaName);
if (!ruleConfig.isPresent()) {
throw new ReadwriteSplittingRulesNotExistedException(schemaName,
getAlteredRuleNames(sqlStatement));
@@ -63,7 +63,7 @@ public final class AlterReadwriteSplittingRuleBackendHandler
extends RDLBackendH
}
@Override
- protected void doExecute(final String schemaName, final
AlterReadwriteSplittingRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
AlterReadwriteSplittingRuleStatement sqlStatement) {
ReadwriteSplittingRuleConfiguration
alterReadwriteSplittingRuleConfiguration = new
YamlRuleConfigurationSwapperEngine()
.swapToRuleConfigurations(Collections.singletonList(ReadwriteSplittingRuleStatementConverter.convert(sqlStatement))).stream()
.map(each -> (ReadwriteSplittingRuleConfiguration)
each).findFirst().get();
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingBindingTableRulesBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingBindingTableRulesBackendHandler.java
index 3bee81a..be65e4a 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingBindingTableRulesBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingBindingTableRulesBackendHandler.java
@@ -41,7 +41,7 @@ public final class
AlterShardingBindingTableRulesBackendHandler extends RDLBacke
}
@Override
- protected void before(final String schemaName, final
AlterShardingBindingTableRulesStatement sqlStatement) {
+ public void before(final String schemaName, final
AlterShardingBindingTableRulesStatement sqlStatement) {
if (!getShardingRuleConfiguration(schemaName).isPresent()) {
throw new ShardingBindingTableRulesNotExistsException(schemaName);
}
@@ -60,7 +60,7 @@ public final class
AlterShardingBindingTableRulesBackendHandler extends RDLBacke
}
@Override
- protected void doExecute(final String schemaName, final
AlterShardingBindingTableRulesStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
AlterShardingBindingTableRulesStatement sqlStatement) {
getShardingRuleConfiguration(schemaName).get().getBindingTableGroups().clear();
getShardingRuleConfiguration(schemaName).get().getBindingTableGroups()
.addAll(ShardingRuleStatementConverter.convert(sqlStatement).getBindingTables());
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingBroadcastTableRulesBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingBroadcastTableRulesBackendHandler.java
index 1bb0b19..67ccafb 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingBroadcastTableRulesBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingBroadcastTableRulesBackendHandler.java
@@ -34,7 +34,7 @@ public final class
AlterShardingBroadcastTableRulesBackendHandler extends RDLBac
}
@Override
- protected void before(final String schemaName, final
AlterShardingBroadcastTableRulesStatement sqlStatement) {
+ public void before(final String schemaName, final
AlterShardingBroadcastTableRulesStatement sqlStatement) {
Optional<ShardingRuleConfiguration> shardingRuleConfig =
getShardingRuleConfiguration(schemaName);
if (!shardingRuleConfig.isPresent()) {
throw new
ShardingBroadcastTableRulesNotExistsException(schemaName);
@@ -42,7 +42,7 @@ public final class
AlterShardingBroadcastTableRulesBackendHandler extends RDLBac
}
@Override
- protected void doExecute(final String schemaName, final
AlterShardingBroadcastTableRulesStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
AlterShardingBroadcastTableRulesStatement sqlStatement) {
getShardingRuleConfiguration(schemaName).get().getBroadcastTables().clear();
getShardingRuleConfiguration(schemaName).get().getBroadcastTables().addAll(sqlStatement.getTables());
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingTableRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingTableRuleBackendHandler.java
index b288980..5a7d3e1 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingTableRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/AlterShardingTableRuleBackendHandler.java
@@ -46,7 +46,7 @@ public final class AlterShardingTableRuleBackendHandler
extends RDLBackendHandle
}
@Override
- protected void before(final String schemaName, final
AlterShardingTableRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
AlterShardingTableRuleStatement sqlStatement) {
Collection<String> notExistResources = getInvalidResources(schemaName,
getResources(sqlStatement));
if (!notExistResources.isEmpty()) {
throw new ResourceNotExistedException(schemaName,
notExistResources);
@@ -67,7 +67,7 @@ public final class AlterShardingTableRuleBackendHandler
extends RDLBackendHandle
}
@Override
- protected void doExecute(final String schemaName, final
AlterShardingTableRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
AlterShardingTableRuleStatement sqlStatement) {
ShardingRuleConfiguration alteredShardingRuleConfiguration = new
YamlRuleConfigurationSwapperEngine()
.swapToRuleConfigurations(Collections.singletonList(ShardingRuleStatementConverter.convert(sqlStatement))).stream()
.map(each -> (ShardingRuleConfiguration)
each).findFirst().get();
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateDatabaseDiscoveryRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateDatabaseDiscoveryRuleBackendHandler.java
index fbbe695..b728c77 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateDatabaseDiscoveryRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateDatabaseDiscoveryRuleBackendHandler.java
@@ -55,14 +55,14 @@ public final class
CreateDatabaseDiscoveryRuleBackendHandler extends RDLBackendH
}
@Override
- protected void before(final String schemaName, final
CreateDatabaseDiscoveryRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
CreateDatabaseDiscoveryRuleStatement sqlStatement) {
checkDuplicateRuleNames(schemaName, sqlStatement);
checkResources(schemaName, sqlStatement);
checkDiscoverTypes(sqlStatement);
}
@Override
- protected void doExecute(final String schemaName, final
CreateDatabaseDiscoveryRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
CreateDatabaseDiscoveryRuleStatement sqlStatement) {
YamlDatabaseDiscoveryRuleConfiguration
yamlDatabaseDiscoveryRuleConfiguration =
DatabaseDiscoveryRuleStatementConverter.convert(sqlStatement.getDatabaseDiscoveryRules());
DatabaseDiscoveryRuleConfiguration
createdDatabaseDiscoveryRuleConfiguration = new
YamlRuleConfigurationSwapperEngine()
.swapToRuleConfigurations(Collections.singleton(yamlDatabaseDiscoveryRuleConfiguration))
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateEncryptRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateEncryptRuleBackendHandler.java
index 7959101..0a9eaa2 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateEncryptRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateEncryptRuleBackendHandler.java
@@ -53,14 +53,14 @@ public final class CreateEncryptRuleBackendHandler extends
RDLBackendHandler<Cre
}
@Override
- protected void before(final String schemaName, final
CreateEncryptRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
CreateEncryptRuleStatement sqlStatement) {
checkDuplicateRuleNames(schemaName, sqlStatement);
checkEncryptors(sqlStatement);
// TODO check resource
}
@Override
- protected void doExecute(final String schemaName, final
CreateEncryptRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
CreateEncryptRuleStatement sqlStatement) {
YamlEncryptRuleConfiguration yamlEncryptRuleConfiguration =
EncryptRuleStatementConverter.convert(sqlStatement.getEncryptRules());
EncryptRuleConfiguration createdEncryptRuleConfiguration = new
YamlRuleConfigurationSwapperEngine()
.swapToRuleConfigurations(Collections.singleton(yamlEncryptRuleConfiguration))
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateReadwriteSplittingRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateReadwriteSplittingRuleBackendHandler.java
index 268980c..27ebffc 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateReadwriteSplittingRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateReadwriteSplittingRuleBackendHandler.java
@@ -55,14 +55,14 @@ public final class
CreateReadwriteSplittingRuleBackendHandler extends RDLBackend
}
@Override
- protected void before(final String schemaName, final
CreateReadwriteSplittingRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
CreateReadwriteSplittingRuleStatement sqlStatement) {
checkDuplicateRuleNames(schemaName, sqlStatement);
checkResources(schemaName, sqlStatement);
checkLoadBalancers(sqlStatement);
}
@Override
- protected void doExecute(final String schemaName, final
CreateReadwriteSplittingRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
CreateReadwriteSplittingRuleStatement sqlStatement) {
YamlReadwriteSplittingRuleConfiguration
yamlReadwriteSplittingRuleConfiguration =
ReadwriteSplittingRuleStatementConverter.convert(sqlStatement);
ReadwriteSplittingRuleConfiguration
createdReadwriteSplittingRuleConfiguration = new
YamlRuleConfigurationSwapperEngine()
.swapToRuleConfigurations(Collections.singleton(yamlReadwriteSplittingRuleConfiguration))
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingBindingTableRulesBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingBindingTableRulesBackendHandler.java
index 160b3ea..2ad99a1 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingBindingTableRulesBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingBindingTableRulesBackendHandler.java
@@ -43,7 +43,7 @@ public final class
CreateShardingBindingTableRulesBackendHandler extends RDLBack
}
@Override
- protected void before(final String schemaName, final
CreateShardingBindingTableRulesStatement sqlStatement) {
+ public void before(final String schemaName, final
CreateShardingBindingTableRulesStatement sqlStatement) {
Optional<ShardingRuleConfiguration> shardingRuleConfig =
getShardingRuleConfiguration(schemaName);
if (!shardingRuleConfig.isPresent()) {
throw new ShardingBindingTableRulesNotExistsException(schemaName);
@@ -63,7 +63,7 @@ public final class
CreateShardingBindingTableRulesBackendHandler extends RDLBack
}
@Override
- protected void doExecute(final String schemaName, final
CreateShardingBindingTableRulesStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
CreateShardingBindingTableRulesStatement sqlStatement) {
YamlShardingRuleConfiguration yamlShardingRuleConfiguration =
ShardingRuleStatementConverter.convert(sqlStatement);
getShardingRuleConfiguration(schemaName).get().getBindingTableGroups().addAll(yamlShardingRuleConfiguration.getBindingTables());
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingBroadcastTableRulesBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingBroadcastTableRulesBackendHandler.java
index 0ab4563..66be57e 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingBroadcastTableRulesBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingBroadcastTableRulesBackendHandler.java
@@ -35,11 +35,11 @@ public final class
CreateShardingBroadcastTableRulesBackendHandler extends RDLBa
}
@Override
- protected void before(final String schemaName, final
CreateShardingBroadcastTableRulesStatement sqlStatement) {
+ public void before(final String schemaName, final
CreateShardingBroadcastTableRulesStatement sqlStatement) {
}
@Override
- protected void doExecute(final String schemaName, final
CreateShardingBroadcastTableRulesStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
CreateShardingBroadcastTableRulesStatement sqlStatement) {
Optional<ShardingRuleConfiguration> shardingRuleConfig =
getShardingRuleConfiguration(schemaName);
if (!shardingRuleConfig.isPresent()) {
ShardingRuleConfiguration shardingRuleConfiguration = new
ShardingRuleConfiguration();
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingTableRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingTableRuleBackendHandler.java
index 451c353..a786f53 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingTableRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/CreateShardingTableRuleBackendHandler.java
@@ -45,7 +45,7 @@ public final class CreateShardingTableRuleBackendHandler
extends RDLBackendHandl
}
@Override
- protected void before(final String schemaName, final
CreateShardingTableRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
CreateShardingTableRuleStatement sqlStatement) {
Collection<String> notExistResources = getInvalidResources(schemaName,
getResources(sqlStatement));
if (!notExistResources.isEmpty()) {
throw new ResourceNotExistedException(schemaName,
notExistResources);
@@ -60,7 +60,7 @@ public final class CreateShardingTableRuleBackendHandler
extends RDLBackendHandl
}
@Override
- protected void doExecute(final String schemaName, final
CreateShardingTableRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
CreateShardingTableRuleStatement sqlStatement) {
ShardingRuleConfiguration shardingRuleConfiguration =
(ShardingRuleConfiguration) new YamlRuleConfigurationSwapperEngine()
.swapToRuleConfigurations(Collections.singleton(ShardingRuleStatementConverter.convert(sqlStatement))).iterator().next();
Optional<ShardingRuleConfiguration> existShardingRuleConfiguration =
getShardingRuleConfiguration(schemaName);
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropDatabaseDiscoveryRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropDatabaseDiscoveryRuleBackendHandler.java
index 3256559..4792e5c 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropDatabaseDiscoveryRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropDatabaseDiscoveryRuleBackendHandler.java
@@ -38,7 +38,7 @@ public final class DropDatabaseDiscoveryRuleBackendHandler
extends RDLBackendHan
}
@Override
- protected void before(final String schemaName, final
DropDatabaseDiscoveryRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
DropDatabaseDiscoveryRuleStatement sqlStatement) {
Optional<DatabaseDiscoveryRuleConfiguration> ruleConfig =
getDatabaseDiscoveryRuleConfiguration(schemaName);
if (!ruleConfig.isPresent()) {
throw new DatabaseDiscoveryRulesNotExistedException(schemaName,
sqlStatement.getRuleNames());
@@ -47,7 +47,7 @@ public final class DropDatabaseDiscoveryRuleBackendHandler
extends RDLBackendHan
}
@Override
- protected void doExecute(final String schemaName, final
DropDatabaseDiscoveryRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
DropDatabaseDiscoveryRuleStatement sqlStatement) {
DatabaseDiscoveryRuleConfiguration databaseDiscoveryRuleConfiguration
= getDatabaseDiscoveryRuleConfiguration(schemaName).get();
sqlStatement.getRuleNames().forEach(each -> {
DatabaseDiscoveryDataSourceRuleConfiguration
databaseDiscoveryDataSourceRuleConfiguration =
databaseDiscoveryRuleConfiguration.getDataSources()
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropEncryptRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropEncryptRuleBackendHandler.java
index 7238537..e1d2944 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropEncryptRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropEncryptRuleBackendHandler.java
@@ -38,7 +38,7 @@ public final class DropEncryptRuleBackendHandler extends
RDLBackendHandler<DropE
}
@Override
- protected void before(final String schemaName, final
DropEncryptRuleStatement sqlStatement) {
+ public void before(final String schemaName, final DropEncryptRuleStatement
sqlStatement) {
Optional<EncryptRuleConfiguration> ruleConfig =
getEncryptRuleConfiguration(schemaName);
if (!ruleConfig.isPresent()) {
throw new EncryptRulesNotExistedException(schemaName,
sqlStatement.getTables());
@@ -47,7 +47,7 @@ public final class DropEncryptRuleBackendHandler extends
RDLBackendHandler<DropE
}
@Override
- protected void doExecute(final String schemaName, final
DropEncryptRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
DropEncryptRuleStatement sqlStatement) {
EncryptRuleConfiguration encryptRuleConfiguration =
getEncryptRuleConfiguration(schemaName).get();
sqlStatement.getTables().forEach(each -> {
EncryptTableRuleConfiguration encryptTableRuleConfiguration =
encryptRuleConfiguration.getTables()
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropReadwriteSplittingRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropReadwriteSplittingRuleBackendHandler.java
index b12b737..9acdf57 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropReadwriteSplittingRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropReadwriteSplittingRuleBackendHandler.java
@@ -38,7 +38,7 @@ public final class DropReadwriteSplittingRuleBackendHandler
extends RDLBackendHa
}
@Override
- protected void before(final String schemaName, final
DropReadwriteSplittingRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
DropReadwriteSplittingRuleStatement sqlStatement) {
Optional<ReadwriteSplittingRuleConfiguration> optional =
getReadwriteSplittingRuleConfiguration(schemaName);
if (!optional.isPresent()) {
throw new ReadwriteSplittingRulesNotExistedException(schemaName,
sqlStatement.getRuleNames());
@@ -51,7 +51,7 @@ public final class DropReadwriteSplittingRuleBackendHandler
extends RDLBackendHa
}
@Override
- protected void doExecute(final String schemaName, final
DropReadwriteSplittingRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
DropReadwriteSplittingRuleStatement sqlStatement) {
ReadwriteSplittingRuleConfiguration
readwriteSplittingRuleConfiguration =
getReadwriteSplittingRuleConfiguration(schemaName).get();
sqlStatement.getRuleNames().forEach(each -> {
ReadwriteSplittingDataSourceRuleConfiguration
readwriteSplittingDataSourceRuleConfiguration =
readwriteSplittingRuleConfiguration
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingBindingTableRulesBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingBindingTableRulesBackendHandler.java
index 2b20b54..bc17bff 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingBindingTableRulesBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingBindingTableRulesBackendHandler.java
@@ -34,7 +34,7 @@ public final class
DropShardingBindingTableRulesBackendHandler extends RDLBacken
}
@Override
- protected void before(final String schemaName, final
DropShardingBindingTableRulesStatement sqlStatement) {
+ public void before(final String schemaName, final
DropShardingBindingTableRulesStatement sqlStatement) {
Optional<ShardingRuleConfiguration> shardingRuleConfiguration =
getShardingRuleConfiguration(schemaName);
if (!shardingRuleConfiguration.isPresent() ||
shardingRuleConfiguration.get().getBindingTableGroups().isEmpty()) {
throw new ShardingBindingTableRulesNotExistsException(schemaName);
@@ -42,7 +42,7 @@ public final class
DropShardingBindingTableRulesBackendHandler extends RDLBacken
}
@Override
- protected void doExecute(final String schemaName, final
DropShardingBindingTableRulesStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
DropShardingBindingTableRulesStatement sqlStatement) {
getShardingRuleConfiguration(schemaName).get().getBindingTableGroups().clear();
}
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingBroadcastTableRulesBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingBroadcastTableRulesBackendHandler.java
index e6e4482..f655cb8 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingBroadcastTableRulesBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingBroadcastTableRulesBackendHandler.java
@@ -34,7 +34,7 @@ public final class
DropShardingBroadcastTableRulesBackendHandler extends RDLBack
}
@Override
- protected void before(final String schemaName, final
DropShardingBroadcastTableRulesStatement sqlStatement) {
+ public void before(final String schemaName, final
DropShardingBroadcastTableRulesStatement sqlStatement) {
Optional<ShardingRuleConfiguration> shardingRuleConfiguration =
getShardingRuleConfiguration(schemaName);
if (!shardingRuleConfiguration.isPresent() ||
shardingRuleConfiguration.get().getBroadcastTables().isEmpty()) {
throw new
ShardingBroadcastTableRulesNotExistsException(schemaName);
@@ -42,7 +42,7 @@ public final class
DropShardingBroadcastTableRulesBackendHandler extends RDLBack
}
@Override
- protected void doExecute(final String schemaName, final
DropShardingBroadcastTableRulesStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
DropShardingBroadcastTableRulesStatement sqlStatement) {
getShardingRuleConfiguration(schemaName).get().getBroadcastTables().clear();
}
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingTableRuleBackendHandler.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingTableRuleBackendHandler.java
index 2ff1b77..a9288fd 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingTableRuleBackendHandler.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/rdl/impl/DropShardingTableRuleBackendHandler.java
@@ -42,7 +42,7 @@ public final class DropShardingTableRuleBackendHandler
extends RDLBackendHandler
}
@Override
- protected void before(final String schemaName, final
DropShardingTableRuleStatement sqlStatement) {
+ public void before(final String schemaName, final
DropShardingTableRuleStatement sqlStatement) {
Collection<String> tableNames =
sqlStatement.getTableNames().stream().map(each ->
each.getIdentifier().getValue()).collect(Collectors.toList());
Optional<ShardingRuleConfiguration> shardingRuleConfig =
getShardingRuleConfiguration(schemaName);
if (!shardingRuleConfig.isPresent()) {
@@ -61,7 +61,7 @@ public final class DropShardingTableRuleBackendHandler
extends RDLBackendHandler
}
@Override
- protected void doExecute(final String schemaName, final
DropShardingTableRuleStatement sqlStatement) {
+ public void doExecute(final String schemaName, final
DropShardingTableRuleStatement sqlStatement) {
ShardingRuleConfiguration shardingRuleConfiguration =
getShardingRuleConfiguration(schemaName).get();
for (String each : getDroppedTables(sqlStatement)) {
dropShardingTable(shardingRuleConfiguration, each);
