22#include "data/cassandra/Handle.hpp"
23#include "data/cassandra/Schema.hpp"
24#include "data/cassandra/SettingsProvider.hpp"
25#include "data/cassandra/Types.hpp"
27#include <fmt/format.h>
32namespace migration::cassandra::impl {
39 std::reference_wrapper<SettingsProviderType const> settingsProvider_;
59 data::cassandra::PreparedStatement
62 std::string
const& tableName,
63 std::string
const& key
71 WHERE TOKEN({}) >= ? AND TOKEN({}) <= ?
86 data::cassandra::PreparedStatement
const&
89 static auto kPREPARED = handler.
prepare(
93 (migrator_name, status)
Represents a handle to the cassandra database cluster.
Definition Handle.hpp:46
PreparedStatementType prepare(std::string_view query) const
Prepare a statement.
Definition Handle.cpp:156
Provides settings for BasicCassandraBackend.
Definition SettingsProvider.hpp:35
data::cassandra::PreparedStatement getPreparedFullScanStatement(data::cassandra::Handle const &handler, std::string const &tableName, std::string const &key)
Get the prepared statement for the full scan of a table.
Definition CassandraMigrationSchema.hpp:60
data::cassandra::PreparedStatement const & getPreparedInsertMigratedMigrator(data::cassandra::Handle const &handler)
Get the prepared statement for insertion of migrator_status table.
Definition CassandraMigrationSchema.hpp:83
CassandraMigrationSchema(SettingsProviderType const &settings)
Construct a new Cassandra Migration Schema object.
Definition CassandraMigrationSchema.hpp:47
std::string qualifiedTableName(SettingsProviderType const &provider, std::string_view name)
Returns the table name qualified with the keyspace and table prefix.
Definition Schema.hpp:46