Struct DbSetQuery 

pub struct DbSetQuery<E: Entity> { /* private fields */ }

Fluent query builder bound to one DbSet<E>.

DbSetQuery stores query intent as AST until execution. SQL text is generated only by the SQL Server compiler. Mandatory runtime policies such as tenant filtering and root-entity soft-delete visibility are applied when the query is compiled or executed.

Implementations

impl<E: Entity> DbSetQuery<E>

pub fn with_select_query(self, select_query: SelectQuery) -> Self

Replaces the underlying SelectQuery AST while keeping this query bound to the same connection and runtime policies.

pub fn filter(self, predicate: Predicate) -> Self

Adds a predicate to the query.

pub fn join(self, join: Join) -> Self

Adds an explicit join described by the query AST.

pub fn inner_join<J: Entity>(self, on: Predicate) -> Self

Adds an explicit INNER JOIN to another entity.

pub fn left_join<J: Entity>(self, on: Predicate) -> Self

Adds an explicit LEFT JOIN to another entity.

pub fn try_inner_join_navigation<J: Entity>( self, navigation: &'static str, ) -> Result<Self, OrmError>

Adds an INNER JOIN inferred from navigation metadata.

The navigation must be declared on the root entity E, and its target table must match J. This only builds the SQL join; it does not load or materialize the related entity.

pub fn try_left_join_navigation<J: Entity>( self, navigation: &'static str, ) -> Result<Self, OrmError>

Adds a LEFT JOIN inferred from navigation metadata.

The navigation must be declared on the root entity E, and its target table must match J. This only builds the SQL join; it does not load or materialize the related entity.

pub fn try_inner_join_navigation_as<J: Entity>( self, navigation: &'static str, alias: &'static str, ) -> Result<Self, OrmError>

Adds an aliased INNER JOIN inferred from navigation metadata.

pub fn try_left_join_navigation_as<J: Entity>( self, navigation: &'static str, alias: &'static str, ) -> Result<Self, OrmError>

Adds an aliased LEFT JOIN inferred from navigation metadata.

pub fn include<J: Entity>( self, navigation: &'static str, ) -> Result<DbSetQueryIncludeOne<E, J>, OrmError>

Includes a single related entity through a belongs_to or has_one navigation.

This first eager-loading cut uses a left join and materializes the related row into Navigation<J>. Collection navigations (has_many) are intentionally rejected because they need grouping or split-query semantics.

pub fn include_as<J: Entity>( self, navigation: &'static str, alias: &'static str, ) -> Result<DbSetQueryIncludeOne<E, J>, OrmError>

Includes a single related entity using an explicit table alias.

pub fn include_many<J: Entity>( self, navigation: &'static str, ) -> Result<DbSetQueryIncludeMany<E, J>, OrmError>

Includes a collection navigation through a has_many relationship.

This first collection include cut uses a left join, materializes joined rows, then groups them by the root entity primary key before assigning Collection<J>. Pagination is rejected for this join-based path because limiting joined rows is not equivalent to limiting root entities.

pub fn include_many_as<J: Entity>( self, navigation: &'static str, alias: &'static str, ) -> Result<DbSetQueryIncludeMany<E, J>, OrmError>

Includes a collection navigation using an explicit table alias.

pub fn order_by(self, order: OrderBy) -> Self

Adds an ordering expression.

pub fn limit(self, limit: u64) -> Self

Limits the number of returned rows with zero offset.

pub fn take(self, limit: u64) -> Self

Alias for limit(...).

pub fn paginate(self, request: PageRequest) -> Self

Applies page-based pagination.

pub fn select<P>(self, projection: P) -> Self

where P: SelectProjections,

Selects an explicit projection instead of materializing full entities.

Use all_as::<T>() or first_as::<T>() to materialize the projection into a DTO implementing FromRow.

pub fn group_by<G>(self, group_by: G) -> Result<DbSetGroupedQuery<E>, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity, G: GroupByExpressions,

Starts a grouped aggregate query over one or more group key expressions.

The returned builder materializes DTOs through all_as::<T>() and first_as::<T>(); it does not expose full-entity materialization.

pub fn with_deleted(self) -> Self

Includes logically deleted rows for entities with soft_delete.

This affects only the root entity E, not every manually joined entity.

pub fn only_deleted(self) -> Self

Returns only logically deleted rows for entities with soft_delete.

This affects only the root entity E, not every manually joined entity.

pub async fn all(self) -> Result<Vec<E>, OrmError>

where E: FromRow + Send + SoftDeleteEntity + TenantScopedEntity,

Executes the query and materializes full entities.

pub async fn first(self) -> Result<Option<E>, OrmError>

where E: FromRow + Send + SoftDeleteEntity + TenantScopedEntity,

Executes the query and materializes the first full entity, if any.

pub async fn all_as<T>(self) -> Result<Vec<T>, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity, T: FromRow + Send,

Executes the query and materializes projected rows as DTOs.

pub async fn first_as<T>(self) -> Result<Option<T>, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity, T: FromRow + Send,

Executes the query and materializes the first projected DTO, if any.

pub async fn count(self) -> Result<i64, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity,

Executes the query as a COUNT(*) over the effective filters.

pub async fn exists(self) -> Result<bool, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity,

Executes the query as an EXISTS predicate over the effective filters.

pub async fn any(self) -> Result<bool, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity,

Alias for exists().

pub async fn sum<T>( self, column: impl Into<Expr>, ) -> Result<Option<T>, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity, T: SqlTypeMapping + Send,

Executes the query as a scalar SUM(...) aggregate.

pub async fn avg<T>( self, column: impl Into<Expr>, ) -> Result<Option<T>, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity, T: SqlTypeMapping + Send,

Executes the query as a scalar AVG(...) aggregate.

pub async fn min<T>( self, column: impl Into<Expr>, ) -> Result<Option<T>, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity, T: SqlTypeMapping + Send,

Executes the query as a scalar MIN(...) aggregate.

pub async fn max<T>( self, column: impl Into<Expr>, ) -> Result<Option<T>, OrmError>

where E: SoftDeleteEntity + TenantScopedEntity, T: SqlTypeMapping + Send,

Executes the query as a scalar MAX(...) aggregate.

Trait Implementations

impl<E: Clone + Entity> Clone for DbSetQuery<E>

fn clone(&self) -> DbSetQuery<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Entity> Debug for DbSetQuery<E>

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

Formats the value using the given formatter.