Struct MongoSelect 

pub struct MongoSelect {
    pub collection: Option<String>,
    pub fields: Vec<String>,
    pub conditions: Vec<MongoCondition>,
    pub sort: Vec<(String, i32)>,
    pub group_by: Vec<String>,
    pub distinct: bool,
    pub limit: Option<i64>,
    pub skip: Option<i64>,
}

MongoDB query builder — the equivalent of SqliteSelect / SurrealSelect.

Instead of rendering SQL, it accumulates native bson::Document parts that map directly onto the mongodb driver’s find/aggregate API.

Fields

collection: Option<String>

Collection name (equivalent to FROM).

fields: Vec<String>

Field names to include in projection. Empty = all fields.

conditions: Vec<MongoCondition>

Filter conditions (combined with $and at resolve time).

sort: Vec<(String, i32)>

Sort specification: field name → 1 (asc) or -1 (desc).

group_by: Vec<String>

GROUP BY fields (for aggregation pipeline).

distinct: bool

Whether to return distinct results.

limit: Option<i64>

Max number of documents to return.

skip: Option<i64>

Number of documents to skip.

Implementations

impl MongoSelect

pub async fn build_filter(&self) -> Result<Document>

Build the filter Document by resolving all conditions.

pub fn build_projection(&self) -> Option<Document>

Build the projection Document. Returns None if all fields requested.

pub fn build_sort(&self) -> Option<Document>

Build the sort Document. Returns None if no ordering.

pub fn build_find_options(&self) -> FindOptions

Build mongodb::options::FindOptions from the current state.

impl MongoSelect

pub async fn as_count_pipeline(&self) -> Result<Vec<Document>>

Build a count aggregation pipeline: [$match, $count].

pub async fn as_aggregate_pipeline( &self, func: &str, field: &str, ) -> Result<Vec<Document>>

Build a $group aggregation pipeline with an accumulator. func is e.g. “$sum”, “$max”, “$min”. field is the column name.

impl MongoSelect

pub fn preview(&self) -> String

Render a human-readable preview string (for debug/logging).

impl MongoSelect

pub fn new() -> Self

Trait Implementations

impl Clone for MongoSelect

fn clone(&self) -> MongoSelect

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MongoSelect

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MongoSelect

fn default() -> MongoSelect

Returns the “default value” for a type.

impl Selectable<AnyMongoType, MongoCondition> for MongoSelect

fn add_source( &mut self, source: impl Into<SourceRef<AnyMongoType>>, _alias: Option<String>, )

Adds a data source to the FROM clause (table name, subquery, etc.). This is additive — calling it multiple times adds comma-separated sources.

fn add_field(&mut self, field: impl Into<String>)

Adds a column name to the SELECT clause.

fn add_expression(&mut self, _expression: impl Expressive<AnyMongoType>)

Adds a complex expression to the SELECT clause.

fn add_where_condition(&mut self, condition: impl Into<MongoCondition>)

Adds a condition to the WHERE clause.

fn set_distinct(&mut self, distinct: bool)

Sets whether the query should return distinct results.

fn add_order_by(&mut self, order: impl Into<MongoCondition>, direction: Order)

Adds an ORDER BY clause with direction and optional null handling.

fn add_group_by(&mut self, expression: impl Expressive<AnyMongoType>)

Adds a GROUP BY clause.

fn set_limit(&mut self, limit: Option<i64>, skip: Option<i64>)

Sets LIMIT and OFFSET for result pagination.

fn clear_fields(&mut self)

Removes all fields from the SELECT clause.

fn clear_where_conditions(&mut self)

Removes all WHERE conditions.

fn clear_order_by(&mut self)

Removes all ORDER BY clauses.

fn clear_group_by(&mut self)

Removes all GROUP BY clauses.

fn has_fields(&self) -> bool

Returns true if any fields have been added to SELECT clause.

fn has_where_conditions(&self) -> bool

Returns true if any WHERE conditions have been added.

fn has_order_by(&self) -> bool

Returns true if any ORDER BY clauses have been added.

fn has_group_by(&self) -> bool

Returns true if any GROUP BY clauses have been added.

fn is_distinct(&self) -> bool

Returns true if DISTINCT mode is enabled.

fn get_limit(&self) -> Option<i64>

Returns the current LIMIT value, if set.

fn get_skip(&self) -> Option<i64>

Returns the current OFFSET/SKIP value, if set.

fn as_field(&self, _field: impl Into<String>) -> Expression<AnyMongoType>

Creates a single-field subquery expression from this query configuration.

fn as_count(&self) -> Expression<AnyMongoType>

Creates a COUNT(*) expression from this query configuration.

fn as_sum( &self, column: impl Expressive<AnyMongoType>, ) -> Expression<AnyMongoType>

Creates a SUM(column) expression from this query configuration.

fn as_max( &self, column: impl Expressive<AnyMongoType>, ) -> Expression<AnyMongoType>

Creates a MAX(column) expression from this query configuration.

fn as_min( &self, column: impl Expressive<AnyMongoType>, ) -> Expression<AnyMongoType>

Creates a MIN(column) expression from this query configuration.

fn with_source(self, source: impl Into<SourceRef<T>>) -> Self

where Self: Sized,

Builder pattern method identical to Self::add_source without alias.

fn with_source_as( self, source: impl Into<SourceRef<T>>, alias: impl Into<String>, ) -> Self

where Self: Sized,

Builder pattern method identical to Self::add_source with alias.

fn with_condition(self, condition: impl Into<C>) -> Self

where Self: Sized,

Builder pattern method identical to Self::add_where_condition.

fn with_order(self, order: impl Into<C>, direction: Order) -> Self

where Self: Sized,

Builder pattern method identical to Self::add_order_by.

fn with_field(self, field: impl Into<String>) -> Self

where Self: Sized,

Builder pattern method identical to Self::add_field.

fn with_expression(self, expression: impl Expressive<T>) -> Self

where Self: Sized,

Builder pattern method identical to Self::add_expression.

fn with_group_by(self, expression: impl Expressive<T>) -> Self

where Self: Sized,

Builder pattern method identical to Self::add_group_by.

fn with_distinct(self, distinct: bool) -> Self

where Self: Sized,

Builder pattern method identical to Self::set_distinct.

fn with_limit(self, limit: Option<i64>, skip: Option<i64>) -> Self

where Self: Sized,

Builder pattern method identical to Self::set_limit.