[shardingsphere] branch master updated: Decouple ShowTablesBackendHandler and QueryResponse.getQueryHeaders() (#8421)

[zhangyonglun]

This is an automated email from the ASF dual-hosted git repository.

zhangyonglun 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 ed64496  Decouple ShowTablesBackendHandler and 
QueryResponse.getQueryHeaders() (#8421)
ed64496 is described below

commit ed644967c52156e2cd8057cf0377249bb1ea6ee6
Author: Liang Zhang <terrym...@163.com>
AuthorDate: Mon Nov 30 14:34:04 2020 +0800

    Decouple ShowTablesBackendHandler and QueryResponse.getQueryHeaders() 
(#8421)
---
 .../proxy/backend/text/admin/ShowTablesBackendHandler.java    | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/admin/ShowTablesBackendHandler.java
 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/admin/ShowTablesBackendHandler.java
index 21419b0..1aa0001 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/admin/ShowTablesBackendHandler.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/admin/ShowTablesBackendHandler.java
@@ -46,7 +46,7 @@ public final class ShowTablesBackendHandler implements 
TextProtocolBackendHandle
     
     private final BackendConnection backendConnection;
     
-    private QueryResponse queryResponse;
+    private QueryResult queryResult;
     
     @Override
     public BackendResponse execute() {
@@ -58,9 +58,8 @@ public final class ShowTablesBackendHandler implements 
TextProtocolBackendHandle
                 null, result.getQueryHeaders().get(0).getColumnName(), 
result.getQueryHeaders().get(0).getColumnLabel(), Types.VARCHAR, "VARCHAR", 
255, 0, false, false, false)));
         Collection<String> allTableNames = 
ProxyContext.getInstance().getMetaData(backendConnection.getSchemaName()).getSchema().getAllTableNames();
         List<MemoryQueryResultDataRow> rows = allTableNames.stream().map(each 
-> new 
MemoryQueryResultDataRow(Collections.singletonList(each))).collect(Collectors.toList());
-        QueryResult queryResult = new RawMemoryQueryResult(metaData, rows);
+        queryResult = new RawMemoryQueryResult(metaData, rows);
         result.getQueryResults().add(queryResult);
-        queryResponse = result;
         return result;
     }
     
@@ -71,14 +70,14 @@ public final class ShowTablesBackendHandler implements 
TextProtocolBackendHandle
     
     @Override
     public boolean next() throws SQLException {
-        return null != queryResponse && 
queryResponse.getQueryResults().get(0).next();
+        return null != queryResult && queryResult.next();
     }
     
     @Override
     public Collection<Object> getRowData() throws SQLException {
         Collection<Object> result = new LinkedList<>();
-        for (int columnIndex = 1; columnIndex <= 
queryResponse.getQueryHeaders().size(); columnIndex++) {
-            
result.add(queryResponse.getQueryResults().get(0).getValue(columnIndex, 
Object.class));
+        for (int columnIndex = 1; columnIndex <= 
queryResult.getMetaData().getColumnCount(); columnIndex++) {
+            result.add(queryResult.getValue(columnIndex, Object.class));
         }
         return result;
     }