(self, queries)
| 1929 | return cmd_names |
| 1930 | |
| 1931 | def execute_query_list(self, queries): |
| 1932 | if not self.imp_client.connected: |
| 1933 | print('Not connected to Impala, could not execute queries.', file=sys.stderr) |
| 1934 | return False |
| 1935 | queries = [self.sanitise_input(q) for q in queries] |
| 1936 | for q in queries: |
| 1937 | if self.onecmd(q) is CmdStatus.ERROR: |
| 1938 | print('Could not execute command: %s' % q, file=sys.stderr) |
| 1939 | if not self.ignore_query_failure: return False |
| 1940 | return True |
| 1941 | |
| 1942 | def oauth_get_access_token(self): |
| 1943 | """Fetches OAuth access token from the OAuth Auth Server |
no test coverage detected