Struct postgres_query::Query

pub struct Query<'a> {
    pub sql: &'static str,
    pub parameters: Vec<&'a (dyn ToSql + Sync)>,
}

A static query with dynamic parameters.

Usage

The preferred way of constructing a Query is by using the query! macro.

When executing the query you have two options, either:

1. use the provided methods: execute, fetch, query, etc.
2. use the sql and parameters fields as arguments to the standard Client methods

#[derive(FromSqlRow)]
struct Person {
    age: i32,
    name: String,
}

let client: Client = connect(/* ... */);
let query = query!("SELECT age, name FROM people");

// Option 1
let people: Vec<Person> = query.fetch(&client).await?;

// Option 2
let rows: Vec<Row> = client.query(query.sql, &query.parameters).await?;
let people: Vec<Person> = Person::from_row_multi(&rows)?;

Fields

sql: &'static str

parameters: Vec<&'a (dyn ToSql + Sync)>

Methods

impl<'a> Query<'a>

pub async fn execute<'_, '_, C>(&'_ self, client: &'_ C) -> Result<u64> where
    C: GenericClient + Sync, 

Execute this query and return the number of affected rows.

pub async fn fetch<'_, '_, T, C>(&'_ self, client: &'_ C) -> Result<Vec<T>> where
    T: FromSqlRow,
    C: GenericClient + Sync, 

Execute this query and return the resulting values.

pub async fn fetch_one<'_, '_, T, C>(&'_ self, client: &'_ C) -> Result<T> where
    T: FromSqlRow,
    C: GenericClient + Sync, 

Execute this query and return the resulting value. This method will return an error if, not exactly one row was returned by the query.

pub async fn fetch_streaming<'_, '_, T, C>(
    &'_ self,
    client: &'_ C
) -> Result<impl Stream<Item = Result<T>>> where
    T: FromSqlRow,
    C: GenericClient + Sync, 

Execute this query and return the resulting values as an asynchronous stream of values.

pub async fn query<'_, '_, C>(&'_ self, client: &'_ C) -> Result<Vec<Row>> where
    C: GenericClient + Sync, 

Execute this query and return the resulting rows.

pub async fn query_one<'_, '_, C>(&'_ self, client: &'_ C) -> Result<Row> where
    C: GenericClient + Sync, 

Execute this query and return the resulting row. This method will return an error if, not exactly one row was returned by the query.

pub async fn query_streaming<'_, '_, C>(
    &'_ self,
    client: &'_ C
) -> Result<impl Stream<Item = Result<Row>>> where
    C: GenericClient + Sync, 

Execute this query and return the resulting values as an asynchronous stream of values.

Trait Implementations

impl<'a> Clone for Query<'a>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Query<'a>

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

Formats the value using the given formatter.