Struct Database 

pub struct Database { /* private fields */ }

A rusqlite-backed connection pool. Cloning shares the underlying pools.

Holds a single writer connection and a pool of reader connections (see the module docs).

Implementations

impl Database

pub fn new(database_filepath: &Path) -> Result<Self, DatabaseError>

Opens a database over database_filepath with the default reader-pool size.

pub fn new_with_pool_size( database_filepath: &Path, connection_pool_size: NonZeroUsize, ) -> Result<Self, DatabaseError>

Opens a database over database_filepath with the given reader-pool size. The writer is always a single connection.

pub async fn read<R, E, F>( &self, msg: impl ToString + Send, query: F, ) -> Result<R, E>

where F: FnOnce(&ReadTx<'_>) -> Result<R, E> + Send + 'static, R: Send + 'static, E: From<DatabaseError> + Send + 'static,

Runs query inside a read-only (DEFERRED, never committed) transaction on a reader connection.

pub async fn write<R, E, F>( &self, msg: impl ToString + Send, query: F, ) -> Result<R, E>

where F: FnOnce(&WriteTx<'_>) -> Result<R, E> + Send + 'static, R: Send + 'static, E: From<DatabaseError> + Send + 'static,

Runs query inside a read-write (IMMEDIATE) transaction on the single writer connection, committing on Ok.

pub async fn begin_read(&self) -> Result<ReadTransaction, DatabaseError>

Begins a read-only (DEFERRED) transaction on a reader connection and returns a handle held across .await points. See ReadTransaction.

pub async fn begin_write(&self) -> Result<WriteTransaction, DatabaseError>

Begins a read-write (IMMEDIATE) transaction on the single writer connection and returns a handle held across .await points. The handle must be committed (or it rolls back). See WriteTransaction.

Trait Implementations

impl Clone for Database

fn clone(&self) -> Database

Returns a duplicate of the value.

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

Performs copy-assignment from source.