Struct PostgresClient 

pub struct PostgresClient<F: ConnectionFactory> { /* private fields */ }

Implementations

impl<F: ConnectionFactory> PostgresClient<F>

pub async fn copy_out( &mut self, query: &(impl Statement + ?Sized), parameters: &[&dyn ToSql], ) -> Result<CopyReader<'_, F>, ElefantClientError>

pub async fn copy_in( &mut self, query: &(impl Statement + ?Sized), parameters: &[&dyn ToSql], ) -> Result<CopyWriter<'_, F>, ElefantClientError>

impl<F: ConnectionFactory> PostgresClient<F>

pub async fn execute_non_query<S>( &mut self, query: &S, parameters: &[&dyn ToSql], ) -> Result<(), ElefantClientError>

where S: Statement + ?Sized,

Execute a non-query statement using binary mode (with prepared statements)

pub async fn execute_non_query_simple( &mut self, query: &str, ) -> Result<(), ElefantClientError>

Execute a non-query statement using simple query mode (text format, no parameters)

impl<F: ConnectionFactory> PostgresClient<F>

pub async fn query( &mut self, query: &(impl Statement + ?Sized), parameters: &[&dyn ToSql], ) -> Result<QueryResult<'_, F>, ElefantClientError>

Execute a query in binary mode - always uses prepared statements

pub async fn query_simple( &mut self, query: &str, ) -> Result<SimpleQueryResult<'_, F>, ElefantClientError>

Execute a simple query in text mode - only accepts &str, no parameters

pub async fn prepare_query( &mut self, query: &str, ) -> Result<PreparedQuery, ElefantClientError>

impl<F: ConnectionFactory> PostgresClient<F>

pub async fn create_replication_slot( &mut self, slot_name: &str, output_plugin: &str, ) -> Result<(String, Lsn), ElefantClientError>

pub async fn drop_replication_slot( &mut self, slot_name: &str, ) -> Result<(), ElefantClientError>

pub async fn start_replication( &mut self, slot_name: &str, lsn: Lsn, options: &str, ) -> Result<ReplicationStream<'_, F>, ElefantClientError>

impl<F: ConnectionFactory> PostgresClient<F>

pub async fn reset(&mut self) -> Result<(), ElefantClientError>

pub fn get_parameter(&self, name: &str) -> Option<&str>

Get a server parameter received via ParameterStatus messages.

PostgreSQL sends these during connection startup and whenever a session parameter changes. Common parameters include server_version, server_encoding, TimeZone, etc.

pub async fn close(self) -> Result<(), ElefantClientError>

Gracefully close this connection by sending a Terminate message to the backend and a TLS close_notify (if applicable). Consumes the client so it cannot be used afterward.