Struct PgBackend 

pub struct PgBackend { /* private fields */ }

PostgreSQL backend backed by sqlx::PgPool.

Implementations

impl PgBackend

pub fn pool(&self) -> &PgPool

Get a reference to the underlying pool (for callers that still need it during the migration period).

pub fn from_pool(pool: PgPool) -> Self

Create from an existing pool (useful for tests and migration).

Trait Implementations

impl DatabaseBackend for PgBackend

fn connect<'life0, 'async_trait>( uri: &'life0 str, pool_size: u32, acquire_timeout_secs: u64, max_lifetime_secs: u64, idle_timeout_secs: u64, ) -> Pin<Box<dyn Future<Output = Result<Self, Error>> + Send + 'async_trait>>

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

Connect to the database and return a backend instance.

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

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

Query the database server version.

fn min_version(&self) -> (u32, u32)

Return the minimum supported version for this backend.

fn exec_raw<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [SqlParam], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Execute a raw SQL statement (no result set expected).

fn exec_statement<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [SqlParam], ) -> Pin<Box<dyn Future<Output = Result<StatementResult, Error>> + Send + 'async_trait>>

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

Execute a CTE-wrapped statement and parse the standard result set.

fn exec_in_transaction<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tx_vars: Option<&'life1 SqlBuilder>, pre_req: Option<&'life2 SqlBuilder>, _mutation: Option<&'life3 SqlBuilder>, main: Option<&'life4 SqlBuilder>, ) -> Pin<Box<dyn Future<Output = Result<StatementResult, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Begin a transaction and execute multiple statements within it.

fn introspector(&self) -> Box<dyn DbIntrospector + '_>

Get a database introspector for schema cache loading.

fn start_listener<'life0, 'life1, 'async_trait>( &'life0 self, channel: &'life1 str, cancel: Receiver<bool>, on_event: Arc<dyn Fn(String) + Send + Sync>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Start a background change listener (e.g. PostgreSQL NOTIFY).

fn map_error(&self, err: Box<dyn Error + Send + Sync>) -> Error

Map a backend-specific database error into our Error type.