committed by
Michael Minella
parent
54bce9a590
commit
d95f46002f
@@ -245,10 +245,10 @@ public class MapTaskExecutionDao implements TaskExecutionDao {
|
||||
}
|
||||
|
||||
private Page getPageFromList(List<TaskExecution> executionList, Pageable pageable, long maxSize){
|
||||
int toIndex = (pageable.getOffset() + pageable.getPageSize() > executionList.size()) ?
|
||||
long toIndex = (pageable.getOffset() + pageable.getPageSize() > executionList.size()) ?
|
||||
executionList.size() : pageable.getOffset() + pageable.getPageSize();
|
||||
return new PageImpl<>(
|
||||
executionList.subList(pageable.getOffset(), toIndex),
|
||||
executionList.subList((int)pageable.getOffset(), (int)toIndex),
|
||||
pageable, maxSize);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -28,7 +28,7 @@ public class Db2PagingQueryProvider extends AbstractSqlPagingQueryProvider {
|
||||
|
||||
@Override
|
||||
public String getPageQuery(Pageable pageable) {
|
||||
int offset = pageable.getOffset() + 1;
|
||||
long offset = pageable.getOffset() + 1;
|
||||
return generateRowNumSqlQueryWithNesting(getSelectClause(), false,
|
||||
"TMP_ROW_NUM BETWEEN " + offset + " AND " + (offset + pageable.getPageSize()));
|
||||
}
|
||||
|
||||
@@ -28,7 +28,7 @@ public class OraclePagingQueryProvider extends AbstractSqlPagingQueryProvider {
|
||||
|
||||
@Override
|
||||
public String getPageQuery(Pageable pageable) {
|
||||
int offset = pageable.getOffset()+1;
|
||||
long offset = pageable.getOffset()+1;
|
||||
return generateRowNumSqlQueryWithNesting(getSelectClause(), false, "TMP_ROW_NUM >= "
|
||||
+ offset + " AND TMP_ROW_NUM < " + (offset+pageable.getPageSize()));
|
||||
}
|
||||
|
||||
@@ -27,7 +27,7 @@ public class SqlServerPagingQueryProvider extends AbstractSqlPagingQueryProvider
|
||||
|
||||
@Override
|
||||
public String getPageQuery(Pageable pageable) {
|
||||
int offset = pageable.getOffset()+1;
|
||||
long offset = pageable.getOffset()+1;
|
||||
return generateRowNumSqlQueryWithNesting(getSelectClause(), false, "TMP_ROW_NUM >= "
|
||||
+ offset + " AND TMP_ROW_NUM < " + (offset+pageable.getPageSize()));
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user