Impl FromSql and ToSql for serde_json::RawValue (#35)

Co-authored-by: Brian <brianheylin@dreamsolution.nl>

Author: bheylin

postgres-types/Cargo.toml

@@ -46,7 +46,7 @@ eui48-1 = { version = "1.0", package = "eui48", optional = true, default-feature
 geo-types-06 = { version = "0.6", package = "geo-types", optional = true }
 geo-types-0_7 = { version = "0.7", package = "geo-types", optional = true }
 serde-1 = { version = "1.0", package = "serde", optional = true }
-serde_json-1 = { version = "1.0", package = "serde_json", optional = true }
+serde_json-1 = { version = "1.0", package = "serde_json", optional = true, features = ["raw_value"]}
 uuid-08 = { version = "0.8", package = "uuid", optional = true }
 uuid-1 = { version = "1.0", package = "uuid", optional = true }
 time-02 = { version = "0.2", package = "time", optional = true }

postgres-types/src/serde_json_1.rs

@@ -1,7 +1,7 @@
 use crate::{FromSql, IsNull, ToSql, Type};
 use bytes::{BufMut, BytesMut};
 use serde_1::{Deserialize, Serialize};
-use serde_json_1::Value;
+use serde_json_1::{value::RawValue, Value};
 use std::error::Error;
 use std::fmt::Debug;
 use std::io::Read;
@@ -71,3 +71,45 @@ impl ToSql for Value {
     accepts!(JSON, JSONB);
     to_sql_checked!();
 }
+
+impl<'a> FromSql<'a> for &'a RawValue {
+    fn from_sql(ty: &Type, raw: &'a [u8]) -> Result<&'a RawValue, Box<dyn Error + Sync + Send>> {
+        Json::<&'a RawValue>::from_sql(ty, raw).map(|json| json.0)
+    }
+
+    accepts!(JSON, JSONB);
+}
+
+impl<'a> ToSql for &'a RawValue {
+    fn to_sql(
+        &self,
+        ty: &Type,
+        out: &mut BytesMut,
+    ) -> Result<IsNull, Box<dyn Error + Sync + Send>> {
+        Json(self).to_sql(ty, out)
+    }
+
+    accepts!(JSON, JSONB);
+    to_sql_checked!();
+}
+
+impl<'a> FromSql<'a> for Box<RawValue> {
+    fn from_sql(ty: &Type, raw: &[u8]) -> Result<Box<RawValue>, Box<dyn Error + Sync + Send>> {
+        Json::<Box<RawValue>>::from_sql(ty, raw).map(|json| json.0)
+    }
+
+    accepts!(JSON, JSONB);
+}
+
+impl ToSql for Box<RawValue> {
+    fn to_sql(
+        &self,
+        ty: &Type,
+        out: &mut BytesMut,
+    ) -> Result<IsNull, Box<dyn Error + Sync + Send>> {
+        Json(self).to_sql(ty, out)
+    }
+
+    accepts!(JSON, JSONB);
+    to_sql_checked!();
+}