Struct PostgresDb 

pub struct PostgresDb { /* private fields */ }

The store’s driver over a Postgres pool. Values go in the statement’s text as literals of unknown type, so Postgres infers each one’s type as it does for node-postgres’s untyped parameters.

Implementations

impl PostgresDb

pub fn new(pool: PgPool) -> PostgresDb

The store’s driver over a pool.

Trait Implementations

impl Clone for PostgresDb

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Db for PostgresDb

fn dialect(&self) -> Dialect

The SQL the database speaks.

fn all<'a>( &'a self, sql: &'a str, params: Vec<Param>, ) -> BoxFuture<'a, Result<Vec<Row>, DbError>>

Runs a query and gives its rows.

fn run<'a>( &'a self, sql: &'a str, params: Vec<Param>, ) -> BoxFuture<'a, Result<u64, DbError>>

Runs a statement and says how many rows it matched.

fn hold(&self, kind: Hold) -> BoxFuture<'_, Result<Arc<dyn Db>, DbError>>

One connection, held for a transaction or a lock until finish. Statements on it run in turn with nothing else of the store’s in between. Holding a transaction on a connection already in one joins it.

fn finish( &self, _ok: bool, ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + '_>>

Ends what hold began: commits a transaction (ok) or rolls it back, or lets go of a lock. A connection that was not held answers Ok.

fn metered(&self) -> bool

True for a database reached one statement at a time over the network with a cap on statements per request (Cloudflare D1), so long jobs send fewer, larger pieces.

fn close(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Lets the connections go.

fn prefix(&self) -> Option<&str>

The prefix this Db puts on Runlight’s table and index names in place of rl_, when it puts one (Prefixed), so a store over it keeps it.