Struct Postgres 

pub struct Postgres { /* private fields */ }

Available on crate feature postgres only.

Implementations

impl Postgres

pub async fn connect( relative_path: PathBuf, pb: ProgressBar, ) -> Result<Self, Error>

Creates a runner for executing queries against an existing postgres connection. relative_path is used for display output and to create a postgres schema.

The database connection details can be overridden by the PG_URI environment variable.

This defaults to

PG_URI="postgresql://postgres@127.0.0.1/test"

See https://docs.rs/tokio-postgres/latest/tokio_postgres/config/struct.Config.html#url for format

pub async fn connect_with_tracked_sql( relative_path: PathBuf, pb: ProgressBar, currently_executing_sql_tracker: CurrentlyExecutingSqlTracker, ) -> Result<Self, Error>

Creates a runner for executing queries against an existing postgres connection with a tracker for currently executing SQL statements.

pub fn with_currently_executing_sql_tracker( self, currently_executing_sql_tracker: CurrentlyExecutingSqlTracker, ) -> Self

Add a tracker that will track the currently executed SQL statement.

This is useful for logging and debugging purposes.

Trait Implementations

impl AsyncDB for Postgres

type Error = Error

The error type of SQL execution.

type ColumnType = DFColumnType

The type of result columns

fn run<'life0, 'life1, 'async_trait>( &'life0 mut self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<DBOutput<Self::ColumnType>, Self::Error>> + Send + 'async_trait>>

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

Async run a SQL query and return the output.

fn engine_name(&self) -> &str

Engine name of current database.

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

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

Shutdown the connection gracefully.

fn sleep<'async_trait>( dur: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

Runner calls this function to perform sleep.

fn run_command<'async_trait>( command: Command, ) -> Pin<Box<dyn Future<Output = Result<Output, Error>> + Send + 'async_trait>>

Runner calls this function to run a system command.