Doing Json or JsonB on String Update case

Author: amigin

my-postgres-core/src/sql_update/sql_update_model.rs

@@ -7,7 +7,7 @@ use super::SqlUpdateModelValue;
 
 pub trait SqlUpdateModel {
     fn get_column_name(no: usize) -> ColumnName;
-    fn get_field_value(&self, no: usize) -> SqlUpdateModelValue;
+    fn get_field_value<'s>(&'s self, no: usize) -> SqlUpdateModelValue<'s>;
     fn get_fields_amount() -> usize;
 
     fn get_primary_key_as_single_string(&self) -> String;

my-postgres-core/src/sql_update/sql_update_value_provider.rs

@@ -20,8 +20,15 @@ impl SqlUpdateValueProvider for String {
     fn get_update_value(
         &self,
         params: &mut SqlValues,
-        _metadata: &Option<SqlValueMetadata>,
+        metadata: &Option<SqlValueMetadata>,
     ) -> SqlUpdateValue {
+        if let Some(metadata) = metadata {
+            if metadata.is_json_or_jsonb() {
+                let index = params.push(self.into());
+                return SqlUpdateValue::Json(index);
+            }
+        }
+
         let index = params.push(self.into());
         SqlUpdateValue::Index(index)
     }
@@ -31,8 +38,14 @@ impl<'s> SqlUpdateValueProvider for &'s str {
     fn get_update_value(
         &self,
         params: &mut SqlValues,
-        _metadata: &Option<SqlValueMetadata>,
+        metadata: &Option<SqlValueMetadata>,
     ) -> SqlUpdateValue {
+        if let Some(metadata) = metadata {
+            if metadata.is_json_or_jsonb() {
+                let index = params.push((*self).into());
+                return SqlUpdateValue::Json(index);
+            }
+        }
         let index = params.push((*self).into());
         SqlUpdateValue::Index(index)
     }

my-postgres-core/src/sql_value/sql_value_metadata.rs

@@ -4,3 +4,13 @@ pub struct SqlValueMetadata {
     pub operator: Option<&'static str>,
     pub wrap_column_name: Option<&'static str>,
 }
+
+impl SqlValueMetadata {
+    pub fn is_json_or_jsonb(&self) -> bool {
+        if let Some(sql_type) = self.sql_type {
+            return sql_type.eq_ignore_ascii_case("json") || sql_type.eq_ignore_ascii_case("jsonb");
+        }
+
+        false
+    }
+}