serde-pgrow 0.3.6

Deserialize a serde-type from a PgRow
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

use std::error::Error as StdError;

use ::serde::de::Error as DeError;
use ::serde_json::Error as SerdeJsonError;
use ::tokio_postgres::Error as PgError;

use crate::pg::PgType;
use crate::AnyError;

#[derive(Debug, ::thiserror::Error)]
pub enum PgDeError {
    #[error("PgDeError::Custom: {}", _0)]
    Custom(String, #[source] Option<AnyError>),

    #[error("PgDeError::PgError")]
    PgError(#[source] PgError),

    #[error("PgDeError::SerdeJsonError")]
    SerdeJsonError(#[source] SerdeJsonError),

    // UnexpectedNull(String),
    #[error("PgDeError::UnsupportedType: {:?}", _0)]
    UnsupportedType(PgType),

    #[error("PgDeError::CastError")]
    CastError(#[source] Box<dyn StdError + Send + Sync>),

    #[error("PgDeError::WasNull")]
    WasNull,

    #[error("PgDeError::Unimplemented: {} [{}]", _0, _1)]
    Unimplemented(&'static str, &'static str),
}

impl PgDeError {
    pub fn cast_error(e: Box<dyn StdError + Send + Sync>) -> Self {
        Self::CastError(e)
    }
}

impl From<PgError> for PgDeError {
    fn from(pg_error: PgError) -> Self {
        Self::PgError(pg_error)
    }
}

impl DeError for PgDeError {
    fn custom<T: std::fmt::Display>(msg: T) -> Self {
        Self::Custom(format!("{}", msg), None)
    }
}