Struct mongodb_query_connector::MongoDbConnection

pub struct MongoDbConnection { /* private fields */ }

Trait Implementations

impl Connection for MongoDbConnection

fn start_transaction<'a, 'async_trait>( &'a mut self, isolation_level: Option<String> ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Transaction + 'a>>> + Send + 'async_trait>>where Self: 'async_trait, 'a: 'async_trait,

fn as_connection_like(&mut self) -> &mut dyn ConnectionLike

Explicit upcast.

impl ReadOperations for MongoDbConnection

fn get_single_record<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, model: &'life1 Model, filter: &'life2 Filter, selected_fields: &'life3 FieldSelection, _relation_load_strategy: RelationLoadStrategy, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<Option<SingleRecord>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Gets a single record or None back from the database.

fn get_many_records<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, model: &'life1 Model, query_arguments: QueryArguments, selected_fields: &'life2 FieldSelection, _relation_load_strategy: RelationLoadStrategy, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<ManyRecords>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Gets multiple records from the database.

fn get_related_m2m_record_ids<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, from_field: &'life1 RelationFieldRef, from_record_ids: &'life2 [SelectionResult], _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<Vec<(SelectionResult, SelectionResult)>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Retrieves pairs of IDs that belong together from a intermediate join table.

fn aggregate_records<'life0, 'life1, 'async_trait>( &'life0 mut self, model: &'life1 Model, query_arguments: QueryArguments, selections: Vec<AggregationSelection>, group_by: Vec<ScalarFieldRef>, having: Option<Filter>, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<Vec<AggregationRow>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Aggregates records for a specific model based on the given selections. Whether or not the aggregations can be executed in a single query or requires multiple roundtrips to the underlying data source is at the discretion of the implementing connector. having can only be a scalar filter. Relation elements can be safely ignored.

impl WriteOperations for MongoDbConnection

fn create_record<'life0, 'life1, 'async_trait>( &'life0 mut self, model: &'life1 Model, args: WriteArgs, _selected_fields: FieldSelection, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<SingleRecord>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Insert a single record to the database.

fn create_records<'life0, 'life1, 'async_trait>( &'life0 mut self, model: &'life1 Model, args: Vec<WriteArgs>, skip_duplicates: bool, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Inserts many records at once into the database.

fn update_records<'life0, 'life1, 'async_trait>( &'life0 mut self, model: &'life1 Model, record_filter: RecordFilter, args: WriteArgs, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update records in the Model with the given WriteArgs filtered by the Filter.

fn update_record<'life0, 'life1, 'async_trait>( &'life0 mut self, model: &'life1 Model, record_filter: RecordFilter, args: WriteArgs, selected_fields: Option<FieldSelection>, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<Option<SingleRecord>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update record in the Model with the given WriteArgs filtered by the Filter.

fn delete_records<'life0, 'life1, 'async_trait>( &'life0 mut self, model: &'life1 Model, record_filter: RecordFilter, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete records in the Model with the given Filter.

fn delete_record<'life0, 'life1, 'async_trait>( &'life0 mut self, model: &'life1 Model, record_filter: RecordFilter, selected_fields: FieldSelection, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<SingleRecord>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete single record in the Model with the given Filter. Return selected fields of the deleted record, if the connector supports it. If the connector does not support it, error is returned.

fn m2m_connect<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, field: &'life1 RelationFieldRef, parent_id: &'life2 SelectionResult, child_ids: &'life3 [SelectionResult], _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Connect the children to the parent (m2m relation only).

fn m2m_disconnect<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, field: &'life1 RelationFieldRef, parent_id: &'life2 SelectionResult, child_ids: &'life3 [SelectionResult], _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Disconnect the children from the parent (m2m relation only).

fn execute_raw<'life0, 'async_trait>( &'life0 mut self, inputs: HashMap<String, PrismaValue> ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Execute the raw query in the database as-is. The parsing of the query arguments is deferred to the connectors.

fn query_raw<'life0, 'life1, 'async_trait>( &'life0 mut self, model: Option<&'life1 Model>, inputs: HashMap<String, PrismaValue>, query_type: Option<String> ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute the raw query in the database as-is. The parsing of the query arguments is deferred to the connectors.

fn native_upsert_record<'life0, 'async_trait>( &'life0 mut self, _upsert: NativeUpsert, _trace_id: Option<String> ) -> Pin<Box<dyn Future<Output = Result<SingleRecord>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Native upsert Use the connectors native upsert to upsert the Model

impl ConnectionLike for MongoDbConnection