Struct Db 

pub struct Db { /* private fields */ }

A database connection pool that auto-selects the backend based on the connection URL scheme.

Db is cheap to clone (internally reference-counted) and safe to share across tokio tasks.

Implementations

impl Db

pub async fn connect(url: &str) -> Result<Self, FlozError>

Connect to a database, auto-detecting the backend from the URL scheme.

• postgres://... or postgresql://... → PostgreSQL
• sqlite://... or sqlite::memory: → SQLite

pub async fn connect_env( env_var: &str, default_url: &str, ) -> Result<Self, FlozError>

Connect using an environment variable, falling back to a default URL.

pub async fn begin(&self) -> Result<Tx, FlozError>

Begin a new transaction.

Trait Implementations

impl Clone for Db

fn clone(&self) -> Db

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Db

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

Formats the value using the given formatter.

impl Executor for Db

async fn execute_raw( &self, sql: &str, params: Vec<Value>, ) -> Result<u64, FlozError>

Execute a raw SQL statement, returning the number of affected rows.

async fn fetch_all<T>( &self, sql: &str, params: Vec<Value>, ) -> Result<Vec<T>, FlozError>

where T: Send + Unpin + FlozRowBound,

Fetch all matching rows.

async fn fetch_one<T>( &self, sql: &str, params: Vec<Value>, ) -> Result<T, FlozError>

where T: Send + Unpin + FlozRowBound,

Fetch exactly one row. Returns FlozError::NotFound if no rows match.

async fn fetch_optional<T>( &self, sql: &str, params: Vec<Value>, ) -> Result<Option<T>, FlozError>

where T: Send + Unpin + FlozRowBound,

Fetch zero or one row.