(self, query_str, set_query_options)
| 742 | return (resp.version, resp.webserver_address) |
| 743 | |
| 744 | def _create_query_req(self, query_str, set_query_options): |
| 745 | conf_overlay = {} |
| 746 | if sys.version_info.major < 3: |
| 747 | key_value_pairs = set_query_options.iteritems() |
| 748 | else: |
| 749 | key_value_pairs = set_query_options.items() |
| 750 | for k, v in key_value_pairs: |
| 751 | conf_overlay[utf8_encode_if_needed(k)] = utf8_encode_if_needed(v) |
| 752 | query = TExecuteStatementReq(sessionHandle=self.session_handle, |
| 753 | statement=utf8_encode_if_needed(query_str), |
| 754 | confOverlay=conf_overlay, runAsync=True) |
| 755 | return query |
| 756 | |
| 757 | def execute_query(self, query_str, set_query_options): |
| 758 | """Execute the query 'query_str' asynchronously on the server with options dictionary |
no test coverage detected