feat: implement queryMany with pageable

Author: vominhtrius

infobip-spring-data-jdbc-querydsl/src/main/java/com/infobip/spring/data/jdbc/QuerydslJdbcFragment.java

@@ -9,6 +9,9 @@
 import java.util.Optional;
 import java.util.function.Function;
 
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+
 public interface QuerydslJdbcFragment<T> {
 
     /**
@@ -24,6 +27,8 @@ public interface QuerydslJdbcFragment<T> {
 
     List<T> queryMany(Function<SQLQuery<?>, SQLQuery<T>> query);
 
+    Page<T> queryMany(Function<SQLQuery<?>, SQLQuery<T>> query, Pageable pageable);
+
     /**
      * @return amount of affected rows
      */

infobip-spring-data-jdbc-querydsl/src/main/java/com/infobip/spring/data/jdbc/QuerydslJdbcPredicateExecutor.java

@@ -184,6 +184,15 @@ List<T> queryMany(SQLQuery<T> query) {
         return result;
     }
 
+    Page<T> queryMany(SQLQuery<T> query, Pageable pageable) {
+        Assert.notNull(query, "Query must not be null!");
+        Assert.notNull(pageable, "Pageable must not be null!");
+
+        var content = queryMany(querydsl.applyPagination(pageable, query).select(constructorExpression));
+
+        return PageableExecutionUtils.getPage(content, pageable, query::fetchCount);
+    }
+
     @Nullable
     private List<T> query(SQLQuery<T> query,
                   RowMapperResultSetExtractor<T> rowMapperResultSetExtractor) {

infobip-spring-data-jdbc-querydsl/src/main/java/com/infobip/spring/data/jdbc/SimpleQuerydslJdbcFragment.java

@@ -15,15 +15,22 @@
  */
 package com.infobip.spring.data.jdbc;
 
-import com.querydsl.core.types.*;
-import com.querydsl.sql.*;
-import com.querydsl.sql.dml.SQLUpdateClause;
-import org.springframework.transaction.annotation.Transactional;
-
 import java.util.List;
 import java.util.Optional;
 import java.util.function.Function;
 
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.querydsl.core.types.ConstructorExpression;
+import com.querydsl.core.types.Expression;
+import com.querydsl.core.types.Predicate;
+import com.querydsl.sql.RelationalPath;
+import com.querydsl.sql.SQLQuery;
+import com.querydsl.sql.SQLQueryFactory;
+import com.querydsl.sql.dml.SQLUpdateClause;
+
 @Transactional(readOnly = true)
 public class SimpleQuerydslJdbcFragment<T> implements QuerydslJdbcFragment<T> {
 
@@ -58,6 +65,11 @@ public List<T> queryMany(Function<SQLQuery<?>, SQLQuery<T>> query) {
         return querydslJdbcPredicateExecutor.queryMany(query.apply(sqlQueryFactory.query()));
     }
 
+	@Override
+	public Page<T> queryMany(Function<SQLQuery<?>, SQLQuery<T>> query, Pageable pageable) {
+		return querydslJdbcPredicateExecutor.queryMany(query.apply(sqlQueryFactory.query()), pageable);
+	}
+
     @Override
     @Transactional
     public long update(Function<SQLUpdateClause, Long> update) {