spg-sqlx 7.25.2

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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

//! v7.16.0 — `SpgPool` type alias + convenience constructors.
//!
//! v7.18 — pool concurrency is full-PG-parity. Each
//! `SpgConnection` lazily attaches a per-connection
//! `AsyncReadHandle` and refreshes it per statement, so a pool
//! of N connections runs N concurrent SELECTs against the
//! engine's snapshot path with read-committed semantics. The
//! convenience constructors no longer pin `max_connections(1)`
//! — they fall through to sqlx-core's default pool size, same
//! as `PgPool::connect()`.

use sqlx_core::error::Error;
use sqlx_core::pool::{Pool, PoolOptions};

use crate::database::Spg;
use crate::options::SpgConnectOptions;

/// Drop-in replacement for `sqlx::PgPool` over an in-process
/// SPG. Same `Pool<Spg>` shape — every sqlx-core API generic
/// over `Pool<DB>` works against this alias.
pub type SpgPool = Pool<Spg>;

/// Pool builder hooks — re-exported for ergonomic
/// `SpgPoolOptions::new()` calls in mailrs-shape code.
pub type SpgPoolOptions = PoolOptions<Spg>;

/// Convenience constructors that mirror sqlx's pool-construction
/// shape (`PgPool::connect(url)` style). Implemented as an
/// extension trait on [`SpgPool`] so consumers can write
/// `SpgPool::connect_in_memory().await` directly.
pub trait SpgPoolExt: Sized {
    /// In-memory pool — no persistence. Uses sqlx-core's
    /// default `max_connections` (10), matching `PgPool::connect`.
    fn connect_in_memory() -> futures_core::future::BoxFuture<'static, Result<SpgPool, Error>>;
    /// File-backed pool at `path`. Uses sqlx-core's default
    /// `max_connections` (10), matching `PgPool::connect`.
    fn connect_path(
        path: std::path::PathBuf,
    ) -> futures_core::future::BoxFuture<'static, Result<SpgPool, Error>>;
}

impl SpgPoolExt for SpgPool {
    fn connect_in_memory() -> futures_core::future::BoxFuture<'static, Result<SpgPool, Error>> {
        Box::pin(async {
            SpgPoolOptions::new()
                .connect_with(SpgConnectOptions::in_memory())
                .await
        })
    }

    fn connect_path(
        path: std::path::PathBuf,
    ) -> futures_core::future::BoxFuture<'static, Result<SpgPool, Error>> {
        Box::pin(async move {
            SpgPoolOptions::new()
                .connect_with(SpgConnectOptions::file(path))
                .await
        })
    }
}