Struct sqlx_models_orm::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.