Struct CassandraEngine 

pub struct CassandraEngine { /* private fields */ }

Top-level query engine for the Cassandra driver.

Thin wrapper around CassandraPool that lets #[derive(Model)]- generated Client<E> target Cassandra through the same codegen pipeline the SQL drivers use. Routes SELECT/DELETE through the real cdrs-tokio session; execute_update runs the UPDATE then re- SELECTs rows matching the WHERE clause; execute_insert currently returns [QueryError::unsupported] — the pool’s query/execute API doesn’t accept bound params yet, so a safe PK-keyed follow-up SELECT isn’t possible. Prefer [prax_scylladb::ScyllaEngine] for typed Client inserts against any CQL-compatible cluster.

Implementations

impl CassandraEngine

pub fn new(pool: CassandraPool) -> Self

Create a new engine wrapping the given pool.

pub fn pool(&self) -> &CassandraPool

Borrow the underlying pool. Exposed for callers that need to reach the raw query/execute/batch helpers directly.

Trait Implementations

impl Clone for CassandraEngine

fn clone(&self) -> CassandraEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl QueryEngine for CassandraEngine

fn dialect(&self) -> &dyn SqlDialect

The SQL dialect this engine targets.

fn query_many<T: Model + FromRow + Send + 'static>( &self, sql: &str, _params: Vec<FilterValue>, ) -> BoxFuture<'_, QueryResult<Vec<T>>>

Execute a SELECT query and return rows.

fn query_one<T: Model + FromRow + Send + 'static>( &self, sql: &str, _params: Vec<FilterValue>, ) -> BoxFuture<'_, QueryResult<T>>

Execute a SELECT query expecting one result.

fn query_optional<T: Model + FromRow + Send + 'static>( &self, sql: &str, _params: Vec<FilterValue>, ) -> BoxFuture<'_, QueryResult<Option<T>>>

Execute a SELECT query expecting zero or one result.

fn execute_insert<T: Model + FromRow + Send + 'static>( &self, sql: &str, _params: Vec<FilterValue>, ) -> BoxFuture<'_, QueryResult<T>>

Execute an INSERT query and return the created row.

fn execute_update<T: Model + FromRow + Send + 'static>( &self, sql: &str, _params: Vec<FilterValue>, ) -> BoxFuture<'_, QueryResult<Vec<T>>>

Execute an UPDATE query and return affected rows.

fn execute_delete( &self, sql: &str, _params: Vec<FilterValue>, ) -> BoxFuture<'_, QueryResult<u64>>

Execute a DELETE query and return affected rows count.

fn execute_raw( &self, sql: &str, params: Vec<FilterValue>, ) -> BoxFuture<'_, QueryResult<u64>>

Execute a raw SQL query.

fn count( &self, sql: &str, _params: Vec<FilterValue>, ) -> BoxFuture<'_, QueryResult<u64>>

Get a count of records.

fn aggregate_query( &self, sql: &str, params: Vec<FilterValue>, ) -> Pin<Box<dyn Future<Output = Result<Vec<HashMap<String, FilterValue>>, QueryError>> + Send + '_>>

Execute an aggregate query (COUNT/SUM/AVG/MIN/MAX/GROUP BY) and return one map of column name → crate::filter::FilterValue per result row.

fn refresh_materialized_view( &self, view_name: &str, concurrently: bool, ) -> Pin<Box<dyn Future<Output = Result<(), QueryError>> + Send + '_>>

Refresh a materialized view.

fn transaction<'a, R, Fut, F>( &'a self, f: F, ) -> Pin<Box<dyn Future<Output = Result<R, QueryError>> + Send + 'a>>

where F: FnOnce(Self) -> Fut + Send + 'a, Fut: Future<Output = Result<R, QueryError>> + Send + 'a, R: Send + 'a, Self: Clone,

Run the closure inside a transaction.