This is an automated email from the ASF dual-hosted git repository.
zhangliang 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 62e07d2 Minor optimization in
DropReadwriteSplittingRuleStatementUpdater (#11302)
62e07d2 is described below
commit 62e07d2e16374bcc18f19b427e7b654aba8a735a
Author: MingxingLAI <[email protected]>
AuthorDate: Tue Jul 13 13:56:50 2021 +0800
Minor optimization in DropReadwriteSplittingRuleStatementUpdater (#11302)
---
.../handler/update/DropReadwriteSplittingRuleStatementUpdater.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/shardingsphere-features/shardingsphere-readwrite-splitting/shardingsphere-readwrite-splitting-distsql/shardingsphere-readwrite-splitting-distsql-handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/DropReadwriteSplittingRuleStatementUpdater.java
b/shardingsphere-features/shardingsphere-readwrite-splitting/shardingsphere-readwrite-splitting-distsql/shardingsphere-readwrite-splitting-distsql-handler/src/main/java/org/apache/shardingsphere/re
[...]
index 045a392..898c106 100644
---
a/shardingsphere-features/shardingsphere-readwrite-splitting/shardingsphere-readwrite-splitting-distsql/shardingsphere-readwrite-splitting-distsql-handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/DropReadwriteSplittingRuleStatementUpdater.java
+++
b/shardingsphere-features/shardingsphere-readwrite-splitting/shardingsphere-readwrite-splitting-distsql/shardingsphere-readwrite-splitting-distsql-handler/src/main/java/org/apache/shardingsphere/readwritesplitting/distsql/handler/update/DropReadwriteSplittingRuleStatementUpdater.java
@@ -76,7 +76,7 @@ public final class DropReadwriteSplittingRuleStatementUpdater
implements RuleDef
}
private boolean isLoadBalancerNotInUse(final
ReadwriteSplittingRuleConfiguration currentRuleConfig, final String
toBeDroppedLoadBalancerName) {
- return !currentRuleConfig.getDataSources().stream().filter(each ->
each.getLoadBalancerName().equals(toBeDroppedLoadBalancerName)).findAny().isPresent();
+ return !currentRuleConfig.getDataSources().stream().anyMatch(each ->
each.getLoadBalancerName().equals(toBeDroppedLoadBalancerName));
}
@Override
