(self)
| 2786 | self.virtual_columns_rows = defaultdict(lambda: defaultdict(list)) |
| 2787 | |
| 2788 | def _query_all(self): |
| 2789 | cl = ConsistencyLevel.ONE |
| 2790 | # todo: this duplicates V3; we should find a way for _query_all methods |
| 2791 | # to extend each other. |
| 2792 | queries = [ |
| 2793 | # copied from V3 |
| 2794 | QueryMessage(query=self._SELECT_KEYSPACES, consistency_level=cl), |
| 2795 | QueryMessage(query=self._SELECT_TABLES, consistency_level=cl), |
| 2796 | QueryMessage(query=self._SELECT_COLUMNS, consistency_level=cl), |
| 2797 | QueryMessage(query=self._SELECT_TYPES, consistency_level=cl), |
| 2798 | QueryMessage(query=self._SELECT_FUNCTIONS, consistency_level=cl), |
| 2799 | QueryMessage(query=self._SELECT_AGGREGATES, consistency_level=cl), |
| 2800 | QueryMessage(query=self._SELECT_TRIGGERS, consistency_level=cl), |
| 2801 | QueryMessage(query=self._SELECT_INDEXES, consistency_level=cl), |
| 2802 | QueryMessage(query=self._SELECT_VIEWS, consistency_level=cl), |
| 2803 | # V4-only queries |
| 2804 | QueryMessage(query=self._SELECT_VIRTUAL_KEYSPACES, consistency_level=cl), |
| 2805 | QueryMessage(query=self._SELECT_VIRTUAL_TABLES, consistency_level=cl), |
| 2806 | QueryMessage(query=self._SELECT_VIRTUAL_COLUMNS, consistency_level=cl) |
| 2807 | ] |
| 2808 | |
| 2809 | responses = self.connection.wait_for_responses( |
| 2810 | *queries, timeout=self.timeout, fail_on_error=False) |
| 2811 | ( |
| 2812 | # copied from V3 |
| 2813 | (ks_success, ks_result), |
| 2814 | (table_success, table_result), |
| 2815 | (col_success, col_result), |
| 2816 | (types_success, types_result), |
| 2817 | (functions_success, functions_result), |
| 2818 | (aggregates_success, aggregates_result), |
| 2819 | (triggers_success, triggers_result), |
| 2820 | (indexes_success, indexes_result), |
| 2821 | (views_success, views_result), |
| 2822 | # V4-only responses |
| 2823 | (virtual_ks_success, virtual_ks_result), |
| 2824 | (virtual_table_success, virtual_table_result), |
| 2825 | (virtual_column_success, virtual_column_result) |
| 2826 | ) = responses |
| 2827 | |
| 2828 | # copied from V3 |
| 2829 | self.keyspaces_result = self._handle_results(ks_success, ks_result) |
| 2830 | self.tables_result = self._handle_results(table_success, table_result) |
| 2831 | self.columns_result = self._handle_results(col_success, col_result) |
| 2832 | self.triggers_result = self._handle_results(triggers_success, triggers_result) |
| 2833 | self.types_result = self._handle_results(types_success, types_result) |
| 2834 | self.functions_result = self._handle_results(functions_success, functions_result) |
| 2835 | self.aggregates_result = self._handle_results(aggregates_success, aggregates_result) |
| 2836 | self.indexes_result = self._handle_results(indexes_success, indexes_result) |
| 2837 | self.views_result = self._handle_results(views_success, views_result) |
| 2838 | # V4-only results |
| 2839 | # These tables don't exist in some DSE versions reporting 4.X so we can |
| 2840 | # ignore them if we got an error |
| 2841 | self.virtual_keyspaces_result = self._handle_results( |
| 2842 | virtual_ks_success, virtual_ks_result, |
| 2843 | expected_failures=(InvalidRequest,) |
| 2844 | ) |
| 2845 | self.virtual_tables_result = self._handle_results( |
nothing calls this directly
no test coverage detected