Struct SQLiteConnection 

pub struct SQLiteConnection { /* private fields */ }

Implementations

impl SQLiteConnection

pub fn last_error(&self) -> String

Trait Implementations

impl Connection for SQLiteConnection

async fn connect(url: Cow<'static, str>) -> Result<SQLiteConnection>

Create a connection (or pool) with at least one underlying session established to the given URL.

fn begin(&mut self) -> impl Future<Output = Result<SQLiteTransaction<'_>>>

Begin a transaction scope tied to the current connection.

fn disconnect(self) -> impl Future<Output = Result<(), Error>>

Disconnect and release the underlying session(s).

impl Executor for SQLiteConnection

type Driver = SQLiteDriver

Associated driver.

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

Driver instance.

async fn prepare(&mut self, sql: String) -> Result<Query<Self::Driver>>

Prepare a query for later execution.

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

Run a query, streaming QueryResult items.

fn accepts_multiple_statements(&self) -> bool

Returns true if the executor accepts multiple SQL statements in a single request (e.g. CREATE; INSERT; SELECT). Defaults to true.

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

Stream only labeled rows (filters non-row results).

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

Execute and aggregate affected rows.

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

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

Insert many entities efficiently.