Struct Database

pub struct Database {
    pub client: Client,
    pub migrations_dir_path: Option<String>,
    pub reconnection_url: String,
    pub max_reconnect_attempts: u32,
    pub timeout_duration: Duration,
}

Fields

client: Client

migrations_dir_path: Option<String>

reconnection_url: String

max_reconnect_attempts: u32

timeout_duration: Duration

Implementations

impl Database

pub async fn connect( conn_url: String, migrations_dir_path: Option<String>, ) -> Result<Database, PostgresError>

pub async fn reconnect(&mut self) -> Result<(), 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>, PostgresError>

pub async fn query_with_reconnect( &mut 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, PostgresError>

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

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

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