Struct QueryBuilder 

pub struct QueryBuilder<'a> { /* private fields */ }

Builder for creating and executing document queries.

Implementations

impl<'a> QueryBuilder<'a>

pub fn new(db: &'a Aurora, collection: &str) -> Self

Creates a new QueryBuilder for the specified collection.

pub fn filter<F>(self, f: F) -> Self

where F: FnOnce(&FilterBuilder) -> Filter,

Adds a filter to the query using the FilterBuilder.

Example

let users = db.query("users")
    .filter(|f| f.eq("active", true))
    .collect()
    .await?;

pub fn order_by(self, field: &str, ascending: bool) -> Self

Sets the sort order for the query.

Arguments

• field - The field to sort by.
• ascending - true for ascending order, false for descending.

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

Limits the number of documents returned by the query.

Using limit enables early termination optimizations, making queries significantly faster on large collections.

pub fn offset(self, offset: usize) -> Self

Sets the number of matching documents to skip.

pub fn select(self, fields: Vec<&str>) -> Self

Specifies which fields to include in the returned documents.

This reduces memory usage and transfer size by only retrieving necessary data.

pub fn debounce(self, duration: Duration) -> Self

Sets a debounce duration for reactive queries.

pub async fn first_one(self) -> Result<Option<Document>>

Executes the query and returns the first matching document, if any.

This is an optimized operation that stops after finding the first match.

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

Executes the query and returns all matching documents.

Uses secondary indices (Roaring Bitmaps) for optimized filtering when possible.

pub async fn count(self) -> Result<usize>

Returns the number of documents that match the query.

pub async fn delete(self) -> Result<usize>

Deletes all documents that match the query.

Returns the number of documents that were deleted.

pub async fn watch(self) -> Result<QueryWatcher>

Creates a reactive query watcher.

The watcher will emit updated result sets whenever the underlying data changes in a way that affects the query results.