Add json support to sql queries and update example to show usage

Author: velo

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

@@ -51,6 +51,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 +95,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;
 

querydsl-examples/querydsl-example-sql-spring/src/main/sql/001_schema.sql

@@ -82,23 +82,12 @@ create table customer_order_delivery (
   constraint order2_fk foreign key (order_id) references customer_order(id)
 );
 
-create table address (
-  id identity primary key, 
-  street varchar(64),
-  zip varchar(64),
-  town varchar(64),
-  state varchar(64),
-  country varchar(3),
-  other_details varchar(64) 
-);
-
 create table customer_address (
   customer_id long,
-  address_id long,
+  address clob,
   from_date date,
   to_date date,
   address_type_code varchar(12),
 
-  constraint customer3_fk foreign key (customer_id) references customer(id),
-  constraint address_fk foreign key (address_id) references address(id)
+  constraint customer3_fk foreign key (customer_id) references customer(id)
 );

querydsl-libraries/pom.xml

@@ -23,6 +23,7 @@
     <module>querydsl-sql</module>
     <module>querydsl-sql-spatial</module>
     <module>querydsl-sql-spring</module>
+    <module>querydsl-sql-json</module>
     <!-- Reactive SQL -->
     <module>querydsl-r2dbc</module>