in persistence-commons/persistence-commons-infinispan/src/main/java/org/kie/kogito/persistence/infinispan/query/InfinispanQuery.java [88:107]
public List<T> execute() {
StringBuilder queryString = new StringBuilder("FROM " + rootType + " o");
if (filters != null && !filters.isEmpty()) {
queryString.append(" WHERE ");
queryString.append(filters.stream().map(filterStringFunction()).collect(joining(AND)));
}
if (sortBy != null && !sortBy.isEmpty()) {
queryString.append(" ORDER BY ");
queryString.append(sortBy.stream().map(f -> "o." + f.getAttribute() + " " + f.getSort().name()).collect(joining(", ")));
}
LOGGER.debug("Executing Infinispan query: {}", queryString);
org.infinispan.query.dsl.Query<T> query = qf.create(queryString.toString());
if (limit != null) {
query.maxResults(limit);
}
if (offset != null) {
query.startOffset(offset);
}
return query.execute().list();
}