jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-19 18:05:41 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: orderField was ignored in the findAsync method

Browse Source
This commit is contained in:
YannC.
2025-11-24 11:32:14 +01:00
parent a5847aeb3a
commit 3a16c758fe
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
jdbc/src/main/java/io/kestra/jdbc/repository/AbstractJdbcCrudRepository.java
View File

@@ -254,6 +254,8 @@ public abstract class AbstractJdbcCrudRepository<T> extends AbstractJdbcReposito
.getDslContextWrapper()
.transaction(configuration -> {
DSLContext context = DSL.using(configuration);
SelectSeekStepN<Record1<String>> selectOrdered = null;
var select = context
.select(VALUE_FIELD)
@@ -262,10 +264,14 @@ public abstract class AbstractJdbcCrudRepository<T> extends AbstractJdbcReposito
.and(condition);
if (orderByFields != null) {
select.orderBy(orderByFields);
selectOrdered = select.orderBy(orderByFields);
}
try (Stream<Record1<String>> stream = select.fetchSize(FETCH_SIZE).stream()){
ResultQuery<Record1<String>> selectFetched = selectOrdered != null ?
selectOrdered.fetchSize(FETCH_SIZE) :
select.fetchSize(FETCH_SIZE);
try (Stream<Record1<String>> stream = selectFetched.stream()){
stream.map((Record record) -> jdbcRepository.map(record))
.forEach(emitter::next);
} finally {