ref[orm]: 重命名了IQueryBuilder方法

This commit is contained in:
jaysunxiao
2022-06-28 18:05:35 +08:00
parent 2210763f09
commit 50dd55df2b
3 changed files with 15 additions and 15 deletions
@@ -241,7 +241,7 @@ public class EntityCaches<PK extends Comparable<PK>, E extends IEntity<PK>> impl
var ids = updateList.stream().map(it -> it.id()).collect(Collectors.toList());
try {
List<IEntity> dbList = OrmContext.getQuery(entityDef.getClazz()).in("_id", ids).queryAll();
var dbList = OrmContext.getQuery((Class<E>)entityDef.getClazz()).in("_id", ids).queryAll();
var dbMap = dbList.stream().collect(Collectors.toMap(key -> key.id(), value -> value));
for (var entity : updateList) {
var dbEntity = dbMap.get(entity.id());
@@ -54,8 +54,6 @@ public interface IQueryBuilder<E extends IEntity> {
List<E> queryAll();
E find();
/**
* 分页查询,默认按照id排序
@@ -63,5 +61,7 @@ public interface IQueryBuilder<E extends IEntity> {
* @param page 第几页
* @param itemsPerPage 每页容量
*/
Pair<Page, List<E>> page(int page, int itemsPerPage);
Pair<Page, List<E>> queryPage(int page, int itemsPerPage);
E queryFirst();
}
@@ -120,17 +120,7 @@ public class MongoQueryBuilder<E extends IEntity<?>> implements IQueryBuilder<E>
}
@Override
public E find() {
var collection = OrmContext.getOrmManager().getCollection(entity);
var list = builder != null ? collection.find(builder) : collection.find();
for (E row : list) {
return row;
}
return null;
}
@Override
public Pair<Page, List<E>> page(int page, int itemsPerPage) {
public Pair<Page, List<E>> queryPage(int page, int itemsPerPage) {
var collection = OrmContext.getOrmManager().getCollection(entity);
var p = Page.valueOf(page, itemsPerPage, collection.countDocuments());
@@ -148,4 +138,14 @@ public class MongoQueryBuilder<E extends IEntity<?>> implements IQueryBuilder<E>
return new Pair<>(p, list);
}
@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;
}
}