Deserializer interface created and override system created

Author: talhadilber

pom.xml

@@ -29,6 +29,10 @@
             <groupId>org.springframework</groupId>
             <artifactId>spring-webmvc</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-autoconfigure</artifactId>

src/main/java/com/beyt/config/DeserializerConfig.java

@@ -0,0 +1,18 @@
+package com.beyt.config;
+
+import com.beyt.deserializer.BasicDeserializer;
+import com.beyt.deserializer.IDeserializer;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class DeserializerConfig {
+
+    @Bean
+    @ConditionalOnMissingBean
+    public IDeserializer basicDeserializer() {
+        return new BasicDeserializer();
+//        return new JacksonDeserializer();// TODO
+    }
+}

src/main/java/com/beyt/deserializer/BasicDeserializer.java

@@ -0,0 +1,10 @@
+package com.beyt.deserializer;
+
+import com.beyt.util.ReflectionUtil;
+
+public class BasicDeserializer implements IDeserializer {
+    @Override
+    public <T> T deserialize(Object value, Class<T> clazz) throws Exception {
+        return ReflectionUtil.deserializeObject(value.toString(), clazz);
+    }
+}

src/main/java/com/beyt/deserializer/IDeserializer.java

@@ -0,0 +1,5 @@
+package com.beyt.deserializer;
+
+public interface IDeserializer {
+    <T> T deserialize(Object value, Class<T> clazz) throws Exception;
+}

src/main/java/com/beyt/deserializer/JacksonDeserializer.java

@@ -0,0 +1,30 @@
+package com.beyt.deserializer;
+
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.MapperFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.json.JsonMapper;
+
+public class JacksonDeserializer implements IDeserializer {
+
+    public static final ObjectMapper mapper;
+
+    static {
+        mapper = JsonMapper.builder()
+                .enable(MapperFeature.ACCEPT_CASE_INSENSITIVE_ENUMS)
+                .build();
+        mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+    }
+
+    @Override
+    public <T> T deserialize(Object value, Class<T> clazz) throws Exception {
+        if (value.getClass().isAssignableFrom(clazz)) {
+            return (T) value;
+        }
+
+        if (clazz.isEnum()) {
+            return (T) Enum.valueOf((Class<Enum>) clazz, value.toString());
+        }
+        return mapper.readValue(value.toString(), clazz);
+    }
+}

src/main/java/com/beyt/exception/DynamicQueryValueSerializeException.java

@@ -0,0 +1,19 @@
+package com.beyt.exception;
+
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * Created by tdilber at 24-Aug-19
+ */
+@Slf4j
+public class DynamicQueryValueSerializeException extends RuntimeException {
+    public DynamicQueryValueSerializeException(String errorMessage) {
+        super(errorMessage);
+        log.error(errorMessage, this);
+    }
+
+    public DynamicQueryValueSerializeException(String errorMessage, Throwable err) {
+        super(errorMessage, err);
+        log.error(errorMessage, err);
+    }
+}

src/main/java/com/beyt/query/DynamicSpecification.java

@@ -3,11 +3,8 @@
 import com.beyt.dto.Criteria;
 import com.beyt.dto.enums.CriteriaType;
 import com.beyt.dto.enums.JoinType;
-import com.beyt.exception.DynamicQueryNoAvailableEnumException;
-import com.beyt.exception.DynamicQueryNoAvailableOperationException;
-import com.beyt.exception.DynamicQueryNoAvailableOrOperationUsageException;
-import com.beyt.exception.DynamicQueryNoAvailableParenthesesOperationUsageException;
-import com.beyt.util.ReflectionUtil;
+import com.beyt.exception.*;
+import com.beyt.util.ApplicationContextUtil;
 import com.beyt.util.SpecificationUtil;
 import org.apache.commons.lang3.tuple.ImmutableTriple;
 import org.apache.commons.lang3.tuple.Triple;
@@ -113,10 +110,10 @@ public static String getFieldName(String key) {
         return splitedKey[splitedKey.length - 1];
     }
 
-    private Predicate addPredicate(Path<?> root, CriteriaBuilder builder, Criteria criteria) {
+    protected Predicate addPredicate(Path<?> root, CriteriaBuilder builder, Criteria criteria) {
         if (!criteria.operation.equals(CriteriaType.SPECIFIED)) {
             try {
-                criteria.values = ReflectionUtil.convertObjectArrayToIfNotAvailable(root.get(criteria.key).getJavaType(), criteria.values);
+                criteria.values = deserialize(root.get(criteria.key).getJavaType(), criteria.values);
             } catch (Exception e) {
                 throw new DynamicQueryNoAvailableEnumException("There is a "
                         + root.get(criteria.key).getJavaType().getSimpleName() + " Enum Problem in Criteria Key: "
@@ -142,4 +139,20 @@ private Predicate addPredicate(Path<?> root, CriteriaBuilder builder, Criteria c
         joinMap.put(joinMapKey, join);
         return join;
     }
+
+    protected List<Object> deserialize(Class<?> clazz, List<Object> objects) throws Exception {
+        List<Object> result = new ArrayList<>();
+        for (Object object : objects) {
+            Object deserialized = null;
+            try {
+                deserialized = ApplicationContextUtil.getDeserializer().deserialize(object.toString(), clazz);
+            } catch (Exception e) {
+                throw new DynamicQueryValueSerializeException("There is a "
+                        + clazz.getSimpleName() + " Deserialization Problem in Criteria Value: "
+                        + object.toString());
+            }
+            result.add(deserialized);
+        }
+        return result;
+    }
 }

src/main/java/com/beyt/util/ApplicationContextUtil.java

@@ -1,5 +1,6 @@
 package com.beyt.util;
 
+import com.beyt.deserializer.IDeserializer;
 import com.beyt.provider.IEntityManagerProvider;
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
@@ -10,11 +11,13 @@
 public class ApplicationContextUtil implements ApplicationContextAware {
  private static ApplicationContext applicationContext;
     private static IEntityManagerProvider entityManagerProvider;
+    private static IDeserializer deserializer;
 
   @Override
   public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
       ApplicationContextUtil.applicationContext = applicationContext;
       ApplicationContextUtil.entityManagerProvider = applicationContext.getBean(IEntityManagerProvider.class);
+      ApplicationContextUtil.deserializer = applicationContext.getBean(IDeserializer.class);
   }
 
   public static ApplicationContext getApplicationContext() {
@@ -24,4 +27,8 @@ public static ApplicationContext getApplicationContext() {
   public static EntityManager getEntityManager(){
       return entityManagerProvider.provide();
   }
+
+    public static IDeserializer getDeserializer() {
+        return deserializer;
+    }
 }

src/main/java/com/beyt/util/ReflectionUtil.java

@@ -2,6 +2,7 @@
 
 import com.beyt.util.field.FieldUtil;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.SerializationException;
 
 import java.lang.reflect.Method;
 import java.util.ArrayList;
@@ -49,4 +50,13 @@ public static List<Object> convertObjectArrayToIfNotAvailable(Class<?> clazz, Li
 
         return objects;
     }
+
+    @SuppressWarnings("unchecked")
+    public static <T> T deserializeObject(String serialized, Class<T> clazz) throws Exception {
+        if (FieldUtil.isSupportedType(clazz)) {
+            return (T) FieldUtil.fillValue(clazz, serialized);
+        }
+
+        throw new SerializationException("Field Type: " + clazz.getName() + " not supported!");
+    }
 }