Attempts to fetch rows from the query identified by the given operation handle. Asserts that the fetch returns an error with an error message matching the given expected_error_prefix.
(self, handle, orientation, expected_error_prefix)
| 259 | assert num_rows_fetched == expected_num_rows |
| 260 | |
| 261 | def fetch_fail(self, handle, orientation, expected_error_prefix): |
| 262 | """Attempts to fetch rows from the query identified by the given operation handle. |
| 263 | Asserts that the fetch returns an error with an error message matching the given |
| 264 | expected_error_prefix.""" |
| 265 | fetch_results_req = TCLIService.TFetchResultsReq() |
| 266 | fetch_results_req.operationHandle = handle |
| 267 | fetch_results_req.orientation = orientation |
| 268 | fetch_results_req.maxRows = 100 |
| 269 | fetch_results_resp = self.hs2_client.FetchResults(fetch_results_req) |
| 270 | HS2TestSuite.check_response(fetch_results_resp, TCLIService.TStatusCode.ERROR_STATUS, |
| 271 | expected_error_prefix) |
| 272 | return fetch_results_resp |
| 273 | |
| 274 | def result_metadata(self, handle): |
| 275 | """ Gets the schema for the query identified by the handle """ |
no test coverage detected