Enum DbPool 

pub enum DbPool {
    Sqlite(Pool<Sqlite>),
    Postgres(Pool<Postgres>),
    MySql(Pool<MySql>),
}

Available on crate features model-mysql or model-postgres or model-sqlite only.

An async connection pool backed by sqlx.

Cheap to clone — the inner pool is reference-counted. Which variant a DbPool is depends on the Backend it was created with; see the module docs for running more than one backend in the same binary.

Variants

Sqlite(Pool<Sqlite>)

Available on crate feature model-sqlite only.

Postgres(Pool<Postgres>)

Available on crate feature model-postgres only.

MySql(Pool<MySql>)

Available on crate feature model-mysql only.

Implementations

impl DbPool

pub async fn new(config: DbConfig) -> Result<Self, DbError>

Create a new pool for config.backend, with the given configuration and the default TLS (DbTls::default: TLS when the server offers it, certificate not checked).

pub async fn new_with_tls(config: DbConfig, tls: DbTls) -> Result<Self, DbError>

As DbPool::new, with tls for PostgreSQL and MySQL (SQLite ignores it). User and password are passed as they are, not through a URL, so any characters work.

pub async fn from_env() -> Result<Self, DbError>

Create a pool using DbConfig::from_env and DbTls::from_env.

pub async fn memory() -> Result<Self, DbError>

Available on crate feature model-sqlite only.

Create a pool backed by a SQLite in-memory database.

All connections in the pool share the same in-memory database (max_connections = 1). Each call returns an independent, isolated database — ideal for tests.

use rust_web_server::model::{DbPool, Value};

let pool = DbPool::memory().await?;
pool.execute("CREATE TABLE t (id INTEGER PRIMARY KEY, v TEXT)", &[]).await?;
pool.execute("INSERT INTO t (v) VALUES (?)", &[Value::Text("hello".into())]).await?;
let rows = pool.query_rows("SELECT * FROM t", &[]).await?;
assert_eq!(1, rows.len());

pub fn backend(&self) -> Backend

Which backend this pool talks to.

pub async fn execute(&self, sql: &str, params: &[Value]) -> Result<u64, DbError>

Execute a SQL statement (INSERT / UPDATE / DELETE / DDL).

Returns the number of rows affected.

pub async fn query_rows( &self, sql: &str, params: &[Value], ) -> Result<Vec<ModelRow>, DbError>

Execute a SQL query and return untyped rows.

pub async fn query<T: Model>( &self, sql: &str, params: &[Value], ) -> Result<Vec<T>, DbError>

Execute a SQL query and deserialise results into T: Model.

pub async fn query_raw( &self, sql: &str, params: &[Value], ) -> Result<Vec<ModelRow>, DbError>

Execute a SQL query returning untyped rows (alias for query_rows).

pub async fn begin(&self) -> Result<DbTransaction, DbError>

Begin a transaction. Call DbTransaction::commit to commit or let it drop to automatically roll back.

pub async fn transaction<F, T, Fut>(&self, f: F) -> Result<T, DbError>

where F: FnOnce(DbTransaction) -> Fut + Send, Fut: Future<Output = Result<T, DbError>> + Send, T: Send,

Run a closure in a transaction.

The closure owns the transaction: call tx.commit() before returning Ok. A transaction that isn’t committed — the closure returns Err, or Ok without committing — is dropped, which rolls it back.

use rust_web_server::model::{DbPool, Value};

let pool = DbPool::memory().await?;
let result = pool.transaction(|mut tx| async move {
    tx.execute("INSERT INTO t (v) VALUES (?)", &[Value::Text("hi".into())]).await?;
    tx.commit().await?;
    Ok(42i32)
}).await?;
assert_eq!(42, result);

pub async fn migrate(&self, dir: &str) -> Result<(), DbError>

Run pending migrations from SQL files in dir.

Files are applied in lexicographic order. Already-applied versions are tracked in a _schema_migrations table (created if absent). Idempotent.

pub async fn migration_status( &self, dir: &str, ) -> Result<Vec<MigrationStatus>, DbError>

Return the status (applied / pending) for each SQL file in dir.

pub async fn rollback_last(&self, dir: &str) -> Result<Option<String>, DbError>

Roll back the most recently applied migration in dir.

Requires a companion <version-stem>.down.sql file next to the up migration it undoes (e.g. 0001_x.sql → 0001_x.down.sql); returns Err if that file is missing. Returns Ok(None) if nothing is currently applied.

pub async fn rollback( &self, dir: &str, n: usize, ) -> Result<Vec<String>, DbError>

Roll back the last n applied migrations, most recently applied first. Returns the versions actually rolled back — fewer than n if fewer than n migrations were applied. Stops at the first missing down file or SQL error; migrations already rolled back in earlier iterations stay rolled back.

Trait Implementations

impl Clone for DbPool

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DbPool

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

Formats the value using the given formatter.