[shardingsphere] branch master updated: #7549, Operation not allowed after ResultSet closed (#7550)

[zhangliang]

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 94ca2fb  #7549, Operation not allowed after ResultSet closed (#7550)
94ca2fb is described below

commit 94ca2fbfaa5df92689cb7cb6cca43d35dc38f726
Author: Zhang Yonglun <zhangyong...@apache.org>
AuthorDate: Tue Sep 22 12:04:48 2020 +0800

    #7549, Operation not allowed after ResultSet closed (#7550)
---
 .../shardingsphere/proxy/frontend/command/CommandExecutorTask.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/main/java/org/apache/shardingsphere/proxy/frontend/command/CommandExecutorTask.java
 
b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/main/java/org/apache/shardingsphere/proxy/frontend/command/CommandExecutorTask.java
index 43f3abb..1d5735c 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/main/java/org/apache/shardingsphere/proxy/frontend/command/CommandExecutorTask.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-core/src/main/java/org/apache/shardingsphere/proxy/frontend/command/CommandExecutorTask.java
@@ -83,11 +83,11 @@ public final class CommandExecutorTask implements Runnable {
             if (isNeedFlush) {
                 context.flush();
             }
-            Collection<SQLException> exceptions = closeExecutionResources();
             if 
(!backendConnection.getTransactionStatus().isInConnectionHeldTransaction()) {
+                Collection<SQLException> exceptions = 
closeExecutionResources();
                 exceptions.addAll(backendConnection.closeConnections(false));
+                processClosedExceptions(exceptions);
             }
-            processClosedExceptions(exceptions);
             rootInvokeHook.finish(connectionSize);
         }
     }