diff --git a/jnosql-communication/jnosql-communication-semistructured/src/main/java/org/eclipse/jnosql/communication/semistructured/CursorExecutor.java b/jnosql-communication/jnosql-communication-semistructured/src/main/java/org/eclipse/jnosql/communication/semistructured/CursorExecutor.java index 447cea1b2..e93d451ae 100644 --- a/jnosql-communication/jnosql-communication-semistructured/src/main/java/org/eclipse/jnosql/communication/semistructured/CursorExecutor.java +++ b/jnosql-communication/jnosql-communication-semistructured/src/main/java/org/eclipse/jnosql/communication/semistructured/CursorExecutor.java @@ -30,7 +30,7 @@ enum CursorExecutor { OFF_SET { @SuppressWarnings("unchecked") @Override - public CursoredPage cursor(SelectQuery query, PageRequest pageRequest, DatabaseManager template) { + public CursoredPage cursor(SelectQuery query, PageRequest pageRequest, DatabaseManager template) { var select = new DefaultSelectQuery(pageRequest.size(), 0, query.name(), query.columns(), query.sorts(), query.condition().orElse(null)); @@ -38,14 +38,13 @@ public CursoredPage cursor(SelectQuery query, PageRequest(entities, Collections.emptyList(), -1, (PageRequest) pageRequest, + return new CursoredPageRecord<>(entities, Collections.emptyList(), -1, pageRequest, null, null); } else { PageRequest.Cursor cursor = getCursor(query.sorts(), last); - PageRequest afterCursor = PageRequest.ofSize(pageRequest.size()).afterCursor(cursor); + PageRequest afterCursor = PageRequest.ofSize(pageRequest.size()).afterCursor(cursor); - return new CursoredPageRecord<>(entities, List.of(cursor), -1, (PageRequest) - pageRequest, afterCursor, null); + return new CursoredPageRecord<>(entities, List.of(cursor), -1, pageRequest, afterCursor, null); } } @@ -53,7 +52,7 @@ public CursoredPage cursor(SelectQuery query, PageRequest cursor(SelectQuery query, PageRequest pageRequest, DatabaseManager template) { + public CursoredPage cursor(SelectQuery query, PageRequest pageRequest, DatabaseManager template) { var cursor = pageRequest.cursor().orElseThrow(); var condition = condition(query, cursor); @@ -63,12 +62,12 @@ public CursoredPage cursor(SelectQuery query, PageRequest(entities, Collections.emptyList(), -1, (PageRequest) pageRequest, + return new CursoredPageRecord<>(entities, Collections.emptyList(), -1, pageRequest, null, null); } else { var nextCursor = getCursor(query.sorts(), last); var afterCursor = PageRequest.ofSize(pageRequest.size()).afterCursor(nextCursor); - return new CursoredPageRecord<>(entities, List.of(cursor, nextCursor), -1, (PageRequest) + return new CursoredPageRecord<>(entities, List.of(cursor, nextCursor), -1, pageRequest, afterCursor, null); } } @@ -97,7 +96,7 @@ private static CriteriaCondition condition(SelectQuery query, PageRequest.Cursor }, CURSOR_PREVIOUS { @SuppressWarnings("unchecked") @Override - public CursoredPage cursor(SelectQuery query, PageRequest pageRequest, DatabaseManager template) { + public CursoredPage cursor(SelectQuery query, PageRequest pageRequest, DatabaseManager template) { var cursor = pageRequest.cursor().orElseThrow(); var condition = condition(query, cursor); @@ -106,14 +105,13 @@ public CursoredPage cursor(SelectQuery query, PageRequest(entities, Collections.emptyList(), -1, (PageRequest) pageRequest, + return new CursoredPageRecord<>(entities, Collections.emptyList(), -1, pageRequest, null, null); } else { var beforeCursor = getCursor(query.sorts(), last); var beforeRequest = PageRequest.ofSize(pageRequest.size()).beforeCursor(beforeCursor); - return new CursoredPageRecord<>(entities, List.of(beforeCursor, cursor), -1, (PageRequest) - pageRequest, null, beforeRequest); + return new CursoredPageRecord<>(entities, List.of(beforeCursor, cursor), -1, pageRequest, null, beforeRequest); } } @@ -138,7 +136,7 @@ private static CriteriaCondition condition(SelectQuery query, PageRequest.Cursor } }; - abstract CursoredPage cursor(SelectQuery query, PageRequest pageRequest, DatabaseManager template); + abstract CursoredPage cursor(SelectQuery query, PageRequest pageRequest, DatabaseManager template); public static CursorExecutor of(PageRequest.Mode value) {