runledger-postgres 0.3.0

PostgreSQL persistence layer for the Runledger durable job and workflow system
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use crate::{DbTx, Error, QueryError, QueryErrorCategory, Result};

pub(crate) async fn ensure_read_committed_tx(
    tx: &mut DbTx<'_>,
    operation: &'static str,
    code: &'static str,
    client_message: &'static str,
) -> Result<()> {
    // SHOW reports the effective isolation for the current transaction, so a
    // caller's SET TRANSACTION change is visible here. PostgreSQL treats READ
    // UNCOMMITTED as READ COMMITTED.
    //
    // Call this at the start of each transaction-sensitive operation. The guard
    // is not meant to defend against callers changing isolation again later in
    // the same transaction.
    let isolation: String = sqlx::query_scalar("SHOW transaction_isolation")
        .fetch_one(&mut **tx)
        .await
        .map_err(|error| {
            Error::from_query_sqlx_with_context("inspect transaction isolation", error)
        })?;

    let normalized = isolation.to_ascii_lowercase();
    if matches!(normalized.as_str(), "read committed" | "read uncommitted") {
        return Ok(());
    }

    Err(Error::QueryError(QueryError::from_classified(
        QueryErrorCategory::Validation,
        code,
        client_message,
        format!("{operation} requires READ COMMITTED isolation; got {isolation}"),
    )))
}