Struct PSConnection

pub struct PSConnection {
    pub session: Arc<Mutex<Option<Session>>>,
    pub client: Client,
    /* private fields */
}

Fields

session: Arc<Mutex<Option<Session>>>

client: Client

Implementations

impl PSConnection

pub fn new(host: &str, username: &str, password: &str) -> Self

Creates a new connection

pub fn new_from_env() -> Result<Self>

Creates a new connection from the environment variables (DATABASE_HOST, DATABASE_USERNAME, DATABASE_PASSWORD)

pub async fn execute(&self, query: &str) -> Result<()>

Execute a SQL query

pub async fn execute_raw(&self, query: &str) -> Result<ExecuteResponse>

Execute a SQL query and return the raw response

pub async fn transaction<F, Fut>(&self, f: F) -> Result<()>

where F: FnOnce(Self) -> Fut, Fut: Future<Output = Result<()>>,

As the name suggests, this function is making a transaction

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

Refreshes the session

Trait Implementations

impl Clone for PSConnection

fn clone(&self) -> PSConnection

Returns a copy of the value.

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

Performs copy-assignment from source.