Struct Transaction 

pub struct Transaction<'a, DB>
where
    DB: Database,
{ /* private fields */ }

A database transaction with auto-rollback on drop.

If the transaction is dropped without calling commit, it will automatically roll back.

Implementations

impl<'a> Transaction<'a, Sqlite>

pub async fn find_by_id<E>( &mut self, id: <E as Entity>::Id, ) -> Result<E, FletchError>

where E: Entity + for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Find an entity by its primary key.

pub async fn find_all<E>(&mut self) -> Result<Vec<E>, FletchError>

where E: Entity + for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Fetch all entities of this type.

pub async fn insert<E>(&mut self, entity: &E) -> Result<E, FletchError>

where E: Entity + for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Insert a new entity and return it.

pub async fn update<E>(&mut self, entity: &E) -> Result<E, FletchError>

where E: Entity + for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Update an existing entity and return the updated row.

pub async fn delete<E>( &mut self, id: <E as Entity>::Id, ) -> Result<(), FletchError>

where E: Entity,

Delete an entity by its primary key.

pub async fn fetch_all<T>( &mut self, sql: &str, params: &[Value], ) -> Result<Vec<T>, FletchError>

where T: for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Execute a raw SQL query and return all matching rows.

impl<'a, DB> Transaction<'a, DB>

where DB: Database,

pub async fn commit(self) -> Result<(), FletchError>

Commit the transaction.

pub async fn rollback(self) -> Result<(), FletchError>

Explicitly roll back the transaction.

pub fn inner_mut(&mut self) -> &mut Transaction<'a, DB>

Returns a mutable reference to the underlying sqlx transaction.

Escape hatch for advanced or raw SQLx access. Prefer fletch CRUD and the query builder where possible.