Struct PgHelpers 

pub struct PgHelpers;

PostgreSQL-specific query helpers.

Implementations

impl PgHelpers

pub async fn query_returning(pool: &PgPool, sql: &str) -> SqlxResult<Vec<PgRow>>

Execute a query with RETURNING clause.

pub async fn upsert( _pool: &PgPool, table: &str, columns: &[&str], conflict_columns: &[&str], update_columns: &[&str], ) -> SqlxResult<String>

Execute INSERT … ON CONFLICT (upsert).

pub fn array_literal<T: Display>(values: &[T]) -> String

Generate a PostgreSQL array literal.

pub fn json_path(column: &str, path: &[&str]) -> String

Generate a PostgreSQL JSON/JSONB path expression.

pub async fn has_extension(pool: &PgPool, extension: &str) -> SqlxResult<bool>

Check if a PostgreSQL extension is available.

pub async fn version(pool: &PgPool) -> SqlxResult<String>

Get PostgreSQL version.

pub async fn listen(pool: &PgPool, channel: &str) -> SqlxResult<()>

Execute LISTEN for notifications.

pub async fn notify( pool: &PgPool, channel: &str, payload: &str, ) -> SqlxResult<()>

Execute NOTIFY.