Struct MongoAdapter 

pub struct MongoAdapter { /* private fields */ }

Implementations

impl MongoAdapter

pub async fn connect(uri: &str, database: &str) -> Result<Self, ParseError>

Trait Implementations

impl StorageAdapter for MongoAdapter

async fn all_schemas(&self) -> Result<Vec<ClassSchema>, ParseError>

Load every class schema. Upstream has no per-class fetch: a miss on any class triggers a full getAllClasses, and reproducing that shape keeps the caching behavior comparable.

async fn upsert_schema(&self, schema: &ClassSchema) -> Result<(), ParseError>

Persist a class schema, creating the class if it does not exist.

async fn create( &self, schema: &ClassSchema, row: &Row, ) -> Result<WriteResult, ParseError>

Insert one row. object_id is generated by the caller, not the adapter, because it is part of the Parse contract rather than a storage detail.

async fn find( &self, schema: &ClassSchema, constraints: &[Constraint], options: &QueryOptions, ) -> Result<Vec<Row>, ParseError>

Find rows matching every constraint.

async fn count( &self, schema: &ClassSchema, constraints: &[Constraint], ) -> Result<u64, ParseError>

Count rows matching every constraint.

async fn update( &self, schema: &ClassSchema, constraints: &[Constraint], values: &Row, ) -> Result<u64, ParseError>

Update matching rows with the given field values.

async fn delete( &self, schema: &ClassSchema, constraints: &[Constraint], ) -> Result<u64, ParseError>

Delete matching rows. Returns how many, for the same reason as update.

async fn ensure_unique_index( &self, class_name: &str, fields: &[&str], name: Option<&str>, ) -> Result<(), ParseError>

Create a unique index.