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.

Errors

Returns a FerriormError if the connection fails.

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

Connect to a PostgreSQL database with custom pool configuration.

Errors

Returns a FerriormError if the connection fails.

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

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

Errors

Returns a FerriormError if the connection fails or no backend is enabled.

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.

Errors

Returns a FerriormError if the connection fails or no backend is enabled.

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

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

Errors

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).

Errors

Returns a FerriormError on query failure or wrong connection type.

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).

Errors

Returns a FerriormError on query failure or wrong connection type.

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).

Errors

Returns a FerriormError on query failure or wrong connection type.

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.

Errors

Returns a FerriormError on query failure or wrong connection type.

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.

Errors

Returns a FerriormError on query failure or wrong connection type.

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,

Fetch an optional row via a PostgreSQL query builder.

Errors

Returns a FerriormError on query failure or wrong connection type.

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,

Fetch exactly one row via a PostgreSQL query builder.

Errors

Returns a FerriormError on query failure or wrong connection type.

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

Execute a PostgreSQL query builder without returning rows.

Errors

Returns a FerriormError on query failure or wrong connection type.

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.