Struct EsQuery 

pub struct EsQuery<'q, Repo, Flavor, F, A> { /* private fields */ }

Query builder for event-sourced entities.

This type is generated by the es_query! macro and should not be constructed directly. It wraps a SQLx query and provides methods to fetch and hydrate entities from their events.

Implementations

impl<'q, Repo, Flavor, F, A> EsQuery<'q, Repo, Flavor, F, A>

where Repo: EsRepo, <<<Repo as EsRepo>::Entity as EsEntity>::Event as EsEvent>::EntityId: Unpin, F: FnMut(PgRow) -> Result<GenericEvent<<<<Repo as EsRepo>::Entity as EsEntity>::Event as EsEvent>::EntityId>, Error> + Send, A: 'q + Send + IntoArguments<'q, Postgres>,

pub fn new(query: Map<'q, Postgres, F, A>) -> Self

impl<'q, Repo, F, A> EsQuery<'q, Repo, EsQueryFlavorFlat, F, A>

where Repo: EsRepo, <<<Repo as EsRepo>::Entity as EsEntity>::Event as EsEvent>::EntityId: Unpin, F: FnMut(PgRow) -> Result<GenericEvent<<<<Repo as EsRepo>::Entity as EsEntity>::Event as EsEvent>::EntityId>, Error> + Send, A: 'q + Send + IntoArguments<'q, Postgres>,

pub async fn fetch_optional( self, op: impl IntoOneTimeExecutor<'_>, ) -> Result<Option<<Repo as EsRepo>::Entity>, <Repo as EsRepo>::Err>

Fetches at most one entity from the query results.

Returns Ok(None) if no entities match the query, or Ok(Some(entity)) if found.

pub async fn fetch_one( self, op: impl IntoOneTimeExecutor<'_>, ) -> Result<<Repo as EsRepo>::Entity, <Repo as EsRepo>::Err>

Fetches exactly one entity from the query results.

Returns an error if no entities match or if the entity cannot be loaded.

pub async fn fetch_n( self, op: impl IntoOneTimeExecutor<'_>, first: usize, ) -> Result<(Vec<<Repo as EsRepo>::Entity>, bool), <Repo as EsRepo>::Err>

Fetches up to first entities from the query results.

Returns a tuple of (entities, has_more) where has_more indicates if there were more entities available beyond the requested limit.

impl<'q, Repo, F, A> EsQuery<'q, Repo, EsQueryFlavorNested, F, A>

where Repo: EsRepo, <<<Repo as EsRepo>::Entity as EsEntity>::Event as EsEvent>::EntityId: Unpin, F: FnMut(PgRow) -> Result<GenericEvent<<<<Repo as EsRepo>::Entity as EsEntity>::Event as EsEvent>::EntityId>, Error> + Send, A: 'q + Send + IntoArguments<'q, Postgres>,

pub async fn fetch_optional<OP>( self, op: &mut OP, ) -> Result<Option<<Repo as EsRepo>::Entity>, <Repo as EsRepo>::Err>

where OP: AtomicOperation,

Fetches at most one entity and loads all nested relationships.

Returns Ok(None) if no entities match, or Ok(Some(entity)) with all nested entities loaded if found.

pub async fn fetch_one<OP>( self, op: &mut OP, ) -> Result<<Repo as EsRepo>::Entity, <Repo as EsRepo>::Err>

where OP: AtomicOperation,

Fetches exactly one entity and loads all nested relationships.

Returns an error if no entities match or if the entity/nested relationships cannot be loaded.

pub async fn fetch_n<OP>( self, op: &mut OP, first: usize, ) -> Result<(Vec<<Repo as EsRepo>::Entity>, bool), <Repo as EsRepo>::Err>

where OP: AtomicOperation,

Fetches up to first entities and loads all nested relationships.

Returns a tuple of (entities, has_more) where all entities have their nested relationships loaded, and has_more indicates if more entities were available.