Struct QueryBuilder 

pub struct QueryBuilder<T> { /* private fields */ }

Implementations

impl<T> QueryBuilder<T>

where T: Send + Sync + Unpin + 'static,

pub fn new(table: impl Into<String>, pk: impl Into<String>) -> Self

pub fn with_soft_delete_col(self, col: impl Into<String>) -> Self

Устанавливает имя колонки soft-delete. Если установлено, автоматически добавляет WHERE col IS NULL.

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

where F: FnOnce(&T::Columns) -> FilterExpr, T: HasColumns,

Добавляет условие фильтрации (AND).

pub fn filter_raw(self, sql: impl Into<String>) -> Self

Добавляет сырое WHERE условие.

pub fn filter_if<F>(self, condition: bool, f: F) -> Self

where F: FnOnce(&T::Columns) -> FilterExpr, T: HasColumns,

Условный фильтр — добавляется только если condition == true.

pub fn apply(self, scope: Scope<T>) -> Self

Применяет scope к текущему builder’у.

pub fn with_deleted(self) -> Self

Включить удалённые записи.

pub fn only_deleted(self) -> Self

Только удалённые записи.

pub fn select_cols( self, cols: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Выбрать конкретные колонки.

pub fn select_distinct_col(self, col: impl Into<String>) -> Self

pub fn inner_join(self, table: impl Into<String>, on: impl Into<String>) -> Self

INNER JOIN таблицы с ON-выражением.

pub fn left_join(self, table: impl Into<String>, on: impl Into<String>) -> Self

LEFT JOIN.

pub fn group_by_col(self, col: impl Into<String>) -> Self

pub fn having_raw(self, sql: impl Into<String>) -> Self

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

where F: FnOnce(&T::Columns) -> OrderExpr, T: HasColumns,

pub fn order_by_raw(self, sql: impl Into<String>) -> Self

pub fn order_by_random(self) -> Self

pub fn limit(self, n: i64) -> Self

pub fn offset(self, n: i64) -> Self

pub fn paginate(self, page: i64, per_page: i64) -> Self

Выставляет limit/offset для страницы page (с 1), per_page записей.

pub fn build_select(&self) -> (String, Vec<SqlValue>)

Строит финальный SELECT SQL и список bind-значений.

pub async fn fetch_all(self, pool: &PgPool) -> OrmResult<Vec<T>>

where T: for<'r> FromRow<'r, PgRow>,

Выполняет запрос и возвращает Vec<T>.

pub async fn first(self, pool: &PgPool) -> OrmResult<Option<T>>

where T: for<'r> FromRow<'r, PgRow>,

Первая запись или None.

pub async fn first_or_fail(self, pool: &PgPool) -> OrmResult<T>

where T: for<'r> FromRow<'r, PgRow>,

Первая или OrmError::NotFound.

pub async fn last(self, pool: &PgPool) -> OrmResult<Option<T>>

where T: for<'r> FromRow<'r, PgRow>,

Последняя запись (обратный порядок по PK).

pub async fn count(self, pool: &PgPool) -> OrmResult<i64>

Количество записей, удовлетворяющих фильтру.

pub async fn exists(self, pool: &PgPool) -> OrmResult<bool>

Существует ли хоть одна запись по фильтру.

pub async fn fetch_page( self, page: i64, per_page: i64, pool: &PgPool, ) -> OrmResult<Page<T>>

where T: for<'r> FromRow<'r, PgRow>,

Пагинированный результат.

pub async fn update_all<F>(self, f: F, pool: &PgPool) -> OrmResult<u64>

where F: FnOnce(&mut UpdateBuilder<T>), T: HasColumns,

UPDATE table SET ... WHERE <накопленные фильтры> — возвращает кол-во строк.

pub async fn delete_all(self, pool: &PgPool) -> OrmResult<u64>

DELETE FROM table WHERE <накопленные фильтры> — возвращает кол-во строк.

Trait Implementations

impl<T> Clone for QueryBuilder<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for QueryBuilder<T>

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

Formats the value using the given formatter.