postgres_types/
serde_json_1.rs1use crate::{FromSql, IsNull, ToSql, Type};
2use bytes::{BufMut, BytesMut};
3use serde_1::{Deserialize, Serialize};
4use serde_json_1::Value;
5use std::error::Error;
6use std::fmt::Debug;
7use std::io::Read;
8
9#[derive(Clone, Default, Debug, PartialEq, Eq)]
11pub struct Json<T>(pub T);
12
13impl<'a, T> FromSql<'a> for Json<T>
14where
15 T: Deserialize<'a>,
16{
17 fn from_sql(ty: &Type, mut raw: &'a [u8]) -> Result<Json<T>, Box<dyn Error + Sync + Send>> {
18 if *ty == Type::JSONB {
19 let mut b = [0; 1];
20 raw.read_exact(&mut b)?;
21 if b[0] != 1 {
23 return Err("unsupported JSONB encoding version".into());
24 }
25 }
26 serde_json_1::de::from_slice(raw)
27 .map(Json)
28 .map_err(Into::into)
29 }
30
31 accepts!(JSON, JSONB);
32}
33
34impl<T> ToSql for Json<T>
35where
36 T: Serialize + Debug,
37{
38 fn to_sql(
39 &self,
40 ty: &Type,
41 out: &mut BytesMut,
42 ) -> Result<IsNull, Box<dyn Error + Sync + Send>> {
43 if *ty == Type::JSONB {
44 out.put_u8(1);
45 }
46 serde_json_1::ser::to_writer(out.writer(), &self.0)?;
47 Ok(IsNull::No)
48 }
49
50 accepts!(JSON, JSONB);
51 to_sql_checked!();
52}
53
54impl<'a> FromSql<'a> for Value {
55 fn from_sql(ty: &Type, raw: &[u8]) -> Result<Value, Box<dyn Error + Sync + Send>> {
56 Json::<Value>::from_sql(ty, raw).map(|json| json.0)
57 }
58
59 accepts!(JSON, JSONB);
60}
61
62impl ToSql for Value {
63 fn to_sql(
64 &self,
65 ty: &Type,
66 out: &mut BytesMut,
67 ) -> Result<IsNull, Box<dyn Error + Sync + Send>> {
68 Json(self).to_sql(ty, out)
69 }
70
71 accepts!(JSON, JSONB);
72 to_sql_checked!();
73}