Struct Pool 

pub struct Pool { /* private fields */ }

A PostgreSQL connection pool. sqlx’s pool is the pool; this adds nothing but the keelson traits.

Implementations

impl Pool

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

Connect to url (postgres://user:pass@host:port/db).

pub fn from_pool(inner: PgPool) -> Self

Wrap an existing sqlx pool.

pub fn inner(&self) -> &PgPool

The wrapped sqlx pool — keelson is a layer, not a jail.

Trait Implementations

impl Begin for Pool

fn begin(&self) -> ExecFuture<'_, Result<Transaction, ExecError>>

Open a transaction on a connection this executor owns or checks out.

impl BeginWith for Pool

fn begin_with( &self, opts: TxOptions, ) -> ExecFuture<'_, Result<Transaction, ExecError>>

Open a transaction with explicit options.

impl Clone for Pool

fn clone(&self) -> Pool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Pool

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

Formats the value using the given formatter.

impl Executor for Pool

fn family(&self) -> Family

Which engine family this executor talks to.

fn fetch(&self, stmt: Statement) -> ExecFuture<'_, Result<Vec<Row>, ExecError>>

Run a statement and collect every row — SELECT, or any mutation with RETURNING.

fn execute( &self, stmt: Statement, ) -> ExecFuture<'_, Result<ExecResult, ExecError>>

Run a statement for its side effect.

impl StreamExecutor for Pool

fn fetch_stream( &self, stmt: Statement, ) -> ExecFuture<'_, Result<RowStream, ExecError>>

Run a statement and hand rows back incrementally.