Struct QueryExecutor 

pub struct QueryExecutor { /* private fields */ }

Implementations

impl QueryExecutor

pub async fn new(storage: Arc<Storage>) -> Result<Self>

pub fn with_timeout(self, timeout: Duration) -> Self

pub fn storage(&self) -> &Arc<Storage>

pub async fn execute(&self, statement: &Statement) -> Result<QueryResult>

impl QueryExecutor

pub async fn execute_recursive_cte( &self, db: &Database, cte: &Cte, cte_results: &HashMap<String, QueryResult>, ) -> Result<QueryResult>

Execute a RECURSIVE CTE

RECURSIVE CTEs work by:

1. Executing the base case (non-recursive part)
2. Iteratively executing the recursive part using previous results
3. Continuing until no new rows are produced
4. Combining all results

Trait Implementations

impl Clone for QueryExecutor

fn clone(&self) -> QueryExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.