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 a8652ca5254 Fix sonar issue on NewRuleDefinitionBackendHandler (#26669)
a8652ca5254 is described below

commit a8652ca5254a5cc4d02a8d1f3c4f0ac682bbdf86
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Jun 28 20:31:39 2023 +0800

    Fix sonar issue on NewRuleDefinitionBackendHandler (#26669)
---
 .../distsql/rdl/rule/NewRuleDefinitionBackendHandler.java | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)

diff --git 
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/rule/NewRuleDefinitionBackendHandler.java
 
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/rule/NewRuleDefinitionBackendHandler.java
index eef8476ccfb..f7adaa5ac5c 100644
--- 
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/rule/NewRuleDefinitionBackendHandler.java
+++ 
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/rule/NewRuleDefinitionBackendHandler.java
@@ -85,19 +85,20 @@ public final class NewRuleDefinitionBackendHandler<T 
extends RuleDefinitionState
                                                             final T 
sqlStatement, final RuleDefinitionUpdater updater, final RuleConfiguration 
currentRuleConfig) {
         if (updater instanceof RuleDefinitionCreateUpdater) {
             return processCreate(database, sqlStatement, 
(RuleDefinitionCreateUpdater) updater, currentRuleConfig);
-        } else if (updater instanceof RuleDefinitionAlterUpdater) {
+        }
+        if (updater instanceof RuleDefinitionAlterUpdater) {
             return processAlter(database, sqlStatement, 
(RuleDefinitionAlterUpdater) updater, currentRuleConfig);
-        } else if (updater instanceof RuleDefinitionDropUpdater) {
+        }
+        if (updater instanceof RuleDefinitionDropUpdater) {
             return processDrop(database, sqlStatement, 
(RuleDefinitionDropUpdater) updater, currentRuleConfig);
-        } else {
-            throw new UnsupportedSQLOperationException(String.format("Cannot 
support RDL updater type `%s`", updater.getClass().getName()));
         }
+        throw new UnsupportedSQLOperationException(String.format("Cannot 
support RDL updater type `%s`", updater.getClass().getName()));
     }
     
     @SuppressWarnings({"rawtypes", "unchecked"})
     private Collection<MetaDataVersion> processCreate(final 
ShardingSphereDatabase database, final T sqlStatement, final 
RuleDefinitionCreateUpdater updater,
                                                       final RuleConfiguration 
currentRuleConfig) {
-        final RuleConfiguration toBeCreatedRuleConfig = 
updater.buildToBeCreatedRuleConfiguration(currentRuleConfig, sqlStatement);
+        RuleConfiguration toBeCreatedRuleConfig = 
updater.buildToBeCreatedRuleConfiguration(currentRuleConfig, sqlStatement);
         if (null != currentRuleConfig) {
             updater.updateCurrentRuleConfiguration(currentRuleConfig, 
toBeCreatedRuleConfig);
         }
@@ -110,12 +111,12 @@ public final class NewRuleDefinitionBackendHandler<T 
extends RuleDefinitionState
     
     @SuppressWarnings({"rawtypes", "unchecked"})
     private Collection<MetaDataVersion> processAlter(final 
ShardingSphereDatabase database, final T sqlStatement, final 
RuleDefinitionAlterUpdater updater, final RuleConfiguration currentRuleConfig) {
-        final RuleConfiguration toBeAlteredRuleConfig = 
updater.buildToBeAlteredRuleConfiguration(sqlStatement);
-        final RuleConfiguration toBeDroppedRuleConfig = 
updater.buildToBeDroppedRuleConfiguration(currentRuleConfig, 
toBeAlteredRuleConfig);
+        RuleConfiguration toBeAlteredRuleConfig = 
updater.buildToBeAlteredRuleConfiguration(sqlStatement);
         updater.updateCurrentRuleConfiguration(currentRuleConfig, 
toBeAlteredRuleConfig);
         if (sqlStatement instanceof UnloadSingleTableStatement) {
             return 
ProxyContext.getInstance().getContextManager().getInstanceContext().getModeContextManager().alterRuleConfiguration(database.getName(),
 currentRuleConfig);
         }
+        RuleConfiguration toBeDroppedRuleConfig = 
updater.buildToBeDroppedRuleConfiguration(currentRuleConfig, 
toBeAlteredRuleConfig);
         
ProxyContext.getInstance().getContextManager().getInstanceContext().getModeContextManager().removeRuleConfiguration(database.getName(),
 toBeDroppedRuleConfig);
         return 
ProxyContext.getInstance().getContextManager().getInstanceContext().getModeContextManager().alterRuleConfiguration(database.getName(),
 toBeAlteredRuleConfig);
     }

Reply via email to