Struct deltachat::sql::Sql

pub struct Sql {
    pub(crate) dbfile: PathBuf,
    pool: RwLock<Option<Pool>>,
    is_encrypted: RwLock<Option<bool>>,
    pub(crate) config_cache: RwLock<HashMap<String, Option<String>>>,
}

A wrapper around the underlying Sqlite3 object.

Fields

dbfile: PathBuf

Database file path

pool: RwLock<Option<Pool>>

SQL connection pool.

is_encrypted: RwLock<Option<bool>>

None if the database is not open, true if it is open with passphrase and false if it is open without a passphrase.

config_cache: RwLock<HashMap<String, Option<String>>>

Cache of config table.

Implementations

impl Sql

async fn set_db_version(&self, version: i32) -> Result<()>

fn set_db_version_trans( transaction: &mut Transaction<'_>, version: i32, ) -> Result<()>

async fn set_db_version_in_cache(&self, version: i32) -> Result<()>

async fn execute_migration(&self, query: &str, version: i32) -> Result<()>

impl Sql

pub fn new(dbfile: PathBuf) -> Sql

Creates new SQL database.

pub async fn check_passphrase(&self, passphrase: String) -> Result<bool>

Tests SQLCipher passphrase.

Returns true if passphrase is correct, i.e. the database is new or can be unlocked with this passphrase, and false if the database is already encrypted with another passphrase or corrupted.

Fails if database is already open.

pub async fn is_open(&self) -> bool

Checks if there is currently a connection to the underlying Sqlite database.

pub(crate) async fn is_encrypted(&self) -> Option<bool>

Returns true if the database is encrypted.

If database is not open, returns None.

pub(crate) async fn close(&self)

Closes all underlying Sqlite connections.

pub(crate) async fn import(&self, path: &Path, passphrase: String) -> Result<()>

Imports the database from a separate file with the given passphrase.

fn new_pool(dbfile: &Path, passphrase: String) -> Result<Pool>

Creates a new connection pool.

async fn try_open( &self, context: &Context, dbfile: &Path, passphrase: String, ) -> Result<()>

pub async fn run_migrations(&self, context: &Context) -> Result<()>

Updates SQL schema to the latest version.

pub async fn open(&self, context: &Context, passphrase: String) -> Result<()>

Opens the provided database and runs any necessary migrations. If a database is already open, this will return an error.

pub async fn change_passphrase(&self, passphrase: String) -> Result<()>

Changes the passphrase of encrypted database.

The database must already be encrypted and the passphrase cannot be empty. It is impossible to turn encrypted database into unencrypted and vice versa this way, use import/export for this.

async fn call<'a, F, R>(&'a self, query_only: bool, function: F) -> Result<R>

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

Allocates a connection and calls function with the connection.

If query_only is true, allocates read-only connection, otherwise allocates write connection.

Returns the result of the function.

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

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

Allocates a connection and calls given function, assuming it does write queries, with the connection.

Returns the result of the function.

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

Execute query assuming it is a write query, returning the number of affected rows.

pub async fn insert( &self, query: &str, params: impl Params + Send, ) -> Result<i64>

Executes the given query, returning the last inserted row ID.

pub async fn query_map<T, F, G, H>( &self, sql: &str, params: impl Params + Send, f: F, g: G, ) -> Result<H>

where F: Send + FnMut(&Row<'_>) -> Result<T>, G: Send + FnMut(MappedRows<'_, F>) -> Result<H>, H: Send + 'static,

Prepares and executes the statement and maps a function over the resulting rows. Then executes the second function over the returned iterator and returns the result of that function.

pub async fn count( &self, query: &str, params: impl Params + Send, ) -> Result<usize>

Used for executing SELECT COUNT statements only. Returns the resulting count.

pub async fn exists( &self, sql: &str, params: impl Params + Send, ) -> Result<bool>

Used for executing SELECT COUNT statements only. Returns true, if the count is at least one, false otherwise.

pub async fn query_row<T, F>( &self, query: &str, params: impl Params + Send, f: F, ) -> Result<T>

where F: FnOnce(&Row<'_>) -> Result<T> + Send, T: Send + 'static,

Execute a query which is expected to return one row.

pub async fn transaction<G, H>(&self, callback: G) -> Result<H>

where H: Send + 'static, G: Send + FnOnce(&mut Transaction<'_>) -> Result<H>,

Execute the function inside a transaction assuming that it does write queries.

If the function returns an error, the transaction will be rolled back. If it does not return an error, the transaction will be committed.

pub async fn table_exists(&self, name: &str) -> Result<bool>

Query the database if the requested table already exists.

pub async fn col_exists(&self, table_name: &str, col_name: &str) -> Result<bool>

Check if a column exists in a given table.

pub async fn query_row_optional<T, F>( &self, sql: &str, params: impl Params + Send, f: F, ) -> Result<Option<T>>

where F: Send + FnOnce(&Row<'_>) -> Result<T>, T: Send + 'static,

Execute a query which is expected to return zero or one row.

pub async fn query_get_value<T>( &self, query: &str, params: impl Params + Send, ) -> Result<Option<T>>

where T: FromSql + Send + 'static,

Executes a query which is expected to return one row and one column. If the query does not return any rows, returns Ok(None).

pub async fn set_raw_config(&self, key: &str, value: Option<&str>) -> Result<()>

Set private configuration options.

Setting None deletes the value. On failure an error message will already have been logged.

pub async fn get_raw_config(&self, key: &str) -> Result<Option<String>>

Get configuration options from the database.

pub async fn set_raw_config_int(&self, key: &str, value: i32) -> Result<()>

Sets configuration for the given key to 32-bit signed integer value.

pub async fn get_raw_config_int(&self, key: &str) -> Result<Option<i32>>

Returns 32-bit signed integer configuration value for the given key.

pub async fn get_raw_config_u32(&self, key: &str) -> Result<Option<u32>>

Returns 32-bit unsigned integer configuration value for the given key.

pub async fn get_raw_config_bool(&self, key: &str) -> Result<bool>

Returns boolean configuration value for the given key.

pub async fn set_raw_config_bool(&self, key: &str, value: bool) -> Result<()>

Sets configuration for the given key to boolean value.

pub async fn set_raw_config_int64(&self, key: &str, value: i64) -> Result<()>

Sets configuration for the given key to 64-bit signed integer value.

pub async fn get_raw_config_int64(&self, key: &str) -> Result<Option<i64>>

Returns 64-bit signed integer configuration value for the given key.

Trait Implementations

impl Debug for Sql

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

Formats the value using the given formatter.