Struct Connection 

pub struct Connection { /* private fields */ }

Implementations

impl Connection

pub fn new(client: Client) -> Self

Initialize a Toasty PostgreSQL connection using an initialized client.

pub async fn connect<T>(config: Config, tls: T) -> Result<Self>

where T: MakeTlsConnect<Socket> + 'static, T::Stream: Send,

Connects to a PostgreSQL database using a [postgres::Config].

See [postgres::Client::configure] for more information.

pub async fn create_table( &mut self, schema: &Schema, table: &Table, ) -> Result<()>

Creates a table.

Trait Implementations

impl Connection for Connection

fn exec<'life0, 'life1, 'async_trait>( &'life0 mut self, schema: &'life1 Arc<Schema>, op: Operation, ) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a database operation

fn push_schema<'life0, 'life1, 'async_trait>( &'life0 mut self, schema: &'life1 Schema, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Creates tables and indices defined in the schema on the database. TODO: This will probably use database introspection in the future.

fn applied_migrations<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Vec<AppliedMigration>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns a list of currently applied database migrations.

fn apply_migration<'life0, 'life1, 'async_trait>( &'life0 mut self, id: u64, name: String, migration: &'life1 Migration, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Applies a migration to the database.

impl Debug for Connection

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

Formats the value using the given formatter.

impl From<Client> for Connection

fn from(client: Client) -> Self

Converts to this type from the input type.