You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by du...@apache.org on 2021/06/04 09:32:56 UTC
[shardingsphere] branch master updated: Refactor for checkstyle
(#10652)
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 <me...@gmail.com>
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);