Skip to content

Commit f811d66

Browse files
committed
updates Mongo API
1 parent 4e4417a commit f811d66

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

mongodb-driver/src/main/java/org/jnosql/diana/mongodb/document/MongoDBDocumentCollectionManager.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,8 +115,8 @@ public List<DocumentEntity> select(DocumentQuery query) {
115115

116116
FindIterable<Document> documents = collection.find(mongoDBQuery);
117117

118-
if (query.getStart() > 0) {
119-
documents.skip((int) query.getStart());
118+
if (query.getSkip() > 0) {
119+
documents.skip((int) query.getSkip());
120120
}
121121

122122
if (query.getLimit() > 0) {

mongodb-driver/src/main/java/org/jnosql/diana/mongodb/document/MongoDBDocumentCollectionManagerAsync.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -131,12 +131,12 @@ public void select(DocumentQuery query, Consumer<List<DocumentEntity>> callBack)
131131
List<DocumentEntity> entities = new CopyOnWriteArrayList<>();
132132
FindIterable<Document> result = collection.find(mongoDBQuery);
133133

134-
if (query.getFirstResult() > 0) {
135-
result.skip((int) query.getFirstResult());
134+
if (query.getSkip() > 0) {
135+
result.skip((int) query.getSkip());
136136
}
137137

138-
if (query.getMaxResults() > 0) {
139-
result.limit((int) query.getMaxResults());
138+
if (query.getLimit() > 0) {
139+
result.limit((int) query.getLimit());
140140
}
141141

142142
query.getSorts().stream().map(this::getSort).forEach(result::sort);

0 commit comments

Comments
 (0)