Struct sqlx::pool::PoolOptions
source Ā· [−]pub struct PoolOptions<DB> where
DB: Database, { /* private fields */ }
Implementations
sourceimpl<DB> PoolOptions<DB> where
DB: Database,
impl<DB> PoolOptions<DB> where
DB: Database,
pub fn new() -> PoolOptions<DB>
sourcepub fn max_connections(self, max: u32) -> PoolOptions<DB>
pub fn max_connections(self, max: u32) -> PoolOptions<DB>
Set the maximum number of connections that this pool should maintain.
sourcepub fn connect_timeout(self, timeout: Duration) -> PoolOptions<DB>
pub fn connect_timeout(self, timeout: Duration) -> PoolOptions<DB>
Set the amount of time to attempt connecting to the database.
If this timeout elapses, Pool::acquire
will return an error.
sourcepub fn min_connections(self, min: u32) -> PoolOptions<DB>
pub fn min_connections(self, min: u32) -> PoolOptions<DB>
Set the minimum number of connections to maintain at all times.
When the pool is built, this many connections will be automatically spun up.
If any connection is reaped by max_lifetime
or idle_timeout
and it brings
the connection count below this amount, a new connection will be opened to replace it.
sourcepub fn max_lifetime(
self,
lifetime: impl Into<Option<Duration>>
) -> PoolOptions<DB>
pub fn max_lifetime(
self,
lifetime: impl Into<Option<Duration>>
) -> PoolOptions<DB>
Set the maximum lifetime of individual connections.
Any connection with a lifetime greater than this will be closed.
When set to None
, all connections live until either reaped by idle_timeout
or explicitly disconnected.
Infinite connections are not recommended due to the unfortunate reality of memory/resource leaks on the database-side. It is better to retire connections periodically (even if only once daily) to allow the database the opportunity to clean up data structures (parse trees, query metadata caches, thread-local storage, etc.) that are associated with a session.
sourcepub fn idle_timeout(
self,
timeout: impl Into<Option<Duration>>
) -> PoolOptions<DB>
pub fn idle_timeout(
self,
timeout: impl Into<Option<Duration>>
) -> PoolOptions<DB>
Set a maximum idle duration for individual connections.
Any connection with an idle duration longer than this will be closed.
For usage-based database server billing, this can be a cost saver.
sourcepub fn test_before_acquire(self, test: bool) -> PoolOptions<DB>
pub fn test_before_acquire(self, test: bool) -> PoolOptions<DB>
If true, the health of a connection will be verified by a call to Connection::ping
before returning the connection.
Defaults to true
.
sourcepub fn after_connect<F>(self, callback: F) -> PoolOptions<DB> where
F: 'static + for<'c> Fn(&'c mut <DB as Database>::Connection) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'c, Global>> + Send + Sync,
pub fn after_connect<F>(self, callback: F) -> PoolOptions<DB> where
F: 'static + for<'c> Fn(&'c mut <DB as Database>::Connection) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'c, Global>> + Send + Sync,
Perform an action after connecting to the database.
Example
use sqlx_core::executor::Executor;
use sqlx_core::postgres::PgPoolOptions;
// PostgreSQL
let pool = PgPoolOptions::new()
.after_connect(|conn| Box::pin(async move {
conn.execute("SET application_name = 'your_app';").await?;
conn.execute("SET search_path = 'my_schema';").await?;
Ok(())
}))
.connect("postgres:// ā¦").await?;
pub fn before_acquire<F>(self, callback: F) -> PoolOptions<DB> where
F: 'static + for<'c> Fn(&'c mut <DB as Database>::Connection) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'c, Global>> + Send + Sync,
pub fn after_release<F>(self, callback: F) -> PoolOptions<DB> where
F: 'static + Fn(&mut <DB as Database>::Connection) -> bool + Send + Sync,
sourcepub async fn connect(self, uri: &'_ str) -> Result<Pool<DB>, Error>
pub async fn connect(self, uri: &'_ str) -> Result<Pool<DB>, Error>
Creates a new pool from this configuration and immediately establishes one connection.
sourcepub async fn connect_with(
self,
options: <<DB as Database>::Connection as Connection>::Options
) -> Result<Pool<DB>, Error>
pub async fn connect_with(
self,
options: <<DB as Database>::Connection as Connection>::Options
) -> Result<Pool<DB>, Error>
Creates a new pool from this configuration and immediately establishes one connection.
sourcepub fn connect_lazy(self, uri: &str) -> Result<Pool<DB>, Error>
pub fn connect_lazy(self, uri: &str) -> Result<Pool<DB>, Error>
Creates a new pool from this configuration and will establish a connections as the pool starts to be used.
sourcepub fn connect_lazy_with(
self,
options: <<DB as Database>::Connection as Connection>::Options
) -> Pool<DB>
pub fn connect_lazy_with(
self,
options: <<DB as Database>::Connection as Connection>::Options
) -> Pool<DB>
Creates a new pool from this configuration and will establish a connections as the pool starts to be used.
Trait Implementations
sourceimpl<DB> Debug for PoolOptions<DB> where
DB: Database,
impl<DB> Debug for PoolOptions<DB> where
DB: Database,
sourceimpl<DB> Default for PoolOptions<DB> where
DB: Database,
impl<DB> Default for PoolOptions<DB> where
DB: Database,
sourcefn default() -> PoolOptions<DB>
fn default() -> PoolOptions<DB>
Returns the ādefault valueā for a type. Read more
Auto Trait Implementations
impl<DB> !RefUnwindSafe for PoolOptions<DB>
impl<DB> Send for PoolOptions<DB>
impl<DB> Sync for PoolOptions<DB>
impl<DB> Unpin for PoolOptions<DB>
impl<DB> !UnwindSafe for PoolOptions<DB>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable Ā· sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more