Struct PreparedQueries

pub(crate) struct PreparedQueries {

    select_txo_ada: PreparedStatement,
    delete_txo_ada: SkipMap<u16, Arc<Batch>>,
    select_txo_assets: PreparedStatement,
    delete_txo_assets: SkipMap<u16, Arc<Batch>>,
    select_unstaked_txo_ada: PreparedStatement,
    delete_unstaked_txo_ada: SkipMap<u16, Arc<Batch>>,
    select_unstaked_txo_assets: PreparedStatement,
    delete_unstaked_txo_assets: SkipMap<u16, Arc<Batch>>,
    select_txi_by_hash: PreparedStatement,
    delete_txi_by_hash: SkipMap<u16, Arc<Batch>>,
    select_stake_registration: PreparedStatement,
    delete_stake_registration: SkipMap<u16, Arc<Batch>>,
    select_cip36_registration: PreparedStatement,
    delete_cip36_registration: SkipMap<u16, Arc<Batch>>,
    select_cip36_registration_invalid: PreparedStatement,
    delete_cip36_registration_invalid: SkipMap<u16, Arc<Batch>>,
    select_cip36_registration_for_vote_key: PreparedStatement,
    delete_cip36_registration_for_vote_key: SkipMap<u16, Arc<Batch>>,
    select_rbac509_registration: PreparedStatement,
    delete_rbac509_registration: SkipMap<u16, Arc<Batch>>,
    select_chain_root_for_txn_id: PreparedStatement,
    delete_chain_root_for_txn_id: SkipMap<u16, Arc<Batch>>,
    select_chain_root_for_role0_key: PreparedStatement,
    delete_chain_root_for_role0_key: SkipMap<u16, Arc<Batch>>,
    select_chain_root_for_stake_address: PreparedStatement,
    delete_chain_root_for_stake_address: SkipMap<u16, Arc<Batch>>,
}

All prepared purge queries for a session.

Fields

select_txo_ada: PreparedStatement

TXO ADA Primary Key Query.

delete_txo_ada: SkipMap<u16, Arc<Batch>>

TXO Delete Query.

select_txo_assets: PreparedStatement

TXO Asset Primary Key Query.

delete_txo_assets: SkipMap<u16, Arc<Batch>>

TXO Assets Delete Query.

select_unstaked_txo_ada: PreparedStatement

Unstaked TXO ADA Primary Key Query.

delete_unstaked_txo_ada: SkipMap<u16, Arc<Batch>>

Unstaked TXO ADA Delete Query.

select_unstaked_txo_assets: PreparedStatement

Unstaked TXO Assets Primary Key Query.

delete_unstaked_txo_assets: SkipMap<u16, Arc<Batch>>

Unstaked TXO Asset Delete Query.

select_txi_by_hash: PreparedStatement

TXI by TXN Hash by TXN Hash Primary Key Query.

delete_txi_by_hash: SkipMap<u16, Arc<Batch>>

TXI by TXN Hash Delete Query.

select_stake_registration: PreparedStatement

Stake Registration Primary Key Query.

delete_stake_registration: SkipMap<u16, Arc<Batch>>

Stake Registration Delete Query.

select_cip36_registration: PreparedStatement

CIP36 Registrations Primary Key Query.

delete_cip36_registration: SkipMap<u16, Arc<Batch>>

CIP36 Registrations Delete Query.

select_cip36_registration_invalid: PreparedStatement

CIP36 Registration Invalid Primary Key Query.

delete_cip36_registration_invalid: SkipMap<u16, Arc<Batch>>

CIP36 Registration Invalid Delete Query.

select_cip36_registration_for_vote_key: PreparedStatement

CIP36 Registration for Vote Key Primary Key Query.

delete_cip36_registration_for_vote_key: SkipMap<u16, Arc<Batch>>

CIP36 Registration for Vote Key Delete Query.

select_rbac509_registration: PreparedStatement

RBAC 509 Registrations Primary Key Query.

delete_rbac509_registration: SkipMap<u16, Arc<Batch>>

RBAC 509 Registrations Delete Query.

select_chain_root_for_txn_id: PreparedStatement

Chain Root for TX ID Primary Key Query..

delete_chain_root_for_txn_id: SkipMap<u16, Arc<Batch>>

Chain Root for TX ID Delete Query..

select_chain_root_for_role0_key: PreparedStatement

Chain Root for Role 0 Key Primary Key Query..

delete_chain_root_for_role0_key: SkipMap<u16, Arc<Batch>>

Chain Root for Role 0 Key Delete Query..

select_chain_root_for_stake_address: PreparedStatement

Chain Root for Stake Address Primary Key Query..

delete_chain_root_for_stake_address: SkipMap<u16, Arc<Batch>>

Chain Root for Stake Address Delete Query..

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_iter( &self, session: Arc<Session>, select_query: PreparedSelectQuery, ) -> Result<QueryPager>

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: PreparedDeleteQuery, values: Vec<T>, ) -> Result<Vec<QueryResult>>

Execute a purge query with the given parameters.