Struct sqlx::postgres::PgConnection

pub struct PgConnection { /* fields omitted */ }

An asynchronous connection to a Postgres database.

The connection string expected by Connection::open should be a PostgreSQL connection string, as documented at https://www.postgresql.org/docs/12/libpq-connect.html#LIBPQ-CONNSTRING

Trait Implementations

impl Connection for PgConnection

fn open<T>(
    url: T
) -> Pin<Box<dyn Future<Output = Result<PgConnection, Error>> + 'static + Send>> where
    T: TryInto<Url, Error = Error>,
    PgConnection: Sized, 

Establish a new database connection.

fn close(
    self
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'static + Send>>

Close this database connection.

fn ping(&mut self) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send>>

Verifies a connection to the database is still alive.

impl Executor for PgConnection

type Database = Postgres

fn send<'e, 'q>(
    &'e mut self,
    query: &'q str
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'e + Send>> where
    'q: 'e, 

Send a raw SQL command to the database.

fn execute<'e, 'q>(
    &'e mut self,
    query: &'q str,
    args: PgArguments
) -> Pin<Box<dyn Future<Output = Result<u64, Error>> + 'e + Send>> where
    'q: 'e, 

Execute the query, returning the number of rows affected.

fn fetch<'e, 'q>(
    &'e mut self,
    query: &'q str,
    args: PgArguments
) -> Pin<Box<dyn Stream<Item = Result<PgRow, Error>> + 'e + Send>> where
    'q: 'e, 

Executes the query and returns a [Stream] of [Row].

fn describe<'e, 'q>(
    &'e mut self,
    query: &'q str
) -> Pin<Box<dyn Future<Output = Result<Describe<<PgConnection as Executor>::Database>, Error>> + 'e + Send>> where
    'q: 'e, 

Analyze the SQL query and report the inferred bind parameter types and returned columns.

fn fetch_optional<'e, 'q>(
    &'e mut self,
    query: &'q str,
    args: <Self::Database as Database>::Arguments
) -> Pin<Box<dyn Future<Output = Result<Option<<Self::Database as Database>::Row>, Error>> + 'e + Send>> where
    'q: 'e, 

Executes the query and returns up to resulting record.

fn fetch_one<'e, 'q>(
    &'e mut self,
    query: &'q str,
    args: <Self::Database as Database>::Arguments
) -> Pin<Box<dyn Future<Output = Result<<Self::Database as Database>::Row, Error>> + 'e + Send>> where
    'q: 'e, 

Execute the query and return at most one resulting record.