You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@calcite.apache.org by jh...@apache.org on 2015/03/11 07:59:23 UTC
[3/3] incubator-calcite git commit: [CALCITE-612] Update
AvaticaStatement to handle cancelled queries (Parth Chandra)
[CALCITE-612] Update AvaticaStatement to handle cancelled queries (Parth Chandra)
Project: http://git-wip-us.apache.org/repos/asf/incubator-calcite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-calcite/commit/469e5fc1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-calcite/tree/469e5fc1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-calcite/diff/469e5fc1
Branch: refs/heads/master
Commit: 469e5fc1231ee93db333c47222ecf4b6533f2c6b
Parents: 1b8b6b4
Author: Julian Hyde <jh...@apache.org>
Authored: Tue Mar 10 23:31:23 2015 -0700
Committer: Julian Hyde <jh...@apache.org>
Committed: Tue Mar 10 23:31:23 2015 -0700
----------------------------------------------------------------------
.../main/java/org/apache/calcite/avatica/AvaticaStatement.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-calcite/blob/469e5fc1/avatica/src/main/java/org/apache/calcite/avatica/AvaticaStatement.java
----------------------------------------------------------------------
diff --git a/avatica/src/main/java/org/apache/calcite/avatica/AvaticaStatement.java b/avatica/src/main/java/org/apache/calcite/avatica/AvaticaStatement.java
index 58bf287..37242c2 100644
--- a/avatica/src/main/java/org/apache/calcite/avatica/AvaticaStatement.java
+++ b/avatica/src/main/java/org/apache/calcite/avatica/AvaticaStatement.java
@@ -376,6 +376,10 @@ public abstract class AvaticaStatement
protected boolean executeInternal(Meta.Signature signature)
throws SQLException {
ResultSet resultSet = executeQueryInternal(signature);
+ // user may have cancelled the query
+ if (resultSet.isClosed()) {
+ return false;
+ }
return true;
}