This is an automated email from the ASF dual-hosted git repository.
zhaojinchao 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 21517d961a0 Fix sonar issue (#26422)
21517d961a0 is described below
commit 21517d961a0ab121150a52d52e3e6390a57f9d53
Author: ChenJiaHao <[email protected]>
AuthorDate: Mon Jun 19 00:48:01 2023 +0800
Fix sonar issue (#26422)
---
.../handler/update/AlterReadwriteSplittingRuleStatementUpdater.java | 5 ++---
.../handler/update/DropReadwriteSplittingRuleStatementUpdater.java | 5 -----
2 files changed, 2 insertions(+), 8 deletions(-)
diff --git
a/features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/AlterReadwriteSplittingRuleStatementUpdater.java
b/features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/AlterReadwriteSplittingRuleStatementUpdater.java
index c6c80219376..df8b16e1a4a 100644
---
a/features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/AlterReadwriteSplittingRuleStatementUpdater.java
+++
b/features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/AlterReadwriteSplittingRuleStatementUpdater.java
@@ -51,8 +51,7 @@ public final class
AlterReadwriteSplittingRuleStatementUpdater implements RuleDe
}
@Override
- public ReadwriteSplittingRuleConfiguration
buildToBeDroppedRuleConfiguration(
-
final ReadwriteSplittingRuleConfiguration currentRuleConfig,
+ public ReadwriteSplittingRuleConfiguration
buildToBeDroppedRuleConfiguration(final ReadwriteSplittingRuleConfiguration
currentRuleConfig,
final ReadwriteSplittingRuleConfiguration toBeAlteredRuleConfig) {
Collection<ReadwriteSplittingDataSourceRuleConfiguration> dataSources
= new LinkedList<>();
Map<String, AlgorithmConfiguration> loadBalancers = new HashMap<>();
@@ -60,7 +59,7 @@ public final class
AlterReadwriteSplittingRuleStatementUpdater implements RuleDe
for (ReadwriteSplittingDataSourceRuleConfiguration each :
currentRuleConfig.getDataSources()) {
if (toBeAlteredDataSourceNames.contains(each.getName())) {
dataSources.add(each);
- loadBalancers.put(each.getLoadBalancerName(),
currentRuleConfig.getLoadBalancers().get(each));
+ loadBalancers.put(each.getLoadBalancerName(),
currentRuleConfig.getLoadBalancers().get(each.getLoadBalancerName()));
}
}
return new ReadwriteSplittingRuleConfiguration(dataSources,
loadBalancers);
diff --git
a/features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/DropReadwriteSplittingRuleStatementUpdater.java
b/features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/DropReadwriteSplittingRuleStatementUpdater.java
index f5c8c638fa6..c9245276362 100644
---
a/features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/DropReadwriteSplittingRuleStatementUpdater.java
+++
b/features/readwrite-splitting/distsql/handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/DropReadwriteSplittingRuleStatementUpdater.java
@@ -138,11 +138,6 @@ public final class
DropReadwriteSplittingRuleStatementUpdater implements RuleDef
.filter(Objects::nonNull).noneMatch(toBeDroppedLoadBalancerName::equals);
}
- private boolean isLoadBalancerNotInUse(final
ReadwriteSplittingRuleConfiguration currentRuleConfig, final String
toBeDroppedLoadBalancerName, final Collection<String> dataSourceNames) {
- return currentRuleConfig.getDataSources().stream().filter(each ->
!dataSourceNames.contains(each.getName())).map(ReadwriteSplittingDataSourceRuleConfiguration::getLoadBalancerName)
-
.filter(Objects::nonNull).noneMatch(toBeDroppedLoadBalancerName::equals);
- }
-
@Override
public boolean hasAnyOneToBeDropped(final
DropReadwriteSplittingRuleStatement sqlStatement, final
ReadwriteSplittingRuleConfiguration currentRuleConfig) {
return null != currentRuleConfig &&
!getIdenticalData(currentRuleConfig.getDataSources().stream()