[shardingsphere] branch master updated: Refactor SetReadwriteSplittingStatusHandler (#18403)

[duanzhengqiang]

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 94b783c03fe Refactor SetReadwriteSplittingStatusHandler (#18403)
94b783c03fe is described below

commit 94b783c03fe2b45d3c0e1f4d557bc3df8ebf0d42
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Fri Jun 17 11:28:57 2022 +0800

    Refactor SetReadwriteSplittingStatusHandler (#18403)
---
 .../ral/common/updatable/SetReadwriteSplittingStatusHandler.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/SetReadwriteSplittingStatusHandler.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/SetReadwriteSplittingStatusHandler.java
index bd107092e80..574cc8e6dee 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/SetReadwriteSplittingStatusHandler.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/updatable/SetReadwriteSplittingStatusHandler.java
@@ -197,7 +197,7 @@ public final class SetReadwriteSplittingStatusHandler 
extends UpdatableRALBacken
     
     private Map<String, Map<String, String>> 
getExportedReadwriteSplittingRules(final ContextManager contextManager, final 
String databaseName) {
         Map<String, Map<String, String>> result = new HashMap<>();
-        
contextManager.getMetaDataContexts().getMetaData().getDatabases().get(databaseName).getRuleMetaData().findRules(ReadwriteSplittingRule.class).stream().findAny()
+        
contextManager.getMetaDataContexts().getMetaData().getDatabases().get(databaseName).getRuleMetaData().findSingleRule(ReadwriteSplittingRule.class)
                 .filter(each -> new RuleExportEngine(each)
                         
.containExportableKey(Arrays.asList(ExportableConstants.EXPORT_DYNAMIC_READWRITE_SPLITTING_RULE,
 ExportableConstants.EXPORT_STATIC_READWRITE_SPLITTING_RULE)))
                 .map(each -> new 
RuleExportEngine(each).export(Arrays.asList(ExportableConstants.EXPORT_DYNAMIC_READWRITE_SPLITTING_RULE,
 ExportableConstants.EXPORT_STATIC_READWRITE_SPLITTING_RULE)))