From 8345874ddae18af38db2a87ced714a223d2bb947 Mon Sep 17 00:00:00 2001 From: Pekka Enberg Date: Wed, 17 Jun 2015 15:45:45 +0300 Subject: [PATCH] database: Add database::has_schema() helper Signed-off-by: Pekka Enberg --- database.cc | 4 ++++ database.hh | 1 + 2 files changed, 5 insertions(+) diff --git a/database.cc b/database.cc index 2348035b03..f52eb7c75e 100644 --- a/database.cc +++ b/database.cc @@ -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& ksm) { auto i = _keyspaces.find(ksm->name()); diff --git a/database.hh b/database.hh index b2da21a386..f75756c12c 100644 --- a/database.hh +++ b/database.hh @@ -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 existing_index_names(const sstring& cf_to_exclude = sstring()) const; future<> stop(); unsigned shard_of(const dht::token& t);