(self, query)
| 129 | self.close(execute_statement_resp.operationHandle) |
| 130 | |
| 131 | def __query_and_fetch(self, query): |
| 132 | execute_statement_req = TCLIService.TExecuteStatementReq() |
| 133 | execute_statement_req.sessionHandle = self.session_handle |
| 134 | execute_statement_req.statement = query |
| 135 | execute_statement_resp = self.hs2_client.ExecuteStatement(execute_statement_req) |
| 136 | HS2TestSuite.check_response(execute_statement_resp) |
| 137 | |
| 138 | # Do the actual fetch with a valid request. |
| 139 | fetch_results_req = TCLIService.TFetchResultsReq() |
| 140 | fetch_results_req.operationHandle = execute_statement_resp.operationHandle |
| 141 | fetch_results_req.maxRows = 1024 |
| 142 | fetch_results_resp = self.fetch(fetch_results_req) |
| 143 | |
| 144 | return fetch_results_resp |
| 145 | |
| 146 | @needs_session() |
| 147 | def test_alltypes_v6(self): |
no test coverage detected