Struct QuerySetTx 

pub struct QuerySetTx<'tx, T> { /* private fields */ }

A QuerySet bound to an open transaction. See module docs for the construction sites and the borrow-checker contract.

Implementations

impl<'tx, T: Model> QuerySetTx<'tx, T>

pub async fn fetch(self) -> Result<Vec<T>, Error>

where T: for<'r> FromRow<'r, SqliteRow> + for<'r> FromRow<'r, PgRow> + HydrateRelated,

SELECT all matching rows inside the transaction.

pub async fn first(self) -> Result<Option<T>, Error>

where T: for<'r> FromRow<'r, SqliteRow> + for<'r> FromRow<'r, PgRow> + HydrateRelated,

SELECT LIMIT 1 and return the first row, if any.

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

SELECT COUNT(*) inside the transaction.

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

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

Return whether any row matches, inside the transaction.

pub async fn get(self) -> Result<T, GetError>

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

Exactly-one terminal inside the transaction. See super::QuerySet::get.

pub async fn delete(self) -> Result<u64, Error>

DELETE inside the transaction. Returns the number of rows deleted.

pub async fn update_values( self, values: Map<String, Value>, ) -> Result<u64, WriteError>

UPDATE inside the transaction. Takes the same column → JSON value map as super::QuerySet::update_values.

pub async fn create(self, instance: T) -> Result<T, WriteError>

where T: Serialize + for<'r> FromRow<'r, SqliteRow> + for<'r> FromRow<'r, PgRow> + HydrateRelated,

INSERT one row and return the populated row, inside the transaction.

This is the Manager::create_in_tx equivalent called through the QuerySet API: Post::objects().on_tx(tx).create(instance).await?.