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

Underlying driver type supplying SQL dialect + I/O.

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

Access the driver instance.

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

Prepare a query (e.g. statement caching / parameter binding) returning a Query.

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

Run an already prepared query, streaming heterogeneous QueryResult items.

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

Run a query and stream only labeled rows, filtering out non-row results.

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

Execute a query and return a single aggregated RowsAffected.

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,

Append entities to a table.

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.