Method _execute_query

mssqlcli/mssqlcliclient.py:118–154

(self, query)

                        continue

    def _execute_query(self, query):
        query_response, query_messages, query_had_error \
            = self._execute_query_execute_request_for(query)

        if self._exception_found_in(query_response):
            yield self._generate_query_results_to_tuples(query=query,
                                                         message=query_response.exception_message,
                                                         is_error=query_had_error)
            return

        if self._no_results_found_in(query_response) or self._no_rows_found_in(query_response):
            query_message = query_messages[0].message if query_messages else u''
            yield self._generate_query_results_to_tuples(query=query,
                                                         message=query_message,
                                                         is_error=query_had_error)
        else:
            query_subset_responses_and_summaries \
                = self._execute_query_subset_request_for(query_response)

            for query_subset_response, result_set_summary, query_subset_error \
                in query_subset_responses_and_summaries:
                if self._error_message_found_in(query_subset_response):
                    yield self._generate_query_results_to_tuples(query=query,
                                                                 message=query_subset_response\
                                                                    .error_message,
                                                                 is_error=query_subset_error)

                query_message_for_current_result_set \
                    = query_messages[result_set_summary.request_id].message if query_messages \
                                                                            else u''

                yield self._generate_query_results_to_tuples(
                    column_info=result_set_summary.column_info,
                    result_rows=query_subset_response.rows,
                    query=query,
                    message=query_message_for_current_result_set
                )

    def clone(self, sqltoolsclient=None):
        cloned_mssqlcli_client = copy.copy(self)