spg-sqlx 7.32.0

sqlx 0.8 Database driver for spg-embedded — let in-process callers use sqlx::query / query_as / pool.begin against an in-process SPG without a TCP listener. Backs mailrs's drop-in PgPool → SpgPool swap (gap-eval E1).
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

//! v7.16.0 — `sqlx::QueryResult` for SPG INSERT/UPDATE/DELETE.

/// Rows-affected counter returned by every DML execute. SPG
/// doesn't have last-insert-id (BIGSERIAL is computed inside
/// the engine + visible only via `RETURNING`); only the
/// affected-count is surfaced here.
#[derive(Debug, Default, Clone)]
pub struct SpgQueryResult {
    rows_affected: u64,
}

impl SpgQueryResult {
    /// Build a fresh result with the given rows-affected count.
    #[must_use]
    pub const fn new(rows_affected: u64) -> Self {
        Self { rows_affected }
    }

    /// Reads back the rows-affected count. Mirrors
    /// `sqlx::postgres::PgQueryResult::rows_affected`.
    #[must_use]
    pub const fn rows_affected(&self) -> u64 {
        self.rows_affected
    }
}

impl Extend<SpgQueryResult> for SpgQueryResult {
    fn extend<T: IntoIterator<Item = SpgQueryResult>>(&mut self, iter: T) {
        for next in iter {
            self.rows_affected = self.rows_affected.saturating_add(next.rows_affected);
        }
    }
}