Struct Pool 

pub struct Pool<DB>
where
    DB: Database,
{ /* private fields */ }

A connection pool wrapping sqlx::Pool.

Generic over DB: sqlx::Database so that the same API works with SQLite, PostgreSQL, and MySQL while retaining compile-time type safety.

Implementations

impl Pool<Sqlite>

pub async fn find_by_id<E>( &self, id: <E as Entity>::Id, ) -> Result<E, FletchError>

where E: Entity + for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Find an entity by its primary key.

pub async fn find_all<E>(&self) -> Result<Vec<E>, FletchError>

where E: Entity + for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Fetch all entities of this type.

pub async fn insert<E>(&self, entity: &E) -> Result<E, FletchError>

where E: Entity + for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Insert a new entity and return it.

pub async fn update<E>(&self, entity: &E) -> Result<E, FletchError>

where E: Entity + for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Update an existing entity and return the updated row.

pub async fn delete<E>(&self, id: <E as Entity>::Id) -> Result<(), FletchError>

where E: Entity,

Delete an entity by its primary key.

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

where T: for<'r> FromRow<'r, <Sqlite as Database>::Row> + Send + Unpin,

Execute a raw SQL query and return all matching rows.

impl<DB> Pool<DB>

where DB: Database,

pub async fn connect(url: &str) -> Result<Pool<DB>, FletchError>

Connect to the database at the given URL.

This creates a connection pool with SQLx’s default pool options.

pub fn builder() -> PoolBuilder<DB>

Returns a PoolBuilder for configuring pool options before connecting.

pub async fn close(&self)

Close the pool, waiting for all connections to be returned.

pub fn inner(&self) -> &Pool<DB>

Returns a reference to the underlying sqlx pool.

Escape hatch for advanced or raw SQLx access. Prefer fletch CRUD and the query builder where possible.

pub fn size(&self) -> u32

Returns the number of connections currently active (including idle).

pub fn num_idle(&self) -> usize

Returns the number of idle connections in the pool.

pub async fn begin(&self) -> Result<Transaction<'static, DB>, FletchError>

Begin a new transaction.

Trait Implementations

impl<DB> Clone for Pool<DB>

where DB: Database,

fn clone(&self) -> Pool<DB>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<DB> Debug for Pool<DB>

where DB: Debug + Database,

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

Formats the value using the given formatter.