Enum DatabaseClient 

pub enum DatabaseClient {
    Postgres(PgPool),
}

The database client, wrapping an sqlx connection pool.

Supports PostgreSQL and SQLite via feature flags.

Variants

Postgres(PgPool)

Implementations

impl DatabaseClient

pub async fn connect_postgres(url: &str) -> Result<Self, FerriormError>

Connect to a PostgreSQL database.

pub async fn connect_postgres_with_config( url: &str, config: &PoolConfig, ) -> Result<Self, FerriormError>

Connect to a PostgreSQL database with custom pool configuration.

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

Connect by auto-detecting the database type from the URL.

pub async fn connect_with_config( url: &str, config: &PoolConfig, ) -> Result<Self, FerriormError>

Connect by auto-detecting the database type from the URL, using custom pool configuration.

pub fn pg_pool(&self) -> Result<&PgPool, FerriormError>

Get a reference to the underlying PostgreSQL pool for raw queries.

Returns an error if this client is not connected to PostgreSQL.

pub async fn disconnect(self)

Close the connection pool.

pub async fn raw_fetch_all_pg<T>( &self, sql: &str, ) -> Result<Vec<T>, FerriormError>

where T: for<'r> FromRow<'r, PgRow> + Send + Unpin,

Execute raw SQL and return all rows mapped to T (PostgreSQL).

pub async fn raw_fetch_one_pg<T>(&self, sql: &str) -> Result<T, FerriormError>

where T: for<'r> FromRow<'r, PgRow> + Send + Unpin,

Execute raw SQL and return exactly one row mapped to T (PostgreSQL).

pub async fn raw_fetch_optional_pg<T>( &self, sql: &str, ) -> Result<Option<T>, FerriormError>

where T: for<'r> FromRow<'r, PgRow> + Send + Unpin,

Execute raw SQL and return an optional row mapped to T (PostgreSQL).

pub async fn raw_execute_pg(&self, sql: &str) -> Result<u64, FerriormError>

Execute raw SQL without returning rows (PostgreSQL). Returns the number of rows affected.

pub async fn fetch_all_pg<'q, T>( &self, qb: QueryBuilder<'q, Postgres>, ) -> Result<Vec<T>, FerriormError>

where T: for<'r> FromRow<'r, PgRow> + Send + Unpin,

Execute a query builder against the appropriate pool, returning all rows.

pub async fn fetch_optional_pg<'q, T>( &self, qb: QueryBuilder<'q, Postgres>, ) -> Result<Option<T>, FerriormError>

where T: for<'r> FromRow<'r, PgRow> + Send + Unpin,

pub async fn fetch_one_pg<'q, T>( &self, qb: QueryBuilder<'q, Postgres>, ) -> Result<T, FerriormError>

where T: for<'r> FromRow<'r, PgRow> + Send + Unpin,

pub async fn execute_pg<'q>( &self, qb: QueryBuilder<'q, Postgres>, ) -> Result<u64, FerriormError>

Trait Implementations

impl Clone for DatabaseClient

fn clone(&self) -> DatabaseClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DatabaseClient

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

Formats the value using the given formatter.