pub struct QueryEngine { /* private fields */ }Expand description
Legacy query engine wrapper for backward compatibility.
Delegates to AdvancedQueryEngine (re-exported from engine); kept as a
stable public surface used by crate::Database and the CLI’s REPL.
Implementations§
Source§impl QueryEngine
impl QueryEngine
Sourcepub fn new(
storage: Arc<StorageEngine>,
schema: Arc<SchemaManager>,
memory: Arc<MemoryManager>,
config: &Config,
) -> Result<Self>
pub fn new( storage: Arc<StorageEngine>, schema: Arc<SchemaManager>, memory: Arc<MemoryManager>, config: &Config, ) -> Result<Self>
Create a new query engine.
Sourcepub async fn execute(&self, cql: &str) -> Result<QueryResult>
pub async fn execute(&self, cql: &str) -> Result<QueryResult>
Execute a CQL query
Sourcepub async fn prepare(&self, cql: &str) -> Result<Arc<PreparedQuery>>
pub async fn prepare(&self, cql: &str) -> Result<Arc<PreparedQuery>>
Prepare a query for repeated execution
Sourcepub fn stats(&self) -> QueryStats
pub fn stats(&self) -> QueryStats
Get query statistics
Sourcepub fn clear_cache(&self)
pub fn clear_cache(&self)
Clear prepared statement cache
Sourcepub async fn explain(&self, cql: &str) -> Result<ExplainResult>
pub async fn explain(&self, cql: &str) -> Result<ExplainResult>
Explain a query
Sourcepub async fn analyze(&self, cql: &str) -> Result<AnalyzeResult>
pub async fn analyze(&self, cql: &str) -> Result<AnalyzeResult>
Analyze query performance
Sourcepub async fn execute_streaming(
&self,
cql: &str,
config: StreamingConfig,
) -> Result<QueryResultIterator>
pub async fn execute_streaming( &self, cql: &str, config: StreamingConfig, ) -> Result<QueryResultIterator>
Execute a CQL query with streaming results (Issue #280)
Returns a QueryResultIterator that yields rows incrementally via a bounded
channel, enabling memory-efficient processing of large result sets.
Sourcepub fn cache_stats(&self) -> CacheStats
pub fn cache_stats(&self) -> CacheStats
Get cache statistics
Sourcepub async fn has_schema_for_table(&self, table: &str) -> bool
pub async fn has_schema_for_table(&self, table: &str) -> bool
Check if schema is available for a table
Sourcepub async fn schema_status(&self, table: &str) -> SchemaStatus
pub async fn schema_status(&self, table: &str) -> SchemaStatus
Get detailed schema status for debugging
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for QueryEngine
impl !UnwindSafe for QueryEngine
impl Freeze for QueryEngine
impl Send for QueryEngine
impl Sync for QueryEngine
impl Unpin for QueryEngine
impl UnsafeUnpin for QueryEngine
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more