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
use ::serde::Deserialize; use crate::de::DeRow; use crate::de::PgDeError; use crate::pg::*; pub trait PgRowExt { fn cast<'de, T>(&self) -> Result<T, PgDeError> where T: Deserialize<'de>; } impl PgRowExt for PgRow { fn cast<'de, T>(&self) -> Result<T, PgDeError> where T: Deserialize<'de>, { #[cfg(feature = "debug-logs")] log::trace!("PgRowExt::cast<'de, {}>", std::any::type_name::<T>()); let de = DeRow::new(self); ::serde::Deserialize::deserialize(de) } } pub trait PgRowOptionExt { fn cast<'de, T>(&self) -> Result<Option<T>, PgDeError> where T: Deserialize<'de>; } impl PgRowOptionExt for Option<&PgRow> { fn cast<'de, T>(&self) -> Result<Option<T>, PgDeError> where T: Deserialize<'de>, { self.as_ref().map(|r| r.cast()).transpose() } } pub trait PgSeqExt { fn cast<'de, T>(&self) -> Result<Vec<T>, PgDeError> where T: Deserialize<'de>; } impl PgSeqExt for Vec<PgRow> { fn cast<'de, T>(&self) -> Result<Vec<T>, PgDeError> where T: Deserialize<'de>, { self.iter().map(|r| r.cast()).collect() } }