spg-sqlx 7.37.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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

//! v7.16.0 — `Type` / `Encode` / `Decode` for `String` / `&str`.

use sqlx_core::decode::Decode;
use sqlx_core::encode::{Encode, IsNull};
use sqlx_core::error::BoxDynError;
use sqlx_core::types::Type;

use spg_embedded::Value as EngineValue;

use crate::arguments::SpgArgumentValue;
use crate::database::Spg;
use crate::type_info::{Kind, SpgTypeInfo};
use crate::value::SpgValueRef;

impl Type<Spg> for str {
    fn type_info() -> SpgTypeInfo {
        SpgTypeInfo::of(Kind::Text)
    }

    fn compatible(ty: &SpgTypeInfo) -> bool {
        // v7.17.0 Phase 3.P0-67 / P0-68 / P0-69 — exact-decimal,
        // pgvector, tsvector, and UUID cells all decode to their
        // canonical PG text form, so `String` / `&str` accept
        // them as compatible. Keeps
        // `query_as::<_, (String,)>("SELECT vec_col …")` shapes
        // working without enabling type-specific features.
        matches!(
            ty.kind(),
            Kind::Text | Kind::Numeric | Kind::Vector | Kind::TsVector | Kind::Uuid
        )
    }
}

impl Type<Spg> for String {
    fn type_info() -> SpgTypeInfo {
        <str as Type<Spg>>::type_info()
    }

    fn compatible(ty: &SpgTypeInfo) -> bool {
        <str as Type<Spg>>::compatible(ty)
    }
}

impl<'q> Encode<'q, Spg> for &'q str {
    fn encode_by_ref(&self, buf: &mut Vec<SpgArgumentValue<'q>>) -> Result<IsNull, BoxDynError> {
        buf.push(SpgArgumentValue {
            value: EngineValue::Text((*self).to_string()),
            type_info: Some(<str as Type<Spg>>::type_info()),
            _phantom: core::marker::PhantomData,
        });
        Ok(IsNull::No)
    }
}

impl<'q> Encode<'q, Spg> for String {
    fn encode_by_ref(&self, buf: &mut Vec<SpgArgumentValue<'q>>) -> Result<IsNull, BoxDynError> {
        buf.push(SpgArgumentValue {
            value: EngineValue::Text(self.clone()),
            type_info: Some(<String as Type<Spg>>::type_info()),
            _phantom: core::marker::PhantomData,
        });
        Ok(IsNull::No)
    }
}

impl<'r> Decode<'r, Spg> for String {
    fn decode(value: SpgValueRef<'r>) -> Result<Self, BoxDynError> {
        // v7.17.0 Phase 3.P0-67 / P0-68 / P0-69 — NUMERIC /
        // VECTOR / TSVECTOR / UUID cells all decode to their
        // canonical PG text form so the dominant
        // `query_as::<_, (String,)>` pattern works without
        // enabling any type-specific feature.
        if let Some(s) = crate::types::decimal::try_numeric_as_string(value.engine()) {
            return Ok(s);
        }
        if let Some(s) = crate::types::vector::try_vector_as_string(value.engine()) {
            return Ok(s);
        }
        if let Some(s) = crate::types::vector::try_tsvector_as_string(value.engine()) {
            return Ok(s);
        }
        if let Some(s) = crate::types::uuid::try_uuid_as_string(value.engine()) {
            return Ok(s);
        }
        match value.engine() {
            EngineValue::Text(s) | EngineValue::Json(s) => Ok(s.clone()),
            other => Err(format!("cannot decode {other:?} as String / TEXT").into()),
        }
    }
}

impl<'r> Decode<'r, Spg> for &'r str {
    fn decode(value: SpgValueRef<'r>) -> Result<Self, BoxDynError> {
        match value.engine() {
            EngineValue::Text(s) | EngineValue::Json(s) => Ok(s.as_str()),
            other => Err(format!("cannot decode {other:?} as &str / TEXT").into()),
        }
    }
}