(self, keyspaces, keyspace, table)
| 2524 | yield keyspace_meta |
| 2525 | |
| 2526 | def get_table(self, keyspaces, keyspace, table): |
| 2527 | cl = ConsistencyLevel.ONE |
| 2528 | where_clause = bind_params(" WHERE keyspace_name = %%s AND %s = %%s" % (self._table_name_col), (keyspace, table), _encoder) |
| 2529 | cf_query = QueryMessage(query=self._SELECT_TABLES + where_clause, consistency_level=cl) |
| 2530 | col_query = QueryMessage(query=self._SELECT_COLUMNS + where_clause, consistency_level=cl) |
| 2531 | indexes_query = QueryMessage(query=self._SELECT_INDEXES + where_clause, consistency_level=cl) |
| 2532 | triggers_query = QueryMessage(query=self._SELECT_TRIGGERS + where_clause, consistency_level=cl) |
| 2533 | |
| 2534 | # in protocol v4 we don't know if this event is a view or a table, so we look for both |
| 2535 | where_clause = bind_params(" WHERE keyspace_name = %s AND view_name = %s", (keyspace, table), _encoder) |
| 2536 | view_query = QueryMessage(query=self._SELECT_VIEWS + where_clause, |
| 2537 | consistency_level=cl) |
| 2538 | ((cf_success, cf_result), (col_success, col_result), |
| 2539 | (indexes_sucess, indexes_result), (triggers_success, triggers_result), |
| 2540 | (view_success, view_result)) = ( |
| 2541 | self.connection.wait_for_responses( |
| 2542 | cf_query, col_query, indexes_query, triggers_query, |
| 2543 | view_query, timeout=self.timeout, fail_on_error=False) |
| 2544 | ) |
| 2545 | table_result = self._handle_results(cf_success, cf_result) |
| 2546 | col_result = self._handle_results(col_success, col_result) |
| 2547 | if table_result: |
| 2548 | indexes_result = self._handle_results(indexes_sucess, indexes_result) |
| 2549 | triggers_result = self._handle_results(triggers_success, triggers_result) |
| 2550 | return self._build_table_metadata(table_result[0], col_result, triggers_result, indexes_result) |
| 2551 | |
| 2552 | view_result = self._handle_results(view_success, view_result) |
| 2553 | if view_result: |
| 2554 | return self._build_view_metadata(view_result[0], col_result) |
| 2555 | |
| 2556 | @staticmethod |
| 2557 | def _build_keyspace_metadata_internal(row): |
no test coverage detected