fixed same type conversion

Author: chernser

client-v2/src/main/java/com/clickhouse/client/api/internal/SerializerUtils.java

@@ -417,17 +417,41 @@ public static POJOSetter compilePOJOSetter(Method setterMethod, ClickHouseColumn
                         false);
             } else if (!targetPrimitiveType.isPrimitive()) {
                 // boxing
+                String sourceInternalClassName;
+                if (column.getDataType().isSigned()) {
+                    sourceInternalClassName = Type.getInternalName(sourceType);
+                } else if (column.getDataType() == ClickHouseDataType.UInt64) {
+                    sourceInternalClassName = Type.getInternalName(BigInteger.class);
+                } else if (column.getDataType() == ClickHouseDataType.Enum8) {
+                    sourceInternalClassName = Type.getInternalName(Byte.class);
+                } else if (column.getDataType() == ClickHouseDataType.Enum16) {
+                    sourceInternalClassName = Type.getInternalName(Short.class);
+                } else {
+                    sourceInternalClassName = Type.getInternalName(
+                            ClickHouseDataType.toObjectType(ClickHouseDataType.toWiderPrimitiveType(
+                                    ClickHouseDataType.toPrimitiveType(sourceType))));
+                    System.out.println("sourceInternalClassName: " + sourceInternalClassName + " " + column.getColumnName());
+                }
                 mv.visitVarInsn(ALOAD, 2); // load object
-                mv.visitMethodInsn(INVOKEVIRTUAL,
-                        Type.getInternalName(sourceType),
-                        targetPrimitiveType.getSimpleName() + "Value",
-                        "()" + Type.getDescriptor(targetPrimitiveType),
-                        false);
-                mv.visitMethodInsn(INVOKESTATIC,
-                        Type.getInternalName(targetType),
-                        "valueOf",
-                        "(" + Type.getDescriptor(targetPrimitiveType) + ")" + Type.getDescriptor(targetType),
-                        false);
+                mv.visitTypeInsn(CHECKCAST, sourceInternalClassName);
+                try {
+                    if (!targetType.isAssignableFrom(Class.forName(sourceInternalClassName
+                            .replaceAll("/", ".")))) {
+                        mv.visitMethodInsn(INVOKEVIRTUAL,
+                                sourceInternalClassName,
+                                targetPrimitiveType.getSimpleName() + "Value",
+                                "()" + Type.getDescriptor(targetPrimitiveType),
+                                false);
+                        mv.visitMethodInsn(INVOKESTATIC,
+                                Type.getInternalName(targetType),
+                                "valueOf",
+                                "(" + Type.getDescriptor(targetPrimitiveType) + ")" + Type.getDescriptor(targetType),
+                                false);
+                    }
+                } catch (ClassNotFoundException e) {
+                    throw new ClientException("Cannot find class " + sourceInternalClassName + " to compile deserializer for "
+                            + column.getColumnName(), e);
+                }
             } else {
                 throw new ClientException("Unsupported conversion from " + sourceType + " to " + targetType);
             }

examples/demo-service/src/main/java/com/clickhouse/demo_service/DatasetController.java

@@ -193,6 +193,7 @@ public CalculationResult directDatasetFetchCached(@RequestParam(name = "limit",
             for (VirtualDatasetRecord record : result) {
                 p1Sum += record.getP1();
             }
+            log.info(result.toString());
             objectsPool.reset(); // reset pool to for next use
             return new CalculationResult(p1Sum);
         } catch (Exception e) {

examples/demo-service/src/main/java/com/clickhouse/demo_service/data/VirtualDatasetRecord.java

@@ -3,13 +3,15 @@
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
+import lombok.ToString;
 
 import java.math.BigInteger;
 import java.util.UUID;
 
 @Data
 @AllArgsConstructor
 @NoArgsConstructor
+@ToString
 public class VirtualDatasetRecord {
 
     private UUID id;