(self)
| 3006 | row.get("to_clustering_columns")) |
| 3007 | |
| 3008 | def _query_all(self): |
| 3009 | cl = ConsistencyLevel.ONE |
| 3010 | queries = [ |
| 3011 | # copied from v4 |
| 3012 | QueryMessage(query=self._SELECT_KEYSPACES, consistency_level=cl), |
| 3013 | QueryMessage(query=self._SELECT_TABLES, consistency_level=cl), |
| 3014 | QueryMessage(query=self._SELECT_COLUMNS, consistency_level=cl), |
| 3015 | QueryMessage(query=self._SELECT_TYPES, consistency_level=cl), |
| 3016 | QueryMessage(query=self._SELECT_FUNCTIONS, consistency_level=cl), |
| 3017 | QueryMessage(query=self._SELECT_AGGREGATES, consistency_level=cl), |
| 3018 | QueryMessage(query=self._SELECT_TRIGGERS, consistency_level=cl), |
| 3019 | QueryMessage(query=self._SELECT_INDEXES, consistency_level=cl), |
| 3020 | QueryMessage(query=self._SELECT_VIEWS, consistency_level=cl), |
| 3021 | QueryMessage(query=self._SELECT_VIRTUAL_KEYSPACES, consistency_level=cl), |
| 3022 | QueryMessage(query=self._SELECT_VIRTUAL_TABLES, consistency_level=cl), |
| 3023 | QueryMessage(query=self._SELECT_VIRTUAL_COLUMNS, consistency_level=cl), |
| 3024 | # dse6.8 only |
| 3025 | QueryMessage(query=self._SELECT_VERTICES, consistency_level=cl), |
| 3026 | QueryMessage(query=self._SELECT_EDGES, consistency_level=cl) |
| 3027 | ] |
| 3028 | |
| 3029 | responses = self.connection.wait_for_responses( |
| 3030 | *queries, timeout=self.timeout, fail_on_error=False) |
| 3031 | ( |
| 3032 | # copied from V4 |
| 3033 | (ks_success, ks_result), |
| 3034 | (table_success, table_result), |
| 3035 | (col_success, col_result), |
| 3036 | (types_success, types_result), |
| 3037 | (functions_success, functions_result), |
| 3038 | (aggregates_success, aggregates_result), |
| 3039 | (triggers_success, triggers_result), |
| 3040 | (indexes_success, indexes_result), |
| 3041 | (views_success, views_result), |
| 3042 | (virtual_ks_success, virtual_ks_result), |
| 3043 | (virtual_table_success, virtual_table_result), |
| 3044 | (virtual_column_success, virtual_column_result), |
| 3045 | # dse6.8 responses |
| 3046 | (vertices_success, vertices_result), |
| 3047 | (edges_success, edges_result) |
| 3048 | ) = responses |
| 3049 | |
| 3050 | # copied from V4 |
| 3051 | self.keyspaces_result = self._handle_results(ks_success, ks_result) |
| 3052 | self.tables_result = self._handle_results(table_success, table_result) |
| 3053 | self.columns_result = self._handle_results(col_success, col_result) |
| 3054 | self.triggers_result = self._handle_results(triggers_success, triggers_result) |
| 3055 | self.types_result = self._handle_results(types_success, types_result) |
| 3056 | self.functions_result = self._handle_results(functions_success, functions_result) |
| 3057 | self.aggregates_result = self._handle_results(aggregates_success, aggregates_result) |
| 3058 | self.indexes_result = self._handle_results(indexes_success, indexes_result) |
| 3059 | self.views_result = self._handle_results(views_success, views_result) |
| 3060 | |
| 3061 | # These tables don't exist in some DSE versions reporting 4.X so we can |
| 3062 | # ignore them if we got an error |
| 3063 | self.virtual_keyspaces_result = self._handle_results( |
| 3064 | virtual_ks_success, virtual_ks_result, |
| 3065 | expected_failures=(InvalidRequest,) |
nothing calls this directly
no test coverage detected