Struct PostgresAdapter 

pub struct PostgresAdapter { /* private fields */ }

Async PostgreSQL adapter backed by an sqlx connection pool.

Obtain one via PostgresAdapter::connect_url (quick) or PostgresAdapter::connect (full PostgresConfig options).

Implementations

impl PostgresAdapter

pub async fn connect(config: PostgresConfig) -> Result<Self>

pub async fn connect_url(url: impl Into<String>) -> Result<Self>

Trait Implementations

impl DatabaseAdapter for PostgresAdapter

fn name(&self) -> &'static str

Human-readable backend name, e.g. "postgres", "mongo".

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

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

Ping the server — cheapest possible health check.

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

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

Close all connections and release pool resources.

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

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

Create the table / collection described by schema if it does not exist.

fn drop_table<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Drop the table / collection. Irreversible.

fn table_exists<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Return true if the table / collection exists.

fn insert<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, row: Row, ) -> Pin<Box<dyn Future<Output = Result<Row>> + Send + 'async_trait>>

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

Insert one row and return it with any database-generated fields populated (e.g. auto-increment IDs, DEFAULT expressions).

fn insert_many<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, rows: Vec<Row>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Insert multiple rows in a single transaction. Returns the count inserted.

fn find<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 QueryBuilder, ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>>> + Send + 'async_trait>>

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

Execute the SELECT described by query and return all matching rows.

fn find_one<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 QueryBuilder, ) -> Pin<Box<dyn Future<Output = Result<Option<Row>>> + Send + 'async_trait>>

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

Execute the SELECT described by query and return the first row if any.

fn update<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 QueryBuilder, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Execute the UPDATE described by query. Returns the number of rows affected.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 QueryBuilder, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Execute the DELETE described by query. Returns the number of rows deleted.

fn count<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 QueryBuilder, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Count rows matching query.

fn execute_raw<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, bindings: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Execute a raw SQL string (or JSON command for MongoDB) with positional parameter bindings. Returns the number of rows affected.

fn query_raw<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, bindings: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Row>>> + Send + 'async_trait>>

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

Execute a raw SQL string with positional bindings and return the result rows.