Struct Pool 

pub struct Pool { /* private fields */ }

A MySQL connection pool, with the session zone pinned to UTC on every connection.

Implementations

impl Pool

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

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

pub fn from_pool(inner: MySqlPool) -> Self

Wrap an existing sqlx pool.

The caller then owns the session-zone pin: connections this pool establishes are not set to time_zone = '+00:00' unless its own after_connect does so, and TIMESTAMP round-trips are wrong without it. Prefer Pool::connect.

pub fn inner(&self) -> &MySqlPool

The wrapped sqlx pool.

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.