Handle early cancel

integration_tests/test_dbapi.py

@@ -115,6 +115,11 @@ def test_cancel_query(presto_connection):
         cur.fetchall()
     assert 'Query was canceled' in str(cancel_error.value)
 
+    cur = presto_connection.cursor()
+    with pytest.raises(Exception) as cancel_error:
+        cur.cancel()
+    assert 'Cancel query failed; no running query' in str(cancel_error.value)
+
 
 def test_session_properties(run_presto):
     _, host, port = run_presto

prestodb/client.py

@@ -434,8 +434,10 @@ def __init__(
         self._columns = None
 
         self._finished = False
+        self._cancelled = False
         self._request = request
         self._sql = sql
+        self._result = PrestoResult(self)
 
     @property
     def columns(self):
@@ -445,6 +447,10 @@ def columns(self):
     def stats(self):
         return self._stats
 
+    @property
+    def result(self):
+        return self._result
+
     def execute(self):
         # type: () -> PrestoResult
         """Initiate a Presto query by sending the SQL statement
@@ -454,6 +460,8 @@ def execute(self):
         track the rows returned by the query. To fetch all rows,
         call fetch() until is_finished is true.
         """
+        if self._cancelled:
+            raise exceptions.PrestoUserError("Query has been cancelled")
 
         response = self._request.post(self._sql)
         status = self._request.process(response)
@@ -462,8 +470,8 @@ def execute(self):
         self._stats.update(status.stats)
         if status.next_uri is None:
             self._finished = True
-        self.result = PrestoResult(self, status.rows)
-        return self.result
+        self._result = PrestoResult(self, status.rows)
+        return self._result
 
     def fetch(self):
         # type: () -> List[List[Any]]
@@ -483,6 +491,11 @@ def cancel(self):
         # type: None -> None
         if self.is_finished():
             return
+
+        self._cancelled = True
+        if self._request.next_uri is None:
+            return
+
         response = self._request.delete(self._request.next_uri)
         if response.status_code == requests.codes.no_content:
             return

prestodb/dbapi.py

@@ -129,6 +129,7 @@ def __init__(
 
         self.arraysize = 1
         self._iterator = None
+        self._query = None
 
     @property
     def description(self):
@@ -245,4 +246,6 @@ def fetchall(self):
         return list(self.genall())
 
     def cancel(self):
+        if self._query is None:
+            raise OperationalError("Cancel query failed; no running query")
         self._query.cancel()