Struct QueryResultCache 

pub struct QueryResultCache { /* private fields */ }

Thread-safe cache for query results

Caches the actual result rows and schema from SELECT queries. Results are invalidated when any referenced table is modified.

Implementations

impl QueryResultCache

pub fn new(max_size: usize) -> Self

Create a new result cache with specified max size

pub fn get( &self, signature: &QuerySignature, ) -> Option<(Vec<Row>, CombinedSchema)>

Try to get cached result for a query

pub fn insert( &self, signature: QuerySignature, rows: Vec<Row>, schema: CombinedSchema, tables: HashSet<String>, )

Insert query result into cache with table dependencies

pub fn contains(&self, signature: &QuerySignature) -> bool

Check if signature is cached

pub fn clear(&self)

Clear all cached results

pub fn invalidate_table(&self, table: &str)

Invalidate all queries touching a specific table

This should be called when a table is modified (INSERT/UPDATE/DELETE)

pub fn invalidate_all(&self)

Invalidate entire cache (e.g., on any write when not tracking dependencies)

pub fn stats(&self) -> CacheStats

Get cache statistics

pub fn max_size(&self) -> usize

Get maximum cache size