Skip to content

Commit 93bb0c8

Browse files
author
Gerald Unterrainer
committed
Merge branch 'develop'
2 parents 43f5dc6 + 01a6513 commit 93bb0c8

File tree

4 files changed

+33
-2
lines changed

4 files changed

+33
-2
lines changed

pom.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
<modelVersion>4.0.0</modelVersion>
1919
<artifactId>http-server</artifactId>
20-
<version>0.2.21</version>
20+
<version>0.2.22</version>
2121
<name>HttpServer</name>
2222
<packaging>jar</packaging>
2323

src/main/java/info/unterrainer/commons/httpserver/daos/AsyncJpaListQueryBuilder.java

+14
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,9 @@
44
import java.util.HashSet;
55
import java.util.Set;
66

7+
import javax.persistence.EntityManager;
78
import javax.persistence.EntityManagerFactory;
9+
import javax.persistence.TypedQuery;
810

911
import info.unterrainer.commons.rdbutils.entities.BasicAsyncJpa;
1012
import info.unterrainer.commons.rdbutils.enums.AsyncState;
@@ -18,6 +20,18 @@ public class AsyncJpaListQueryBuilder<P extends BasicAsyncJpa>
1820
super(emf, dao, resultType);
1921
}
2022

23+
@Override
24+
public TypedQuery<P> getTypedQuery(final EntityManager em) {
25+
return dao.coreDao.getQuery(em, selectClause, joinClause, whereClause, parameters, resultType, orderByClause,
26+
lockPessimistic, asyncStates, readTenantIds);
27+
}
28+
29+
@Override
30+
public javax.persistence.Query getCountQuery(final EntityManager em) {
31+
return dao.coreDao.getCountQuery(em, selectClause, joinClause, whereClause, parameters, asyncStates,
32+
readTenantIds);
33+
}
34+
2135
public JpaListQuery<P> build() {
2236
return new JpaListQuery<>(emf, this);
2337
}

src/main/java/info/unterrainer/commons/httpserver/daos/AsyncListQueryBuilder.java

+14
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,9 @@
44
import java.util.HashSet;
55
import java.util.Set;
66

7+
import javax.persistence.EntityManager;
78
import javax.persistence.EntityManagerFactory;
9+
import javax.persistence.TypedQuery;
810

911
import info.unterrainer.commons.rdbutils.entities.BasicAsyncJpa;
1012
import info.unterrainer.commons.rdbutils.enums.AsyncState;
@@ -18,6 +20,18 @@ public class AsyncListQueryBuilder<P extends BasicAsyncJpa, T>
1820
super(emf, dao, resultType);
1921
}
2022

23+
@Override
24+
public TypedQuery<T> getTypedQuery(final EntityManager em) {
25+
return dao.coreDao.getQuery(em, selectClause, joinClause, whereClause, parameters, resultType, orderByClause,
26+
lockPessimistic, asyncStates, readTenantIds);
27+
}
28+
29+
@Override
30+
public javax.persistence.Query getCountQuery(final EntityManager em) {
31+
return dao.coreDao.getCountQuery(em, selectClause, joinClause, whereClause, parameters, asyncStates,
32+
readTenantIds);
33+
}
34+
2135
public ListQuery<P, T> build() {
2236
return new ListQuery<>(emf, this);
2337
}

src/main/java/info/unterrainer/commons/httpserver/daos/ListQuery.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,10 @@ public List<T> getList() {
114114
* @return a list containing the rows as specified
115115
*/
116116
public List<T> getList(final long offset, final long size) {
117-
return withEntityManager(em -> builder.getDao().getList(em, builder.getTypedQuery(em), offset, size));
117+
return withEntityManager(em -> {
118+
TypedQuery<T> query = builder.getTypedQuery(em);
119+
return builder.getDao().getList(em, query, offset, size);
120+
});
118121
}
119122

120123
/**

0 commit comments

Comments
 (0)