Struct PreparedQueries

pub(crate) struct PreparedQueries {

    txo_insert_queries: SkipMap<u16, Arc<Batch>>,
    txo_asset_insert_queries: SkipMap<u16, Arc<Batch>>,
    unstaked_txo_insert_queries: SkipMap<u16, Arc<Batch>>,
    unstaked_txo_asset_insert_queries: SkipMap<u16, Arc<Batch>>,
    txi_insert_queries: SkipMap<u16, Arc<Batch>>,
    stake_registration_insert_queries: SkipMap<u16, Arc<Batch>>,
    cip36_registration_insert_queries: SkipMap<u16, Arc<Batch>>,
    cip36_registration_error_insert_queries: SkipMap<u16, Arc<Batch>>,
    cip36_registration_for_stake_address_insert_queries: SkipMap<u16, Arc<Batch>>,
    txo_spent_update_queries: SkipMap<u16, Arc<Batch>>,
    txo_by_stake_address_query: PreparedStatement,
    txi_by_txn_hash_query: PreparedStatement,
    rbac509_registration_insert_queries: SkipMap<u16, Arc<Batch>>,
    chain_root_for_txn_id_insert_queries: SkipMap<u16, Arc<Batch>>,
    chain_root_for_role0_key_insert_queries: SkipMap<u16, Arc<Batch>>,
    chain_root_for_stake_address_insert_queries: SkipMap<u16, Arc<Batch>>,
    native_assets_by_stake_address_query: PreparedStatement,
    registration_from_stake_addr_query: PreparedStatement,
    stake_addr_from_stake_hash_query: PreparedStatement,
    stake_addr_from_vote_key_query: PreparedStatement,
    invalid_registrations_from_stake_addr_query: PreparedStatement,
    sync_status_insert: PreparedStatement,
    chain_root_by_stake_address_query: PreparedStatement,
    registrations_by_chain_root_query: PreparedStatement,
    chain_root_by_role0_key_query: PreparedStatement,
    get_all_stakes_and_vote_keys_query: PreparedStatement,
}

All prepared queries for a session.

Fields

txo_insert_queries: SkipMap<u16, Arc<Batch>>

TXO Insert query.

txo_asset_insert_queries: SkipMap<u16, Arc<Batch>>

TXO Asset Insert query.

unstaked_txo_insert_queries: SkipMap<u16, Arc<Batch>>

Unstaked TXO Insert query.

unstaked_txo_asset_insert_queries: SkipMap<u16, Arc<Batch>>

Unstaked TXO Asset Insert query.

txi_insert_queries: SkipMap<u16, Arc<Batch>>

TXI Insert query.

stake_registration_insert_queries: SkipMap<u16, Arc<Batch>>

TXI Insert query.

cip36_registration_insert_queries: SkipMap<u16, Arc<Batch>>

CIP36 Registrations.

cip36_registration_error_insert_queries: SkipMap<u16, Arc<Batch>>

CIP36 Registration errors.

cip36_registration_for_stake_address_insert_queries: SkipMap<u16, Arc<Batch>>

CIP36 Registration for Stake Address Insert query.

txo_spent_update_queries: SkipMap<u16, Arc<Batch>>

Update TXO spent query.

txo_by_stake_address_query: PreparedStatement

Get TXO by stake address query.

txi_by_txn_hash_query: PreparedStatement

Get TXI by transaction hash.

rbac509_registration_insert_queries: SkipMap<u16, Arc<Batch>>

RBAC 509 Registrations.

chain_root_for_txn_id_insert_queries: SkipMap<u16, Arc<Batch>>

Chain Root for TX ID Insert Query..

chain_root_for_role0_key_insert_queries: SkipMap<u16, Arc<Batch>>

Chain Root for Role 0 Key Insert Query..

chain_root_for_stake_address_insert_queries: SkipMap<u16, Arc<Batch>>

Chain Root for Stake Address Insert Query..

native_assets_by_stake_address_query: PreparedStatement

Get native assets by stake address query.

registration_from_stake_addr_query: PreparedStatement

Get registrations

stake_addr_from_stake_hash_query: PreparedStatement

stake addr from stake hash

stake_addr_from_vote_key_query: PreparedStatement

stake addr from vote key

invalid_registrations_from_stake_addr_query: PreparedStatement

Get invalid registrations

sync_status_insert: PreparedStatement

Insert Sync Status update.

chain_root_by_stake_address_query: PreparedStatement

Get chain root by stake address

registrations_by_chain_root_query: PreparedStatement

Get registrations by chain root

chain_root_by_role0_key_query: PreparedStatement

Get chain root by role0 key

get_all_stakes_and_vote_keys_query: PreparedStatement

Get all stake and vote keys (stake_key,vote_key) for snapshot

Implementations

impl PreparedQueries

pub(crate) async fn new(session: Arc<Session>, cfg: &EnvVars) -> Result<Self>

Create new prepared queries for a given session.

pub(crate) async fn prepare( session: Arc<Session>, query: &str, consistency: Consistency, idempotent: bool, ) -> Result<PreparedStatement>

Prepares a statement.

pub(crate) async fn prepare_batch( session: Arc<Session>, query: &str, cfg: &EnvVars, consistency: Consistency, idempotent: bool, logged: bool, ) -> Result<SkipMap<u16, Arc<Batch>>>

Prepares all permutations of the batch from 1 to max. It is necessary to do this because batches are pre-sized, they can not be dynamic. Preparing the batches in advance is a very larger performance increase.

pub(crate) async fn execute_upsert<P>( &self, session: Arc<Session>, upsert_query: PreparedUpsertQuery, params: P, ) -> Result<()>

where P: SerializeRow,

Executes a single query with the given parameters.

Returns no data, and an error if the query fails.

pub(crate) async fn execute_iter<P>( &self, session: Arc<Session>, select_query: PreparedSelectQuery, params: P, ) -> Result<QueryPager>

where P: SerializeRow,

Executes a select query with the given parameters.

Returns an iterator that iterates over all the result pages that the query returns.

pub(crate) async fn execute_batch<T: SerializeRow + Debug>( &self, session: Arc<Session>, cfg: Arc<EnvVars>, query: PreparedQuery, values: Vec<T>, ) -> Result<Vec<QueryResult>>

Execute a Batch query with the given parameters.

Values should be a Vec of values which implement SerializeRow and they MUST be the same, and must match the query being executed.

This will divide the batch into optimal sized chunks and execute them until all values have been executed or the first error is encountered.