1、普通查询条件
Criteria criteria = new Criteria();
if (status == 2){ // 全部
criteria = Criteria.where("status").ne(StatusEnum.DELETED);
}else if (status == SolitaireConstant.LAUNCH){ // 我发起的
criteria = Criteria.where("userId").is(userId).and("status").ne(StatusEnum.DELETED);
}
Query queryPage = new Query(criteria);
queryPage.with(Sort.by(Sort.Order.desc("createTime"))).skip((long) page.getCurrent() * page.getSize()).limit(page.getSize()); //分页
List<StartSolitaireVO> list = mongoTemplate.find(queryPage, StartSolitaireVO.class,SolitaireConstant.START_SOLITAIRE_COLLECTION);
2、聚合查询（分组、排序、分页、连表）
// 连表
LookupOperation lookup = LookupOperation.newLookup()
// 关联的从表名字
.from(SolitaireConstant.START_SOLITAIRE_COLLECTION)
// 主表中什么字段与从表相关联
.localField("startSolitaireId")
// 从表中的什么字段与主表相关联
.foreignField("_id")
// 自定义的从表结果集名 与主表关联的数据归于此结果集下
.as("startVO");
Criteria criteria = new Criteria();
// 主表可能选择的条件
criteria.and("userId").is(userId);
// 从表可能选择的条件
criteria.and("startVO.status").ne(StatusEnum.DELETED);
// 将筛选条件放入管道中
Aggregation aggregation = Aggregation.newAggregation(
lookup,
Aggregation.match(criteria),
Aggregation.group("startSolitaireId") // 分组的字段
.first("startSolitaireId").as("startSolitaireId") // 映射的字段 并取别名
.first("userId").as("userId")
.first("interact").as("interact")
.first("createTime").as("createTime")
.first("startVO").as("startVO"),
Aggregation.sort(Sort.Direction.DESC,"createTime"), // 排序
Aggregation.skip((long) page.getCurrent() * page.getSize()),
Aggregation.limit(page.getSize())); // 分页
AggregationResults<MySolitaireVO> aggregate = mongoTemplate.aggregate(aggregation, SolitaireConstant.MY_SOLITAIRE_COLLECTION, MySolitaireVO.class);
List<MySolitaireVO> mappedResults = aggregate.getMappedResults();
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/99530.html
