Struct scylla::CachingSession

pub struct CachingSession {
    pub session: Session,
    pub max_capacity: usize,
    pub cache: DashMap<String, PreparedStatement>,
}

Provides auto caching while executing queries

Fields

session: Session

max_capacity: usize

The prepared statement cache size If a prepared statement is added while the limit is reached, the oldest prepared statement is removed from the cache

cache: DashMap<String, PreparedStatement>

Implementations

impl CachingSession

pub fn from(session: Session, cache_size: usize) -> Self

pub async fn execute(
    &self,
    query: impl Into<Query>,
    values: impl ValueList
) -> Result<QueryResult, QueryError>

Does the same thing as Session::execute but uses the prepared statement cache

pub async fn execute_iter(
    &self,
    query: impl Into<Query>,
    values: impl ValueList
) -> Result<RowIterator, QueryError>

Does the same thing as Session::execute_iter but uses the prepared statement cache

pub async fn execute_paged(
    &self,
    query: impl Into<Query>,
    values: impl ValueList,
    paging_state: Option<Bytes>
) -> Result<QueryResult, QueryError>

Does the same thing as Session::execute_paged but uses the prepared statement cache

pub async fn add_prepared_statement(
    &self,
    query: impl Into<&Query>
) -> Result<PreparedStatement, QueryError>

Adds a prepared statement to the cache

Trait Implementations

impl Debug for CachingSession

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.