mirror of
https://github.com/XRPLF/clio.git
synced 2025-12-06 17:27:58 +00:00
1cfa06c9aa
Support AWS Keyspace queries --------- Co-authored-by: Ayaz Salikhov <mathbunnyru@users.noreply.github.com> Co-authored-by: Alex Kremer <akremer@ripple.com>
878 lines
26 KiB
C++
878 lines
26 KiB
C++
//------------------------------------------------------------------------------
|
|
/*
|
|
This file is part of clio: https://github.com/XRPLF/clio
|
|
Copyright (c) 2023, the clio developers.
|
|
|
|
Permission to use, copy, modify, and distribute this software for any
|
|
purpose with or without fee is hereby granted, provided that the above
|
|
copyright notice and this permission notice appear in all copies.
|
|
|
|
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
|
ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
|
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
|
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
*/
|
|
//==============================================================================
|
|
|
|
#pragma once
|
|
|
|
#include "data/cassandra/Concepts.hpp"
|
|
#include "data/cassandra/Handle.hpp"
|
|
#include "data/cassandra/Types.hpp"
|
|
#include "util/log/Logger.hpp"
|
|
|
|
#include <boost/json/string.hpp>
|
|
#include <fmt/compile.h>
|
|
|
|
#include <functional>
|
|
#include <string>
|
|
#include <string_view>
|
|
#include <vector>
|
|
|
|
namespace data::cassandra {
|
|
|
|
/**
|
|
* @brief Returns the table name qualified with the keyspace and table prefix
|
|
*
|
|
* @tparam SettingsProviderType The settings provider type
|
|
* @param provider The settings provider
|
|
* @param name The name of the table
|
|
* @return The qualified table name
|
|
*/
|
|
template <SomeSettingsProvider SettingsProviderType>
|
|
[[nodiscard]] std::string inline qualifiedTableName(SettingsProviderType const& provider, std::string_view name)
|
|
{
|
|
return fmt::format("{}.{}{}", provider.getKeyspace(), provider.getTablePrefix().value_or(""), name);
|
|
}
|
|
|
|
/**
|
|
* @brief Manages the DB schema and provides access to prepared statements.
|
|
*/
|
|
template <SomeSettingsProvider SettingsProviderType>
|
|
class Schema {
|
|
protected:
|
|
util::Logger log_{"Backend"};
|
|
std::reference_wrapper<SettingsProviderType const> settingsProvider_;
|
|
|
|
public:
|
|
virtual ~Schema() = default;
|
|
|
|
/**
|
|
* @brief Shared Schema's between all Schema classes (Cassandra and Keyspace)
|
|
*
|
|
* @param settingsProvider The settings provider
|
|
*/
|
|
explicit Schema(SettingsProviderType const& settingsProvider) : settingsProvider_{std::cref(settingsProvider)}
|
|
{
|
|
}
|
|
|
|
std::string createKeyspace = [this]() {
|
|
return fmt::format(
|
|
R"(
|
|
CREATE KEYSPACE IF NOT EXISTS {}
|
|
WITH replication = {{
|
|
'class': 'SimpleStrategy',
|
|
'replication_factor': '{}'
|
|
}}
|
|
AND durable_writes = True
|
|
)",
|
|
settingsProvider_.get().getKeyspace(),
|
|
settingsProvider_.get().getReplicationFactor()
|
|
);
|
|
}();
|
|
|
|
// =======================
|
|
// Schema creation queries
|
|
// =======================
|
|
|
|
std::vector<Statement> createSchema = [this]() {
|
|
std::vector<Statement> statements;
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
key blob,
|
|
sequence bigint,
|
|
object blob,
|
|
PRIMARY KEY (key, sequence)
|
|
)
|
|
WITH CLUSTERING ORDER BY (sequence DESC)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "objects")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
hash blob PRIMARY KEY,
|
|
ledger_sequence bigint,
|
|
date bigint,
|
|
transaction blob,
|
|
metadata blob
|
|
)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "transactions")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
ledger_sequence bigint,
|
|
hash blob,
|
|
PRIMARY KEY (ledger_sequence, hash)
|
|
)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_transactions")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
key blob,
|
|
seq bigint,
|
|
next blob,
|
|
PRIMARY KEY (key, seq)
|
|
)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "successor")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
seq bigint,
|
|
key blob,
|
|
PRIMARY KEY (seq, key)
|
|
)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "diff")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
account blob,
|
|
seq_idx tuple<bigint, bigint>,
|
|
hash blob,
|
|
PRIMARY KEY (account, seq_idx)
|
|
)
|
|
WITH CLUSTERING ORDER BY (seq_idx DESC)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "account_tx")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
sequence bigint PRIMARY KEY,
|
|
header blob
|
|
)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledgers")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
hash blob PRIMARY KEY,
|
|
sequence bigint
|
|
)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_hashes")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
is_latest boolean PRIMARY KEY,
|
|
sequence bigint
|
|
)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_range")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
token_id blob,
|
|
sequence bigint,
|
|
owner blob,
|
|
is_burned boolean,
|
|
PRIMARY KEY (token_id, sequence)
|
|
)
|
|
WITH CLUSTERING ORDER BY (sequence DESC)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_tokens")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
issuer blob,
|
|
taxon bigint,
|
|
token_id blob,
|
|
PRIMARY KEY (issuer, taxon, token_id)
|
|
)
|
|
WITH CLUSTERING ORDER BY (taxon ASC, token_id ASC)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "issuer_nf_tokens_v2")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
token_id blob,
|
|
sequence bigint,
|
|
uri blob,
|
|
PRIMARY KEY (token_id, sequence)
|
|
)
|
|
WITH CLUSTERING ORDER BY (sequence DESC)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_token_uris")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
token_id blob,
|
|
seq_idx tuple<bigint, bigint>,
|
|
hash blob,
|
|
PRIMARY KEY (token_id, seq_idx)
|
|
)
|
|
WITH CLUSTERING ORDER BY (seq_idx DESC)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_token_transactions")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
mpt_id blob,
|
|
holder blob,
|
|
PRIMARY KEY (mpt_id, holder)
|
|
)
|
|
WITH CLUSTERING ORDER BY (holder ASC)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "mp_token_holders")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
migrator_name TEXT,
|
|
status TEXT,
|
|
PRIMARY KEY (migrator_name)
|
|
)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "migrator_status")
|
|
)
|
|
);
|
|
|
|
statements.emplace_back(
|
|
fmt::format(
|
|
R"(
|
|
CREATE TABLE IF NOT EXISTS {}
|
|
(
|
|
node_id UUID,
|
|
message TEXT,
|
|
PRIMARY KEY (node_id)
|
|
)
|
|
WITH default_time_to_live = 2
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nodes_chat")
|
|
)
|
|
);
|
|
|
|
return statements;
|
|
}();
|
|
|
|
/**
|
|
* @brief Prepared statements holder.
|
|
*/
|
|
class Statements {
|
|
protected:
|
|
std::reference_wrapper<SettingsProviderType const> settingsProvider_;
|
|
std::reference_wrapper<Handle const> handle_;
|
|
|
|
public:
|
|
/**
|
|
* @brief Construct a new Statements object
|
|
*
|
|
* @param settingsProvider The settings provider
|
|
* @param handle The handle to the DB
|
|
*/
|
|
Statements(SettingsProviderType const& settingsProvider, Handle const& handle)
|
|
: settingsProvider_{settingsProvider}, handle_{std::cref(handle)}
|
|
{
|
|
}
|
|
|
|
//
|
|
// Insert queries
|
|
//
|
|
|
|
PreparedStatement insertObject = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(key, sequence, object)
|
|
VALUES (?, ?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "objects")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertTransaction = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(hash, ledger_sequence, date, transaction, metadata)
|
|
VALUES (?, ?, ?, ?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "transactions")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertLedgerTransaction = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(ledger_sequence, hash)
|
|
VALUES (?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_transactions")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertSuccessor = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(key, seq, next)
|
|
VALUES (?, ?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "successor")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertDiff = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(seq, key)
|
|
VALUES (?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "diff")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertAccountTx = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(account, seq_idx, hash)
|
|
VALUES (?, ?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "account_tx")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertNFT = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(token_id, sequence, owner, is_burned)
|
|
VALUES (?, ?, ?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_tokens")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertIssuerNFT = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(issuer, taxon, token_id)
|
|
VALUES (?, ?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "issuer_nf_tokens_v2")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertNFTURI = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(token_id, sequence, uri)
|
|
VALUES (?, ?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_token_uris")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertNFTTx = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(token_id, seq_idx, hash)
|
|
VALUES (?, ?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_token_transactions")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertMPTHolder = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(mpt_id, holder)
|
|
VALUES (?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "mp_token_holders")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertLedgerHeader = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(sequence, header)
|
|
VALUES (?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledgers")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertLedgerHash = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(hash, sequence)
|
|
VALUES (?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_hashes")
|
|
)
|
|
);
|
|
}();
|
|
|
|
//
|
|
// Update (and "delete") queries
|
|
//
|
|
|
|
PreparedStatement deleteLedgerRange = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
UPDATE {}
|
|
SET sequence = ?
|
|
WHERE is_latest = False
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_range")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement insertMigratorStatus = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
INSERT INTO {}
|
|
(migrator_name, status)
|
|
VALUES (?, ?)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "migrator_status")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement updateClioNodeMessage = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
UPDATE {}
|
|
SET message = ?
|
|
WHERE node_id = ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nodes_chat")
|
|
)
|
|
);
|
|
}();
|
|
|
|
//
|
|
// Select queries
|
|
//
|
|
|
|
PreparedStatement selectSuccessor = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT next
|
|
FROM {}
|
|
WHERE key = ?
|
|
AND seq <= ?
|
|
ORDER BY seq DESC
|
|
LIMIT 1
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "successor")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectDiff = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT key
|
|
FROM {}
|
|
WHERE seq = ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "diff")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectObject = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT object, sequence
|
|
FROM {}
|
|
WHERE key = ?
|
|
AND sequence <= ?
|
|
ORDER BY sequence DESC
|
|
LIMIT 1
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "objects")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectTransaction = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT transaction, metadata, ledger_sequence, date
|
|
FROM {}
|
|
WHERE hash = ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "transactions")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectAllTransactionHashesInLedger = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT hash
|
|
FROM {}
|
|
WHERE ledger_sequence = ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_transactions")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement getToken = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT TOKEN(key)
|
|
FROM {}
|
|
WHERE key = ?
|
|
LIMIT 1
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "objects")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectAccountTx = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT hash, seq_idx
|
|
FROM {}
|
|
WHERE account = ?
|
|
AND seq_idx < ?
|
|
LIMIT ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "account_tx")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectAccountTxForward = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT hash, seq_idx
|
|
FROM {}
|
|
WHERE account = ?
|
|
AND seq_idx > ?
|
|
ORDER BY seq_idx ASC
|
|
LIMIT ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "account_tx")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectNFT = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT sequence, owner, is_burned
|
|
FROM {}
|
|
WHERE token_id = ?
|
|
AND sequence <= ?
|
|
ORDER BY sequence DESC
|
|
LIMIT 1
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_tokens")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectNFTURI = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT uri
|
|
FROM {}
|
|
WHERE token_id = ?
|
|
AND sequence <= ?
|
|
ORDER BY sequence DESC
|
|
LIMIT 1
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_token_uris")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectNFTTx = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT hash, seq_idx
|
|
FROM {}
|
|
WHERE token_id = ?
|
|
AND seq_idx < ?
|
|
ORDER BY seq_idx DESC
|
|
LIMIT ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_token_transactions")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectNFTTxForward = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT hash, seq_idx
|
|
FROM {}
|
|
WHERE token_id = ?
|
|
AND seq_idx >= ?
|
|
ORDER BY seq_idx ASC
|
|
LIMIT ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nf_token_transactions")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectNFTIDsByIssuerTaxon = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT token_id
|
|
FROM {}
|
|
WHERE issuer = ?
|
|
AND taxon = ?
|
|
AND token_id > ?
|
|
ORDER BY taxon ASC, token_id ASC
|
|
LIMIT ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "issuer_nf_tokens_v2")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectMPTHolders = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT holder
|
|
FROM {}
|
|
WHERE mpt_id = ?
|
|
AND holder > ?
|
|
ORDER BY holder ASC
|
|
LIMIT ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "mp_token_holders")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectLedgerByHash = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT sequence
|
|
FROM {}
|
|
WHERE hash = ?
|
|
LIMIT 1
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_hashes")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectLedgerBySeq = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT header
|
|
FROM {}
|
|
WHERE sequence = ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledgers")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectLatestLedger = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT sequence
|
|
FROM {}
|
|
WHERE is_latest = True
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_range")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectLedgerRange = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT sequence
|
|
FROM {}
|
|
WHERE is_latest in (True, False)
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "ledger_range")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectMigratorStatus = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT status
|
|
FROM {}
|
|
WHERE migrator_name = ?
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "migrator_status")
|
|
)
|
|
);
|
|
}();
|
|
|
|
PreparedStatement selectClioNodesData = [this]() {
|
|
return handle_.get().prepare(
|
|
fmt::format(
|
|
R"(
|
|
SELECT node_id, message
|
|
FROM {}
|
|
)",
|
|
qualifiedTableName(settingsProvider_.get(), "nodes_chat")
|
|
)
|
|
);
|
|
}();
|
|
};
|
|
|
|
/**
|
|
* @brief Recreates the prepared statements.
|
|
*
|
|
* @param handle The handle to the DB
|
|
*/
|
|
virtual void
|
|
prepareStatements(Handle const& handle) = 0;
|
|
};
|
|
|
|
} // namespace data::cassandra
|