/* * Copyright 2015-present ScyllaDB */ /* * SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0 */ #pragma once #include #include "mutation/mutation.hh" #include "schema/schema_fwd.hh" #include "mutation/canonical_mutation.hh" #include "db/schema_features.hh" // Commutative representation of table schema // Equality ignores tombstones. class schema_mutations { mutation _columnfamilies; mutation _columns; mutation_opt _view_virtual_columns; mutation_opt _computed_columns; mutation_opt _indices; mutation_opt _dropped_columns; mutation_opt _scylla_tables; public: schema_mutations(mutation columnfamilies, mutation columns, mutation_opt view_virtual_columns, mutation_opt computed_columns, mutation_opt indices, mutation_opt dropped_columns, mutation_opt scylla_tables) : _columnfamilies(std::move(columnfamilies)) , _columns(std::move(columns)) , _view_virtual_columns(std::move(view_virtual_columns)) , _computed_columns(std::move(computed_columns)) , _indices(std::move(indices)) , _dropped_columns(std::move(dropped_columns)) , _scylla_tables(std::move(scylla_tables)) { } schema_mutations(canonical_mutation columnfamilies, canonical_mutation columns, bool is_view, std::optional indices, std::optional dropped_columns, std::optional scylla_tables, std::optional view_virtual_columns, std::optional computed_columns); schema_mutations(schema_mutations&&) = default; schema_mutations& operator=(schema_mutations&&) = default; schema_mutations(const schema_mutations&) = default; schema_mutations& operator=(const schema_mutations&) = default; void copy_to(utils::chunked_vector& dst) const; const mutation& columnfamilies_mutation() const { return _columnfamilies; } const mutation& columns_mutation() const { return _columns; } const mutation_opt& view_virtual_columns_mutation() const { return _view_virtual_columns; } const mutation_opt& computed_columns_mutation() const { return _computed_columns; } const mutation_opt& scylla_tables() const { return _scylla_tables; } mutation_opt& scylla_tables() { return _scylla_tables; } const mutation_opt& indices_mutation() const { return _indices; } const mutation_opt& dropped_columns_mutation() const { return _dropped_columns; } canonical_mutation columnfamilies_canonical_mutation() const { return canonical_mutation(_columnfamilies); } canonical_mutation columns_canonical_mutation() const { return canonical_mutation(_columns); } std::optional view_virtual_columns_canonical_mutation() const { if (_view_virtual_columns) { return canonical_mutation(*_view_virtual_columns); } return {}; } std::optional computed_columns_canonical_mutation() const { if (_computed_columns) { return canonical_mutation(*_computed_columns); } return {}; } std::optional indices_canonical_mutation() const { if (_indices) { return canonical_mutation(*_indices); } return {}; } std::optional dropped_columns_canonical_mutation() const { if (_dropped_columns) { return canonical_mutation(*_dropped_columns); } return {}; } std::optional scylla_tables_canonical_mutation() const { if (_scylla_tables) { return canonical_mutation(*_scylla_tables); } return {}; } bool is_view() const; table_schema_version digest(db::schema_features) const; std::optional partitioner() const; bool operator==(const schema_mutations&) const; schema_mutations& operator+=(schema_mutations&&); // Returns true iff any mutations contain any live cells bool live() const; friend std::ostream& operator<<(std::ostream&, const schema_mutations&); }; template <> struct fmt::formatter : fmt::formatter { auto format(const schema_mutations&, fmt::format_context& ctx) const -> decltype(ctx.out()); };