enabled retrieve all items from paginated end points

This commit is contained in:
apremalal
2013-05-09 14:19:20 +05:30
parent 0d18ddc034
commit f11fe9cdef
5 changed files with 23 additions and 23 deletions
@@ -169,11 +169,13 @@ public class JournalEntryReadPlatformServiceImpl implements JournalEntryReadPlat
maxLimitAllowed = limit; maxLimitAllowed = limit;
} }
sqlBuilder.append(" limit ").append(maxLimitAllowed); sqlBuilder.append(" limit ").append(maxLimitAllowed);
} if (offset != null) {
sqlBuilder.append(" offset ").append(offset);
if (offset != null) { }
sqlBuilder.append(" offset ").append(offset); } else if (limit != null && limit == -1) {
} ;
} else
sqlBuilder.append(" limit ").append(200);
final Object[] finalObjectArray = Arrays.copyOf(objectArray, arrayPos); final Object[] finalObjectArray = Arrays.copyOf(objectArray, arrayPos);
final String sqlCountRows = "SELECT FOUND_ROWS()"; final String sqlCountRows = "SELECT FOUND_ROWS()";
@@ -103,10 +103,9 @@ public class ClientReadPlatformServiceImpl implements ClientReadPlatformService
if (searchParameters.isLimited()) { if (searchParameters.isLimited()) {
sqlBuilder.append(" limit ").append(searchParameters.getLimit()); sqlBuilder.append(" limit ").append(searchParameters.getLimit());
} if (searchParameters.isOffset()) {
sqlBuilder.append(" offset ").append(searchParameters.getOffset());
if (searchParameters.isOffset()) { }
sqlBuilder.append(" offset ").append(searchParameters.getOffset());
} }
final String sqlCountRows = "SELECT FOUND_ROWS()"; final String sqlCountRows = "SELECT FOUND_ROWS()";
@@ -208,10 +208,9 @@ public class CenterReadPlatformServiceImpl implements CenterReadPlatformService
if (searchParameters.isLimited()) { if (searchParameters.isLimited()) {
sqlBuilder.append(" limit ").append(searchParameters.getLimit()); sqlBuilder.append(" limit ").append(searchParameters.getLimit());
} if (searchParameters.isOffset()) {
sqlBuilder.append(" offset ").append(searchParameters.getOffset());
if (searchParameters.isOffset()) { }
sqlBuilder.append(" offset ").append(searchParameters.getOffset());
} }
final String sqlCountRows = "SELECT FOUND_ROWS()"; final String sqlCountRows = "SELECT FOUND_ROWS()";
@@ -126,10 +126,9 @@ public class GroupReadPlatformServiceImpl implements GroupReadPlatformService {
if (searchParameters.isLimited()) { if (searchParameters.isLimited()) {
sqlBuilder.append(" limit ").append(searchParameters.getLimit()); sqlBuilder.append(" limit ").append(searchParameters.getLimit());
} if (searchParameters.isOffset()) {
sqlBuilder.append(" offset ").append(searchParameters.getOffset());
if (searchParameters.isOffset()) { }
sqlBuilder.append(" offset ").append(searchParameters.getOffset());
} }
final String sqlCountRows = "SELECT FOUND_ROWS()"; final String sqlCountRows = "SELECT FOUND_ROWS()";
@@ -70,12 +70,13 @@ public final class SearchParameters {
return StringUtils.isNotBlank(this.sortOrder); return StringUtils.isNotBlank(this.sortOrder);
} }
public static Integer getCheckedLimit(Integer maxLimitAllowed, Integer limit) public static Integer getCheckedLimit(Integer maxLimitAllowed, Integer limit) {
{
if (limit != null && limit < maxLimitAllowed && limit > 0) { if (limit != null && limit < maxLimitAllowed && limit > 0) {
maxLimitAllowed = limit; return limit;
} } else if (limit != null && limit == -1) {
return maxLimitAllowed; return null;
} else
return maxLimitAllowed;
} }
public String getSqlSearch() { public String getSqlSearch() {