(self, keyspaces, keyspace, table)
| 2054 | yield keyspace_meta |
| 2055 | |
| 2056 | def get_table(self, keyspaces, keyspace, table): |
| 2057 | cl = ConsistencyLevel.ONE |
| 2058 | where_clause = bind_params(" WHERE keyspace_name = %%s AND %s = %%s" % (self._table_name_col,), (keyspace, table), _encoder) |
| 2059 | cf_query = QueryMessage(query=self._SELECT_COLUMN_FAMILIES + where_clause, consistency_level=cl) |
| 2060 | col_query = QueryMessage(query=self._SELECT_COLUMNS + where_clause, consistency_level=cl) |
| 2061 | triggers_query = QueryMessage(query=self._SELECT_TRIGGERS + where_clause, consistency_level=cl) |
| 2062 | (cf_success, cf_result), (col_success, col_result), (triggers_success, triggers_result) \ |
| 2063 | = self.connection.wait_for_responses(cf_query, col_query, triggers_query, timeout=self.timeout, fail_on_error=False) |
| 2064 | table_result = self._handle_results(cf_success, cf_result) |
| 2065 | col_result = self._handle_results(col_success, col_result) |
| 2066 | |
| 2067 | # the triggers table doesn't exist in C* 1.2 |
| 2068 | triggers_result = self._handle_results(triggers_success, triggers_result, |
| 2069 | expected_failures=InvalidRequest) |
| 2070 | |
| 2071 | if table_result: |
| 2072 | return self._build_table_metadata(table_result[0], col_result, triggers_result) |
| 2073 | |
| 2074 | def get_type(self, keyspaces, keyspace, type): |
| 2075 | where_clause = bind_params(" WHERE keyspace_name = %s AND type_name = %s", (keyspace, type), _encoder) |
nothing calls this directly
no test coverage detected