ba692d1805
In 380f243986 we added support for rack
lists in replication options. Drivers which are not prepared to parse
that (as of now, all of them), will not create metadata object for
that keyspace. This breaks, for example, the "copy to/from" cqlsh
command. Potentially other things too.
To fix that, keep the "replication" column in the old format, and
store numeric RF there, which corresponds to the number of
replicas. Accurate options in the new format are put in
"replication_v2".
We set replication_v2 in the schema only when it differs from the old
"replication" so that the new column is not set during upgrade,
otherwise downgrade would fail. Partition tombstone is added to ensure
that pre-alter replication_v2 value is deleted on alters which change
replication to a value which is the same as the post-alter
"replication" value.
Fixes #26415
Closes scylladb/scylladb#26429
119 lines
4.1 KiB
C++
119 lines
4.1 KiB
C++
/*
|
|
* Copyright (C) 2021-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <unordered_map>
|
|
#include <vector>
|
|
#include <seastar/core/sstring.hh>
|
|
|
|
#include "cql3/description.hh"
|
|
#include "schema/schema.hh"
|
|
#include "locator/abstract_replication_strategy.hh"
|
|
#include "data_dictionary/user_types_metadata.hh"
|
|
#include "data_dictionary/storage_options.hh"
|
|
#include "data_dictionary/consistency_config_options.hh"
|
|
|
|
namespace gms {
|
|
class feature_service;
|
|
}
|
|
|
|
namespace data_dictionary {
|
|
|
|
class keyspace_metadata final {
|
|
sstring _name;
|
|
sstring _strategy_name;
|
|
locator::replication_strategy_config_options _strategy_options;
|
|
std::optional<unsigned> _initial_tablets;
|
|
std::unordered_map<sstring, schema_ptr> _cf_meta_data;
|
|
bool _durable_writes;
|
|
user_types_metadata _user_types;
|
|
lw_shared_ptr<const storage_options> _storage_options;
|
|
std::optional<consistency_config_option> _consistency_option;
|
|
public:
|
|
keyspace_metadata(std::string_view name,
|
|
std::string_view strategy_name,
|
|
locator::replication_strategy_config_options strategy_options,
|
|
std::optional<unsigned> initial_tablets,
|
|
std::optional<consistency_config_option> consistency_option,
|
|
bool durable_writes,
|
|
std::vector<schema_ptr> cf_defs = std::vector<schema_ptr>{},
|
|
user_types_metadata user_types = user_types_metadata{},
|
|
storage_options storage_opts = storage_options{});
|
|
static lw_shared_ptr<keyspace_metadata>
|
|
new_keyspace(std::string_view name,
|
|
std::string_view strategy_name,
|
|
locator::replication_strategy_config_options options,
|
|
std::optional<unsigned> initial_tablets,
|
|
std::optional<consistency_config_option> consistency_option,
|
|
bool durables_writes = true,
|
|
storage_options storage_opts = {},
|
|
std::vector<schema_ptr> cf_defs = {});
|
|
static lw_shared_ptr<keyspace_metadata>
|
|
new_keyspace(const keyspace_metadata& ksm);
|
|
void validate(const gms::feature_service&, const locator::topology&) const;
|
|
const sstring& name() const {
|
|
return _name;
|
|
}
|
|
const sstring& strategy_name() const {
|
|
return _strategy_name;
|
|
}
|
|
const locator::replication_strategy_config_options& strategy_options() const {
|
|
return _strategy_options;
|
|
}
|
|
locator::replication_strategy_config_options strategy_options_v1() const;
|
|
std::optional<unsigned> initial_tablets() const {
|
|
return _initial_tablets;
|
|
}
|
|
std::optional<data_dictionary::consistency_config_option> consistency_option() const {
|
|
return _consistency_option;
|
|
}
|
|
bool uses_tablets() const noexcept {
|
|
return _initial_tablets.has_value();
|
|
}
|
|
const std::unordered_map<sstring, schema_ptr>& cf_meta_data() const {
|
|
return _cf_meta_data;
|
|
}
|
|
bool durable_writes() const {
|
|
return _durable_writes;
|
|
}
|
|
user_types_metadata& user_types() {
|
|
return _user_types;
|
|
}
|
|
const user_types_metadata& user_types() const {
|
|
return _user_types;
|
|
}
|
|
const storage_options& get_storage_options() const {
|
|
return *_storage_options;
|
|
}
|
|
lw_shared_ptr<const storage_options> get_storage_options_ptr() {
|
|
return _storage_options;
|
|
}
|
|
|
|
void add_or_update_column_family(const schema_ptr& s) {
|
|
_cf_meta_data[s->cf_name()] = s;
|
|
}
|
|
void remove_column_family(const schema_ptr& s) {
|
|
_cf_meta_data.erase(s->cf_name());
|
|
}
|
|
void add_user_type(const user_type ut);
|
|
void remove_user_type(const user_type ut);
|
|
std::vector<schema_ptr> tables() const;
|
|
std::vector<view_ptr> views() const;
|
|
|
|
cql3::description describe(const replica::database& db, cql3::with_create_statement) const;
|
|
};
|
|
|
|
}
|
|
|
|
template <>
|
|
struct fmt::formatter<data_dictionary::keyspace_metadata> {
|
|
constexpr auto parse(format_parse_context& ctx) { return ctx.begin(); }
|
|
auto format(const data_dictionary::keyspace_metadata& ksm, fmt::format_context& ctx) const -> decltype(ctx.out());
|
|
};
|