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>

Build INSERT … ON CONFLICT SQL (does not execute; run it via your pool).

The pool parameter is currently unused; it is reserved for a future executing variant. Identifiers are quoted via quote_identifier; pass trusted identifiers only, not arbitrary user input.

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

Generate a PostgreSQL array literal.

Embedded single quotes in values are escaped (' -> ''). Prefer bound parameters for untrusted values.

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

Generate a PostgreSQL JSON/JSONB path expression.

The column is quoted via quote_identifier and embedded single quotes in path elements are escaped (' -> ''). Pass trusted identifiers only, not arbitrary user input.

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.

The channel is a PostgreSQL identifier and is quoted via quote_identifier; pass trusted channel names only.

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

Execute NOTIFY.

The channel is a PostgreSQL identifier and is quoted via quote_identifier; single quotes in the payload are escaped (' -> ''). Pass trusted channel names only.