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 e7e7e12  Resive #13904 (#13927)
e7e7e12 is described below

commit e7e7e1237c38004779b37148ac985749be6b705e
Author: Guocheng Tang <[email protected]>
AuthorDate: Sat Dec 4 23:28:47 2021 +0800

    Resive #13904 (#13927)
---
 .../executor/information/SelectInformationSchemataExecutor.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/admin/mysql/executor/information/SelectInformationSchemataExecutor.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/admin/mysql/executor/information/SelectInformationSchemataExecutor.java
index ec45e8e..5690aab 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/admin/mysql/executor/information/SelectInformationSchemataExecutor.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/admin/mysql/executor/information/SelectInformationSchemataExecutor.java
@@ -60,7 +60,7 @@ public final class SelectInformationSchemataExecutor extends 
DefaultDatabaseMeta
     
     private String schemaNameAlias = SCHEMA_NAME;
     
-    private boolean isQueryDatabase;
+    private boolean queryDatabase;
     
     public SelectInformationSchemataExecutor(final SelectStatement 
sqlStatement, final String sql) {
         super(sql);
@@ -73,7 +73,7 @@ public final class SelectInformationSchemataExecutor extends 
DefaultDatabaseMeta
     }
     
     private void removeDuplicatedRow() {
-        if (isQueryDatabase) {
+        if (queryDatabase) {
             List<Map<String, Object>> reservedRow = 
getRows().stream().collect(Collectors.groupingBy(each -> 
each.get(schemaNameAlias), Collectors.toCollection(LinkedList::new)))
                     
.values().stream().map(LinkedList::getFirst).collect(Collectors.toList());
             reservedRow.forEach(each -> getRows().removeIf(row -> 
!getRows().contains(each)));
@@ -97,7 +97,7 @@ public final class SelectInformationSchemataExecutor extends 
DefaultDatabaseMeta
         Set<String> catalogs = 
resource.getDataSources().keySet().stream().map(each -> 
resource.getDataSourcesMetaData().getDataSourceMetaData(each).getCatalog()).collect(Collectors.toSet());
         schemaNameAlias = aliasMap.getOrDefault(SCHEMA_NAME, "");
         String rowValue = rowMap.getOrDefault(schemaNameAlias, "").toString();
-        isQueryDatabase = !rowValue.isEmpty();
+        queryDatabase = !rowValue.isEmpty();
         if (catalogs.contains(rowValue)) {
             rowMap.replace(schemaNameAlias, schemaName);
         } else {

Reply via email to