Struct Connection

pub struct Connection { /* private fields */ }

A handle to call functions in background thread.

Implementations

impl Connection

pub fn from_conn(conn: Connection) -> Result<Self>

pub fn open_in_memory() -> Result<Self>

Open a new connection to an in-memory SQLite database.

Failure

Will return Err if the underlying SQLite open call fails.

pub async fn call<F, R>(&self, function: F) -> Result<R>

where F: FnOnce(&mut Connection) -> Result<R> + Send + 'static, R: Send + 'static,

Call a function in background thread and get the result asynchronously.

Failure

Will return Err if the database connection has been closed.

pub fn call_and_forget( &self, function: impl FnOnce(&Connection) + Send + 'static, )

pub async fn query( &self, sql: &str, params: impl Params + Send + 'static, ) -> Result<Rows>

Query SQL statement.

pub async fn query_row( &self, sql: &str, params: impl Params + Send + 'static, ) -> Result<Option<Row>>

pub async fn query_value<T: DeserializeOwned + Send + 'static>( &self, sql: &str, params: impl Params + Send + 'static, ) -> Result<Option<T>>

pub async fn query_values<T: DeserializeOwned + Send + 'static>( &self, sql: &str, params: impl Params + Send + 'static, ) -> Result<Vec<T>>

pub async fn execute( &self, sql: &str, params: impl Params + Send + 'static, ) -> Result<usize>

Execute SQL statement.

pub async fn execute_batch(&self, sql: &str) -> Result<Option<Rows>>

Batch execute SQL statements and return rows of last statement.

pub async fn add_preupdate_hook( &self, hook: Option<impl Fn(Action, &str, &str, &PreUpdateCase) + Send + Sync + 'static>, ) -> Result<()>

Convenience API for (un)setting a new pre-update hook.

pub async fn close(self) -> Result<()>

Close the database connection.

This is functionally equivalent to the Drop implementation for Connection. It consumes the Connection, but on error returns it to the caller for retry purposes.

If successful, any following close operations performed on Connection copies will succeed immediately.

On the other hand, any calls to Connection::call will return a Error::ConnectionClosed, and any calls to [Connection::call_unwrap] will cause a panic.

Failure

Will return Err if the underlying SQLite close call fails.

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.