diff --git a/orm/src/main/java/com/zfoo/orm/model/query/MongoQueryBuilder.java b/orm/src/main/java/com/zfoo/orm/model/query/MongoQueryBuilder.java index 46c504ea..f69f26eb 100644 --- a/orm/src/main/java/com/zfoo/orm/model/query/MongoQueryBuilder.java +++ b/orm/src/main/java/com/zfoo/orm/model/query/MongoQueryBuilder.java @@ -27,18 +27,14 @@ import java.util.function.Consumer; public class MongoQueryBuilder> implements IQueryBuilder { private final Class entity; - private Bson builder; + private Bson builder = Filters.empty(); public MongoQueryBuilder(Class entityClazz) { entity = entityClazz; } private void wrapBuilder(Bson bson) { - if (builder != null) { - builder = Filters.and(builder, bson); - } else { - builder = bson; - } + builder = Filters.and(builder, bson); } @Override @@ -109,7 +105,7 @@ public class MongoQueryBuilder> implements IQueryBuilder public List queryAll() { var collection = OrmContext.getOrmManager().getCollection(entity); var list = new ArrayList(); - var result = builder != null ? collection.find(builder) : collection.find(); + var result = collection.find(builder); result.forEach(new Consumer>() { @Override public void accept(IEntity entity) { @@ -125,7 +121,7 @@ public class MongoQueryBuilder> implements IQueryBuilder var p = Page.valueOf(page, itemsPerPage, collection.countDocuments()); - var result = builder != null ? collection.find(builder) : collection.find(); + var result = collection.find(builder); var list = new ArrayList(); result.skip(p.skipNum()) .limit(p.getItemsPerPage()) @@ -142,10 +138,6 @@ public class MongoQueryBuilder> implements IQueryBuilder @Override public E queryFirst() { var collection = OrmContext.getOrmManager().getCollection(entity); - var list = builder != null ? collection.find(builder) : collection.find(); - for (E row : list) { - return row; - } - return null; + return collection.find(builder).first(); } }