Struct Connection

pub struct Connection<'a> { /* private fields */ }

Implementations

impl Connection<'_>

pub async fn select<R>( &self, table: &str, filter: impl Borrow<Filter<'_>>, ) -> Result<Vec<R>, Error>

where R: FromRowOwned + NamedColumns,

pub async fn select_one<R>( &self, table: &str, filter: impl Borrow<Filter<'_>>, ) -> Result<R, Error>

where R: FromRowOwned + NamedColumns,

pub async fn select_opt<R>( &self, table: &str, filter: impl Borrow<Filter<'_>>, ) -> Result<Option<R>, Error>

where R: FromRowOwned + NamedColumns,

pub async fn count( &self, table: &str, column: &str, filter: impl Borrow<Filter<'_>>, ) -> Result<u64, Error>

count

A column is required because you should select a column which has some indexes on it, this makes the call a lot cheaper

pub async fn insert<U>(&self, table: &str, item: &U) -> Result<(), Error>

where U: ToRow,

pub async fn insert_many<U, I>( &self, table: &str, items: I, ) -> Result<(), Error>

where U: ToRowStatic, I: IntoIterator, I::Item: Borrow<U>,

pub async fn update<U>( &self, table: &str, item: &U, filter: impl Borrow<WhereFilter<'_>>, ) -> Result<(), Error>

where U: ToRow,

pub async fn delete( &self, table: &str, filter: impl Borrow<WhereFilter<'_>>, ) -> Result<(), Error>

pub async fn prepare_cached(&self, query: &str) -> Result<Statement, Error>

Like tokio_postgres::Client::prepare_typed() but uses a cached statement if one exists.

pub async fn prepare(&self, query: &str) -> Result<Statement, Error>

See tokio_postgres::Client::prepare()

pub async fn prepare_typed_cached( &self, query: &str, types: &[Type], ) -> Result<Statement, Error>

Like tokio_postgres::Client::prepare_typed() but uses a cached statement if one exists.

pub async fn prepare_typed( &self, query: &str, parameter_types: &[Type], ) -> Result<Statement, Error>

See tokio_postgres::Client::prepare_typed()

pub async fn query<R, T>( &self, statement: &T, params: &[&(dyn ToSql + Sync)], ) -> Result<Vec<R>, Error>

where R: FromRowOwned, T: ?Sized + ToStatement,

See tokio_postgres::Client::query()

pub async fn query_one<R, T>( &self, statement: &T, params: &[&(dyn ToSql + Sync)], ) -> Result<R, Error>

where R: FromRowOwned, T: ?Sized + ToStatement,

See tokio_postgres::Client::query_one()

pub async fn query_opt<R, T>( &self, statement: &T, params: &[&(dyn ToSql + Sync)], ) -> Result<Option<R>, Error>

where R: FromRowOwned, T: ?Sized + ToStatement,

See tokio_postgres::Client::query_opt()

pub async fn query_raw_opt<R, T, P, I>( &self, statement: &T, params: I, ) -> Result<Option<R>, Error>

where R: FromRowOwned, T: ?Sized + ToStatement, P: BorrowToSql, I: IntoIterator<Item = P>, I::IntoIter: ExactSizeIterator,

See tokio_postgres::Client::query_opt() and tokio_postgres::Client::query_raw()

pub async fn query_raw<T, P, I>( &self, statement: &T, params: I, ) -> Result<RowStream, Error>

where T: ?Sized + ToStatement, P: BorrowToSql, I: IntoIterator<Item = P>, I::IntoIter: ExactSizeIterator,

See tokio_postgres::Client::query_raw()

pub async fn execute<T>( &self, statement: &T, params: &[&(dyn ToSql + Sync)], ) -> Result<u64, Error>

where T: ?Sized + ToStatement,

See tokio_postgres::Client::execute()

pub async fn execute_raw<T, P, I>( &self, statement: &T, params: I, ) -> Result<u64, Error>

where T: ?Sized + ToStatement, P: BorrowToSql, I: IntoIterator<Item = P>, I::IntoIter: ExactSizeIterator,

See tokio_postgres::Client::execute_raw()

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

See tokio_postgres::Client::batch_execute()

Trait Implementations

impl<'a> Clone for Connection<'a>

fn clone(&self) -> Connection<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Connection<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Copy for Connection<'a>