Struct Db 

pub struct Db { /* private fields */ }

Db

The database connection pool manager in NestForge. Provides access to one or more database connections.

Implementations

impl Db

pub async fn connect(config: DbConfig) -> Result<Self, DbError>

Connects to the database synchronously.

Arguments

• config: Database configuration

pub fn connect_lazy(config: DbConfig) -> Result<Self, DbError>

Connects to the database lazily (without verifying connection).

pub async fn connect_many<I>( primary: DbConfig, named: I, ) -> Result<Self, DbError>

where I: IntoIterator<Item = (String, DbConfig)>,

Connects to multiple databases simultaneously.

Arguments

• primary: Configuration for the primary database
• named: Iterator of (name, config) pairs for additional databases

pub fn connect_many_lazy<I>( primary: DbConfig, named: I, ) -> Result<Self, DbError>

where I: IntoIterator<Item = (String, DbConfig)>,

pub fn pool(&self) -> &AnyPool

pub fn pool_named(&self, name: &str) -> Result<&AnyPool, DbError>

pub async fn execute(&self, sql: &str) -> Result<u64, DbError>

pub async fn execute_script(&self, sql: &str) -> Result<(), DbError>

pub async fn execute_named(&self, name: &str, sql: &str) -> Result<u64, DbError>

pub async fn fetch_all<T>(&self, sql: &str) -> Result<Vec<T>, DbError>

where for<'r> T: FromRow<'r, AnyRow> + Send + Unpin,

pub async fn fetch_all_named<T>( &self, name: &str, sql: &str, ) -> Result<Vec<T>, DbError>

where for<'r> T: FromRow<'r, AnyRow> + Send + Unpin,

pub async fn begin(&self) -> Result<DbTransaction, DbError>

pub async fn begin_named(&self, name: &str) -> Result<DbTransaction, DbError>

Trait Implementations

impl Clone for Db

fn clone(&self) -> Db

Returns a duplicate of the value.

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

Performs copy-assignment from source.