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 {