Added support for deserializing object property values based on value class (#510)

Add the getValue method in Type to deserialize JSON data from a
ResultSet into an object of the specified class (clazz).

```java
package com.example;

import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.MapperFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.querydsl.core.types.Path;
import com.querydsl.sql.Configuration;
import com.querydsl.sql.MySQLTemplates;
import com.querydsl.sql.RelationalPathBase;
import com.querydsl.sql.SQLTemplates;
import com.querydsl.sql.mysql.MySQLQueryFactory;
import com.querydsl.sql.types.Type;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Import;
import org.springframework.jdbc.datasource.DataSourceUtils;

import javax.sql.DataSource;
import java.io.IOException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.Arrays;
import java.util.List;
import java.util.Map;

import static org.junit.jupiter.api.Assertions.assertEquals;

/**
 * ExampleTest class with QueryDSL configuration and JSON handling for DataSource properties.
 */
@SpringBootConfiguration
@import(ExampleTest.QueryDSLConfiguration.class)
@SpringBootTest
@EnableAutoConfiguration
class ExampleTest {

    /**
     * Interface representing a JSON entity.
     */
    interface JsonEntity {
    }

    /**
     * JSON type handler using ObjectMapper to convert JSON strings to specified type objects.
     */
    static class JSONType implements Type<JsonEntity> {
        private final ObjectMapper objectMapper;

        public JSONType() {
            objectMapper = new ObjectMapper();
            objectMapper.configure(MapperFeature.SORT_PROPERTIES_ALPHABETICALLY, true);
            objectMapper.configure(SerializationFeature.ORDER_MAP_ENTRIES_BY_KEYS, true);
            objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
            objectMapper.configure(JsonParser.Feature.ALLOW_SINGLE_QUOTES, true);
            objectMapper.configure(JsonParser.Feature.ALLOW_UNQUOTED_FIELD_NAMES, true);
        }

        @OverRide
        public int[] getSQLTypes() {
            return new int[]{Types.BLOB, Types.VARBINARY, Types.VARCHAR, Types.BINARY};
        }

        @OverRide
        public Class<JsonEntity> getReturnedClass() {
            return JsonEntity.class;
        }

        @OverRide
        public String getLiteral(JsonEntity value) {
            if (value == null) {
                return null;
            }
            try {
                return objectMapper.writeValueAsString(value);
            } catch (JsonProcessingException e) {
                throw new RuntimeException(e);
            }
        }

        @OverRide
        public JsonEntity getValue(ResultSet rs, int startIndex) throws SQLException {
            try {
                return objectMapper.readValue(rs.getBytes(startIndex), JsonEntity.class);
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }

        @OverRide
        public JsonEntity getValue(ResultSet rs, int startIndex, Class<JsonEntity> clazz) throws SQLException {
            try {
                return objectMapper.readValue(rs.getBytes(startIndex), clazz);
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }

        @OverRide
        public void setValue(PreparedStatement st, int startIndex, JsonEntity value) throws SQLException {
            st.setObject(startIndex, getLiteral(value));
        }
    }

    /**
     * DataSourceProperties class representing the properties of a data source.
     */
    public static class DataSourceProperties implements JsonEntity {
        private String hostname;
        private int port;
        private String schema;
        private String username;
        private String password;
        private Map<String, Object> connectionProperties;

        public String getHostname() {
            return hostname;
        }

        public void setHostname(String hostname) {
            this.hostname = hostname;
        }

        public int getPort() {
            return port;
        }

        public void setPort(int port) {
            this.port = port;
        }

        public String getSchema() {
            return schema;
        }

        public void setSchema(String schema) {
            this.schema = schema;
        }

        public String getUsername() {
            return username;
        }

        public void setUsername(String username) {
            this.username = username;
        }

        public String getPassword() {
            return password;
        }

        public void setPassword(String password) {
            this.password = password;
        }

        public Map<String, Object> getConnectionProperties() {
            return connectionProperties;
        }

        public void setConnectionProperties(Map<String, Object> connectionProperties) {
            this.connectionProperties = connectionProperties;
        }
    }

    /**
     * DataSourceEntity class representing a data source entity.
     *
     * <pre>
     *     CREATE TABLE `data_source`  (
     *      `id` int NOT NULL AUTO_INCREMENT,
     *      `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL,
     *      `properties` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL,
     *       PRIMARY KEY (`id`) USING BTREE
     *     ) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
     *
     *     INSERT INTO `data_source` VALUES (1, 'mysql-localhost', '{\"hostname\": \"localhost\", \"port\": 3306, \"schema\": \"test\", \"username\": \"root\", \"password\": \"root\", \"connectionProperties\": {\"useSSL\": true, \"useCursorFetch\": true}}');
     * </pre>
     */
    public static class DataSourceEntity {
        private Integer id;
        private String name;
        private DataSourceProperties properties;

        public Integer getId() {
            return id;
        }

        public void setId(Integer id) {
            this.id = id;
        }

        public String getName() {
            return name;
        }

        public void setName(String name) {
            this.name = name;
        }

        public DataSourceProperties getProperties() {
            return properties;
        }

        public void setProperties(DataSourceProperties properties) {
            this.properties = properties;
        }
    }

    /**
     * QDataSourceEntity class representing the QueryDSL path for the DataSourceEntity.
     */
    public static class QDataSourceEntity extends RelationalPathBase<DataSourceEntity> {
        public QDataSourceEntity() {
            this(DataSourceEntity.class, "ds", null, "data_source");
        }

        public QDataSourceEntity(Class<? extends DataSourceEntity> type, String variable, String schema, String table) {
            super(type, variable, schema, table);
        }

        @OverRide
        public List<Path<?>> getColumns() {
            return Arrays.asList(
                    createNumber("id", Integer.class),
                    createString("name"),
                    createSimple("properties", DataSourceProperties.class)
            );
        }
    }

    /**
     * QueryDSL configuration class.
     */
    static class QueryDSLConfiguration {
        /**
         * SQLTemplates implementation for MySQL.
         */
        @bean
        public SQLTemplates sqlTemplates() {
            return new MySQLTemplates();
        }

        /**
         * MySQLQueryFactory - main entry point to build and execute SQL queries.
         */
        @bean
        public MySQLQueryFactory queryFactory(DataSource dataSource) {
            Configuration configuration = new Configuration(new MySQLTemplates());
            configuration.register(new JSONType());
            return new MySQLQueryFactory(configuration, () -> DataSourceUtils.getConnection(dataSource));
        }
    }

    @Autowired
    private MySQLQueryFactory queryFactory;

    @test
    public void test() {
        QDataSourceEntity qDataSource = new QDataSourceEntity();
        List<DataSourceEntity> list = queryFactory.selectFrom(qDataSource).fetch();
        DataSourceEntity dataSourceEntity = list.get(0);

        assertEquals("localhost", dataSourceEntity.getProperties().getHostname());
    }
}
```

Author: velo

.circleci/config.yml

@@ -140,7 +140,7 @@ jobs:
       - run:
           name: 'Test'
           command: |
-            ./mvnw -ntp -B install -Pquickbuild -pl :querydsl-sql-spring,:querydsl-jpa-spring,:querydsl-kotlin-codegen,:querydsl-mongodb,:querydsl-r2dbc -am -T2
+            ./mvnw -ntp -B install -Pquickbuild -pl :querydsl-sql-spring,:querydsl-jpa-spring,:querydsl-kotlin-codegen,:querydsl-mongodb,:querydsl-r2dbc,:querydsl-sql-json -am -T2
             ./mvnw -ntp -B verify -Pexamples -rf :querydsl-examples
       - save-test-results
   buildQuarkusExample:

querydsl-examples/pom.xml

@@ -12,6 +12,10 @@
   <packaging>pom</packaging>
   <name>Querydsl - Examples</name>
 
+  <properties>
+    <main.java.version>17</main.java.version>
+  </properties>
+
   <modules>
     <module>querydsl-example-sql-guice</module>
     <module>querydsl-example-sql-spring</module>

querydsl-examples/querydsl-example-jpa-quarkus/src/main/java/com/querydsl/example/FruitResource.java

@@ -101,8 +101,8 @@ public Response toResponse(Exception exception) {
       LOGGER.error("Failed to handle request", exception);
 
       int code = 500;
-      if (exception instanceof WebApplicationException) {
-        code = ((WebApplicationException) exception).getResponse().getStatus();
+      if (exception instanceof WebApplicationException applicationException) {
+        code = applicationException.getResponse().getStatus();
       }
 
       ObjectNode exceptionJson = objectMapper.createObjectNode();

querydsl-examples/querydsl-example-jpa-spring/pom.xml

@@ -10,11 +10,6 @@
   <artifactId>querydsl-example-jpa-spring</artifactId>
   <name>Querydsl example - JPA Spring</name>
 
-  <properties>
-    <!-- to match spring JDK version -->
-    <main.java.version>17</main.java.version>
-  </properties>
-
   <dependencyManagement>
     <dependencies>
       <dependency>

querydsl-examples/querydsl-example-jpa-spring/src/main/java/com/querydsl/example/Customer.java

@@ -24,7 +24,7 @@ public Customer(String firstName, String lastName) {
 
   @Override
   public String toString() {
-    return String.format("Customer[id=%d, firstName='%s', lastName='%s']", id, firstName, lastName);
+    return "Customer[id=%d, firstName='%s', lastName='%s']".formatted(id, firstName, lastName);
   }
 
   public Long getId() {

querydsl-examples/querydsl-example-r2dbc-sql-codegen/pom.xml

@@ -11,13 +11,6 @@
   <artifactId>querydsl-example-r2dbc-sql-codegen</artifactId>
   <name>Querydsl example - R2DBC SQL Codegen</name>
 
-  <properties>
-    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-
-    <!-- to match spring JDK version -->
-    <main.java.version>17</main.java.version>
-  </properties>
-
   <dependencyManagement>
     <dependencies>
       <dependency>
@@ -31,9 +24,7 @@
   </dependencyManagement>
 
   <dependencies>
-
     <!-- spring -->
-
     <dependency>
       <groupId>org.springframework</groupId>
       <artifactId>spring-context</artifactId>

querydsl-examples/querydsl-example-sql-spring/pom.xml

@@ -11,17 +11,8 @@
   <artifactId>querydsl-example-sql-spring</artifactId>
   <name>Querydsl example - SQL Spring</name>
 
-  <properties>
-    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-
-    <!-- to match spring JDK version -->
-    <main.java.version>17</main.java.version>
-  </properties>
-
   <dependencies>
-
     <!-- spring -->
-
     <dependency>
       <groupId>org.springframework</groupId>
       <artifactId>spring-context</artifactId>
@@ -51,6 +42,11 @@
       <artifactId>querydsl-sql</artifactId>
       <version>${project.version}</version>
     </dependency>
+    <dependency>
+      <groupId>io.github.openfeign.querydsl</groupId>
+      <artifactId>querydsl-sql-json</artifactId>
+      <version>${project.version}</version>
+    </dependency>
     <dependency>
       <groupId>io.github.openfeign.querydsl</groupId>
       <artifactId>querydsl-sql-spring</artifactId>
@@ -90,6 +86,13 @@
             <customType>com.querydsl.sql.types.LocalDateTimeType</customType>
             <customType>com.querydsl.sql.types.LocalDateType</customType>
           </customTypes>
+          <typeMappings>
+            <typeMapping>
+              <table>CUSTOMER_ADDRESS</table>
+              <column>ADDRESS</column>
+              <type>com.querydsl.example.dto.Address</type>
+            </typeMapping>
+          </typeMappings>
           <packageName>com.querydsl.example.sql</packageName>
           <targetFolder>${project.basedir}/target/generated-sources/java</targetFolder>
         </configuration>

querydsl-examples/querydsl-example-sql-spring/src/main/java/com/querydsl/example/config/JdbcConfiguration.java

@@ -2,11 +2,11 @@
 
 import com.querydsl.sql.H2Templates;
 import com.querydsl.sql.SQLQueryFactory;
-import com.querydsl.sql.SQLTemplates;
 import com.querydsl.sql.spring.SpringConnectionProvider;
 import com.querydsl.sql.spring.SpringExceptionTranslator;
 import com.querydsl.sql.types.LocalDateTimeType;
 import com.querydsl.sql.types.LocalDateType;
+import io.github.openfeign.querydsl.sql.json.types.JSONType;
 import javax.sql.DataSource;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
@@ -25,7 +25,7 @@ public class JdbcConfiguration {
 
   @Bean
   public DataSource dataSource() {
-    SimpleDriverDataSource dataSource = new SimpleDriverDataSource();
+    var dataSource = new SimpleDriverDataSource();
     Class driver;
     try {
       driver = Class.forName(env.getRequiredProperty("jdbc.driver"));
@@ -46,17 +46,18 @@ public PlatformTransactionManager transactionManager() {
 
   @Bean
   public com.querydsl.sql.Configuration querydslConfiguration() {
-    SQLTemplates templates = H2Templates.builder().build();
-    com.querydsl.sql.Configuration configuration = new com.querydsl.sql.Configuration(templates);
+    var templates = H2Templates.builder().build();
+    var configuration = new com.querydsl.sql.Configuration(templates);
     configuration.setExceptionTranslator(new SpringExceptionTranslator());
     configuration.register(new LocalDateTimeType());
     configuration.register(new LocalDateType());
+    configuration.register(new JSONType());
     return configuration;
   }
 
   @Bean
   public SQLQueryFactory queryFactory() {
-    SpringConnectionProvider provider = new SpringConnectionProvider(dataSource());
+    var provider = new SpringConnectionProvider(dataSource());
     return new SQLQueryFactory(querydslConfiguration(), provider);
   }
 }

querydsl-examples/querydsl-example-sql-spring/src/main/java/com/querydsl/example/dao/CustomerDaoImpl.java

@@ -1,20 +1,17 @@
 package com.querydsl.example.dao;
 
 import static com.querydsl.core.types.Projections.bean;
-import static com.querydsl.example.sql.QAddress.address;
 import static com.querydsl.example.sql.QCustomer.customer;
 import static com.querydsl.example.sql.QCustomerAddress.customerAddress;
 import static com.querydsl.example.sql.QPerson.person;
 
 import com.querydsl.core.group.GroupBy;
 import com.querydsl.core.types.Predicate;
 import com.querydsl.core.types.QBean;
-import com.querydsl.example.dto.Address;
 import com.querydsl.example.dto.Customer;
 import com.querydsl.example.dto.CustomerAddress;
 import com.querydsl.example.dto.Person;
 import com.querydsl.sql.SQLQueryFactory;
-import com.querydsl.sql.dml.SQLInsertClause;
 import java.util.List;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
@@ -30,7 +27,7 @@ public class CustomerDaoImpl implements CustomerDao {
           customerAddress.addressTypeCode,
           customerAddress.fromDate,
           customerAddress.toDate,
-          bean(Address.class, address.all()).as("address"));
+          customerAddress.address);
 
   final QBean<Customer> customerBean =
       bean(
@@ -42,7 +39,7 @@ public class CustomerDaoImpl implements CustomerDao {
 
   @Override
   public Customer findById(long id) {
-    List<Customer> customers = findAll(customer.id.eq(id));
+    var customers = findAll(customer.id.eq(id));
     return customers.isEmpty() ? null : customers.get(0);
   }
 
@@ -52,14 +49,13 @@ public List<Customer> findAll(Predicate... where) {
         .from(customer)
         .leftJoin(customer.contactPersonFk, person)
         .leftJoin(customer._customer3Fk, customerAddress)
-        .leftJoin(customerAddress.addressFk, address)
         .where(where)
         .transform(GroupBy.groupBy(customer.id).list(customerBean));
   }
 
   @Override
   public Customer save(Customer c) {
-    Long id = c.getId();
+    var id = c.getId();
 
     if (id == null) {
       id =
@@ -81,16 +77,11 @@ public Customer save(Customer c) {
       queryFactory.delete(customerAddress).where(customerAddress.customerId.eq(id)).execute();
     }
 
-    SQLInsertClause insert = queryFactory.insert(customerAddress);
+    var insert = queryFactory.insert(customerAddress);
     for (CustomerAddress ca : c.getAddresses()) {
-      if (ca.getAddress().getId() == null) {
-        ca.getAddress()
-            .setId(
-                queryFactory.insert(address).populate(ca.getAddress()).executeWithKey(address.id));
-      }
       insert
           .set(customerAddress.customerId, id)
-          .set(customerAddress.addressId, ca.getAddress().getId())
+          .set(customerAddress.address, ca.getAddress())
           .set(customerAddress.addressTypeCode, ca.getAddressTypeCode())
           .set(customerAddress.fromDate, ca.getFromDate())
           .set(customerAddress.toDate, ca.getToDate())

querydsl-examples/querydsl-example-sql-spring/src/main/java/com/querydsl/example/dto/Address.java

@@ -1,9 +1,10 @@
 package com.querydsl.example.dto;
 
+import io.github.openfeign.querydsl.sql.json.*;
 import lombok.Data;
 
 @Data
-public class Address {
+public class Address implements JsonEntity {
 
   private Long id;