Struct MongoEngine 

pub struct MongoEngine { /* private fields */ }

MongoDB query engine that implements the Prax QueryEngine trait.

Note: MongoDB is a document database, so the SQL-oriented QueryEngine trait methods are adapted to work with MongoDB operations.

Implementations

impl MongoEngine

pub fn new(client: MongoClient) -> Self

Create a new MongoDB engine with the given client.

pub fn client(&self) -> &MongoClient

Get a reference to the client.

pub fn collection<T>(&self) -> Collection<T>

where T: Model + Send + Sync,

Get a typed collection for a model.

pub fn collection_by_name<T>(&self, name: &str) -> Collection<T>

where T: Send + Sync,

Get a collection by explicit name.

Trait Implementations

impl Clone for MongoEngine

fn clone(&self) -> MongoEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl QueryEngine for MongoEngine

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

Execute a SELECT query and return rows.

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

Execute a SELECT query expecting one result.

fn query_optional<T: Model + 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 + 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 + 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 refresh_materialized_view( &self, view_name: &str, concurrently: bool, ) -> Pin<Box<dyn Future<Output = Result<(), QueryError>> + Send + '_>>

Refresh a materialized view.