added skip also

This commit is contained in:
Thomas Risberg
2011-02-03 16:09:44 -05:00
parent 9e5eb96150
commit d4ebb9a01c
3 changed files with 48 additions and 1 deletions

View File

@@ -24,6 +24,10 @@ public class BasicQuery implements QueryDefinition {
private DBObject fieldsObject = null;
private DBObject sortObject = null;
private int skip;
private int limit;
public BasicQuery(String query) {
@@ -54,6 +58,22 @@ public class BasicQuery implements QueryDefinition {
return fieldsObject;
}
public DBObject getSortObject() {
return sortObject;
}
public void setSortObject(DBObject sortObject) {
this.sortObject = sortObject;
}
public int getSkip() {
return skip;
}
public void setSkip(int skip) {
this.skip = skip;
}
public int getLimit() {
return this.limit;
}

View File

@@ -26,6 +26,10 @@ public class Query implements QueryDefinition {
private Field fieldSpec;
private Sort sort;
private int skip;
private int limit;
public static Criteria newQuery(String key) {
@@ -57,6 +61,15 @@ public class Query implements QueryDefinition {
return this;
}
public Sort sort() {
synchronized (this) {
if (this.sort == null) {
this.sort = new Sort();
}
}
return this.sort;
}
public QueryDefinition build() {
return this;
}
@@ -78,8 +91,18 @@ public class Query implements QueryDefinition {
return fieldSpec.getFieldsObject();
}
public DBObject getSortObject() {
if (this.sort == null) {
return null;
}
return this.sort.getSortObject();
}
public int getSkip() {
return this.skip;
}
public int getLimit() {
return this.limit;
}
}

View File

@@ -24,5 +24,9 @@ public interface QueryDefinition {
DBObject getFieldsObject();
DBObject getSortObject();
int getSkip();
int getLimit();
}