Struct Database

pub struct Database {
    pub migrations_dir_path: Option<String>,
    pub connection_url: String,
    pub max_reconnect_attempts: u32,
    pub timeout_duration: Duration,
    /* private fields */
}

Fields

migrations_dir_path: Option<String>

connection_url: String

max_reconnect_attempts: u32

timeout_duration: Duration

Implementations

impl Database

pub fn new( conn_url: String, max_pool_connections: usize, migrations_dir_path: Option<String>, ) -> Result<Database, PostgresModelError>

impl Database

pub async fn connect(&self) -> Result<Client, PostgresError>

pub async fn migrate(&mut self) -> Result<(), Box<dyn Error>>

pub async fn rollback(&mut self) -> Result<(), Box<dyn Error>>

pub async fn rollback_full(&mut self) -> Result<(), Box<dyn Error>>

pub async fn query( &self, query: &str, params: &[&(dyn ToSql + Sync)], ) -> Result<Vec<Row>, PostgresModelError>

pub async fn query_one( &self, query: &str, params: &[&(dyn ToSql + Sync)], ) -> Result<Row, PostgresModelError>

pub async fn execute( &self, query: &str, params: &[&(dyn ToSql + Sync)], ) -> Result<u64, PostgresModelError>

pub async fn check_connection(&self) -> Result<bool, PostgresModelError>