ankurah-storage-postgres 0.8.1

Ankurah storage engine using Postgres
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

// use tokio_postgres::types::ToSql;

use ankurah_core::value::Value;

#[derive(Debug)]
pub enum PGValue {
    Bytea(Vec<u8>),
    CharacterVarying(String),
    SmallInt(i16),
    Integer(i32),
    BigInt(i64),
    DoublePrecision(f64),
    Boolean(bool),
    /// JSON value - stored as PostgreSQL's native jsonb type for query support.
    /// Uses serde_json::Value for proper type conversion via tokio-postgres.
    Jsonb(serde_json::Value),
}

impl PGValue {
    pub fn postgres_type(&self) -> &'static str {
        match *self {
            PGValue::CharacterVarying(_) => "varchar",
            PGValue::SmallInt(_) => "int2",
            PGValue::Integer(_) => "int4",
            PGValue::BigInt(_) => "int8",
            PGValue::DoublePrecision(_) => "float8",
            PGValue::Bytea(_) => "bytea",
            PGValue::Boolean(_) => "boolean",
            PGValue::Jsonb(_) => "jsonb",
        }
    }
}

impl From<Value> for PGValue {
    fn from(property: Value) -> Self {
        match property {
            Value::String(string) => PGValue::CharacterVarying(string),
            Value::I16(integer) => PGValue::SmallInt(integer),
            Value::I32(integer) => PGValue::Integer(integer),
            Value::I64(integer) => PGValue::BigInt(integer),
            Value::F64(float) => PGValue::DoublePrecision(float),
            Value::Bool(bool) => PGValue::Boolean(bool),
            Value::EntityId(entity_id) => PGValue::CharacterVarying(entity_id.to_base64()),
            Value::Object(items) => PGValue::Bytea(items),
            Value::Binary(items) => PGValue::Bytea(items),
            // Value::Json already contains serde_json::Value
            Value::Json(json) => PGValue::Jsonb(json),
        }
    }
}

// impl ToSql for PGValue {
//     fn to_sql(
//         &self,
//         ty: &tokio_postgres::types::Type,
//         out: &mut tokio_postgres::types::private::BytesMut,
//     ) -> Result<tokio_postgres::types::IsNull, Box<dyn std::error::Error + Sync + Send>>
//     where
//         Self: Sized,
//     {
//         match self {
//             PGValue::CharacterVarying(v) => v.to_sql(ty, out),
//             PGValue::BigInt(v) => v.to_sql(ty, out),
//             PGValue::Bytea(v) => v.to_sql(ty, out),
//         }
//     }

//     fn accepts(ty: &tokio_postgres::types::Type) -> bool
//     where Self: Sized {
//         match self {
//             PGValue::CharacterVarying(v) => v.accepts(ty),
//             PGValue::BigInt(v) => v.accepts(ty),
//             PGValue::Bytea(v) => v.accepts(ty),
//         }
//     }

//     fn to_sql_checked(
//         &self,
//         ty: &tokio_postgres::types::Type,
//         out: &mut tokio_postgres::types::private::BytesMut,
//     ) -> Result<tokio_postgres::types::IsNull, Box<dyn std::error::Error + Sync + Send>> {
//         todo!()
//     }
// }