Struct SQLiteTransaction 

pub struct SQLiteTransaction<'c> { /* private fields */ }

Implementations

impl<'c> SQLiteTransaction<'c>

pub async fn new(connection: &'c mut SQLiteConnection) -> Result<Self>

Trait Implementations

impl<'c> Executor for SQLiteTransaction<'c>

type Driver = SQLiteDriver

Associated driver.

fn accepts_multiple_statements(&self) -> bool

Checks if the driver supports multiple SQL statements in a single request.

fn do_prepare( &mut self, sql: String, ) -> impl Future<Output = Result<Query<Self::Driver>>> + Send

Internal hook for implementing prepared statement support.

fn run<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Stream<Item = Result<QueryResult>> + Send

Executes a query and streams the results (rows or affected counts).

fn fetch<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Stream<Item = Result<Row>> + Send + 's

Executes a query and streams the resulting rows, ignoring affected counts.

fn execute<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Future<Output = Result<RowsAffected>> + Send

Executes a query and returns the total number of affected rows.

fn append<'a, E, It>( &mut self, entities: It, ) -> impl Future<Output = Result<RowsAffected>> + Send

where E: Entity + 'a, It: IntoIterator<Item = &'a E> + Send, <It as IntoIterator>::IntoIter: Send,

Efficiently inserts a collection of entities bypassing regular SQL execution when supported by the driver.

fn driver(&self) -> Self::Driver

where Self: Sized,

Returns the driver instance associated with this executor.

fn prepare<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Future<Output = Result<Query<Self::Driver>, Error>> + Send

Prepares a query for execution, returning a handle to the prepared statement.

impl<'c> Transaction<'c> for SQLiteTransaction<'c>

fn commit(self) -> impl Future<Output = Result<()>>

Commit the outstanding changes.

fn rollback(self) -> impl Future<Output = Result<()>>

Rollback any uncommitted changes.