mirror of
https://github.com/scylladb/scylladb.git
synced 2026-04-25 19:10:42 +00:00
database: Add database::has_schema() helper
Signed-off-by: Pekka Enberg <penberg@cloudius-systems.com>
This commit is contained in:
@@ -757,6 +757,10 @@ schema_ptr database::find_schema(const utils::UUID& uuid) const throw (no_such_c
|
||||
return find_column_family(uuid).schema();
|
||||
}
|
||||
|
||||
bool database::has_schema(const sstring& ks_name, const sstring& cf_name) const {
|
||||
return _ks_cf_to_uuid.count(std::make_pair(ks_name, cf_name)) > 0;
|
||||
}
|
||||
|
||||
future<>
|
||||
database::create_keyspace(const lw_shared_ptr<keyspace_metadata>& ksm) {
|
||||
auto i = _keyspaces.find(ksm->name());
|
||||
|
||||
@@ -302,6 +302,7 @@ public:
|
||||
const column_family& find_column_family(const schema_ptr&) const throw (no_such_column_family);
|
||||
schema_ptr find_schema(const sstring& ks_name, const sstring& cf_name) const throw (no_such_column_family);
|
||||
schema_ptr find_schema(const utils::UUID&) const throw (no_such_column_family);
|
||||
bool has_schema(const sstring& ks_name, const sstring& cf_name) const;
|
||||
std::set<sstring> existing_index_names(const sstring& cf_to_exclude = sstring()) const;
|
||||
future<> stop();
|
||||
unsigned shard_of(const dht::token& t);
|
||||
|
||||
Reference in New Issue
Block a user