Struct Db

pub struct Db {
    pub pool: PgPool,
    pub transaction: PgTx,
}

Fields

pool: PgPool

transaction: PgTx

Implementations

impl Db

pub async fn connect(connection_string: &str) -> Result<Self>

pub async fn transaction(&self) -> Result<Self>

pub async fn execute<'a>(&self, query: PgQuery<'a>) -> Result<PgQueryResult>

pub async fn fetch_one<'a, T, F>(&self, query: PgMap<'a, F>) -> Result<T>

where F: FnMut(PgRow) -> Result<T, Error> + Send, T: Unpin + Send,

pub async fn fetch_all<'a, T, F>(&self, query: PgMap<'a, F>) -> Result<Vec<T>>

where F: FnMut(PgRow) -> Result<T, Error> + Send, T: Unpin + Send,

pub async fn fetch_optional<'a, T, F>( &self, query: PgMap<'a, F>, ) -> Result<Option<T>>

where F: FnMut(PgRow) -> Result<T, Error> + Send, T: Unpin + Send,

pub async fn fetch_one_scalar<'a, T>( &self, query: PgQueryScalar<'a, T>, ) -> Result<T>

where (T,): for<'r> FromRow<'r, PgRow>, T: Unpin + Send,

pub async fn fetch_all_scalar<'a, T>( &self, query: PgQueryScalar<'a, T>, ) -> Result<Vec<T>>

where (T,): for<'r> FromRow<'r, PgRow>, T: Unpin + Send,

pub async fn fetch_optional_scalar<'a, T>( &self, query: PgQueryScalar<'a, T>, ) -> Result<Option<T>>

where (T,): for<'r> FromRow<'r, PgRow>, T: Unpin + Send,

pub async fn commit(&self) -> Result<()>

Trait Implementations

impl Clone for Db

fn clone(&self) -> Db

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Db

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

Formats the value using the given formatter.