JPA 链表查询，子查询操作

@Autowired
private JPAQueryFactory queryFactory;

//联表查询操作
1>
QMmFileDefEntity qDefEntity = QMmFileDefEntity.mmFileDefEntity;
QMmFileDtlEntity qDtlEntity = QMmFileDtlEntity.mmFileDtlEntity;
QMmLinkEntity qLinkEntity = QMmLinkEntity.mmLinkEntity;
JPAQuery<Tuple> tupleJPAQuery = queryFactory.select(qDefEntity,qDtlEntity).from(qDtlEntity).innerJoin(qDefEntity).on(qDefEntity.defId.eq(qDtlEntity.defId)).leftJoin(qLinkEntity).on(qLinkEntity.sourceId.eq(qDtlEntity.mediaId).and(qLinkEntity.sourceTable.eq(DefaultsValue.MM_FILE_DTL)).and(qLinkEntity.sourceType.in(setEpisodeSourceType())).and(qLinkEntity.showType.in(MediaConstant.ShowType.HORIZONTAL_COVER.getCode(),MediaConstant.ShowType.VERTICAL_COVER.getCode())).and(qLinkEntity.dflag.eq(DefaultsValue.BYTE_TWO))).where(qDtlEntity.dflag.eq(DefaultsValue.BYTE_TWO).and(qDefEntity.mediaType.eq(MediaConstant.MediaType.VIDEO.getCode())));

List<Tuple> tuples = queryFactory.select(qDtlEntity,qLinkEntity).from(qDtlEntity).innerJoin(qLinkEntity).on(qLinkEntity.sourceId.in(bo.getMediaIds()).and(qLinkEntity.sourceTable.eq(DefaultsValue.MM_FILE_DTL).and(qLinkEntity.mediaType.eq(MediaConstant.MediaType.VIDEO.getCode())).and(qLinkEntity.sourceType.in(getVideoSourceType())))).where(qDtlEntity.mediaId.in(bo.getMediaIds()).and(qDtlEntity.dflag.eq(DefaultsValue.BYTE_TWO))).fetch();

List<Tuple> dtlTuples = queryFactory.select(qDtlEntity.defId,qDtlEntity.mediaId.max(),qDtlEntity.gmtModified,qDtlEntity.sort,qDtlEntity.count(),qDtlEntity.dtlName,qDtlEntity.collectTotal,qDtlEntity.likeTotal,qDtlEntity.playTotal,qDtlEntity.shareTotal,qDtlEntity.vedioId).from(qDtlEntity).where(qDtlEntity.defId.in(bo.getDefIds()).and(qDtlEntity.dflag.eq(DefaultsValue.BYTE_TWO))).groupBy(qDtlEntity.defId).fetch();

Set<Long> defIds = new HashSet<>();
tuples.forEach(row -> {MmFileDtlEntity dtlEntity = row.get(qDtlEntity);VideoPlayListVo vo = new VideoPlayListVo();dtlConversionCollectionPlayVo(vo,dtlEntity);vo.setCurrentMediaId(dtlEntity.getMediaId());vo.setMediaId(null);MmLinkEntity linkEntity = row.get(qLinkEntity);vo.setDuration(linkEntity.getDuration());listVos.add(vo);defIds.add(dtlEntity.getDefId());
});

//子查询操作

JPAQuery<MmFileDefEntity> query = queryFactory.selectFrom(qDefEntity).where(qDefEntity.mediaType.eq(MediaConstant.MediaType.VIDEO.getCode()).and(qDefEntity.cateType.eq(MediaConstant.CateType.WEMEDIA.getCode()).or(qDefEntity.cateType.eq(MediaConstant.CateType.VIDEO.getCode()).and(qDefEntity.cateCode.eq(SysCategroupEnums.CEnName.TVPLAY.getCEnName())))).and(qDefEntity.dflag.eq(DefaultsValue.BYTE_TWO)).and(JPAExpressions.select(qDtlEntity.count()).from(qDtlEntity).where(qDtlEntity.defId.eq(qDefEntity.defId).and(qDtlEntity.dflag.eq(DefaultsValue.BYTE_TWO))).groupBy(qDtlEntity.defId).goe(DefaultsValue.LONG_ONE)));

JPAQueryFactory 多条件动态查询

public RestVo<PageVo<VideoListVo>> videoReviewList(PageBo<VideoListBo> bo){//TODO 入参组装查询JPAQuery<Tuple> jDtlEntityQuery = queryVideoList(bo);long total = jDtlEntityQuery.fetchCount();List<Tuple> results = jDtlEntityQuery.offset((bo.getPage() - 1) * bo.getSize()).limit(bo.getSize()).fetch();
}

private JPAQuery<Tuple> queryVideoList(PageBo<VideoListBo> bo){QMmFileDefEntity qDefEntity = QMmFileDefEntity.mmFileDefEntity;QMmFileDtlEntity qDtlEntity = QMmFileDtlEntity.mmFileDtlEntity;QMmLinkEntity qLinkEntity = QMmLinkEntity.mmLinkEntity;JPAQuery<Tuple> tupleJPAQuery = queryFactory.select(qDefEntity,qDtlEntity).from(qDtlEntity).innerJoin(qDefEntity).on(qDefEntity.defId.eq(qDtlEntity.defId)).leftJoin(qLinkEntity).on(qLinkEntity.sourceId.eq(qDtlEntity.mediaId).and(qLinkEntity.sourceTable.eq(DefaultsValue.MM_FILE_DTL)).and(qLinkEntity.sourceType.in(setEpisodeSourceType())).and(qLinkEntity.showType.in(MediaConstant.ShowType.HORIZONTAL_COVER.getCode(),MediaConstant.ShowType.VERTICAL_COVER.getCode())).and(qLinkEntity.dflag.eq(DefaultsValue.BYTE_TWO)));//类似1=1Predicate predicate = qDefEntity.isNotNull().or(qDefEntity.isNull());if(null != bo.getParam()){String regx = "^[1-9]\\d*$";Pattern pattern = Pattern.compile(regx);if(StringUtils.isNotBlank(bo.getParam().getUserParam())){if(pattern.matcher(bo.getParam().getUserParam()).matches()){predicate = ExpressionUtils.and(predicate,qDefEntity.userId.eq(Long.valueOf(bo.getParam().getUserParam())).or(qDefEntity.nickName.likeIgnoreCase(bo.getParam().getUserParam())));}else {predicate = ExpressionUtils.and(predicate,qDefEntity.nickName.likeIgnoreCase(bo.getParam().getUserParam()));}}if(null != bo.getParam().getCheckStatus()){if(MediaConstant.PersonCheck.CHECKING.getCode() == bo.getParam().getCheckStatus()){predicate = ExpressionUtils.and(predicate,qDtlEntity.machineCheck.eq(bo.getParam().getCheckStatus()));}else if(MediaConstant.PersonCheck.NORMAL.getCode() == bo.getParam().getCheckStatus()){predicate = ExpressionUtils.and(predicate,qDtlEntity.fileStatus.eq(MediaConstant.FileStatus.NORMAL_FILE_STATUS.getCode()));}else if(MediaConstant.PersonCheck.NOT_PASS.getCode() == bo.getParam().getCheckStatus()){predicate = ExpressionUtils.and(predicate,qDtlEntity.fileStatus.ne(MediaConstant.FileStatus.NORMAL_FILE_STATUS.getCode()));}}if(StringUtils.isNotBlank(bo.getParam().getStar())){predicate = ExpressionUtils.and(predicate,qDefEntity.star.eq(bo.getParam().getStar()));}}predicate = ExpressionUtils.and(predicate,qDtlEntity.dflag.eq(DefaultsValue.BYTE_TWO).and(qDefEntity.mediaType.eq(MediaConstant.MediaType.VIDEO.getCode())));return tupleJPAQuery.where(predicate);
}

参考：https://blog.csdn.net/phapha1996/article/details/83614975

JPA 链表查询，子查询操作相关推荐

sql 基础语法创建数据库和数据表数据增删改查分组查询子查询回顾
参考链接: SQL教程 MySQL教程一.创建数据库语法 --用master数据库 use master --判断数据库是否存在,若存在则删除 if exists (select * from sy ...
数据库 day60,61 Oracle入门,单行函数,多表查询,子查询,事物处理,约束,rownum分页,视图,序列,索引
1. oracle介绍 ORACLE数据库系统是美国ORACLE公司(甲骨文)提供的以分布式数据库为核心的一组软件产品,是目前最流行的客户/服务器(CLIENT/SERVER)或B/S体系结构的 ...
MySQL数据库多表查询,子查询
写博客的第四天,今天来点数据库的操作,温故而知新,在前进的路上,多看看自己曾经走过的路,不要忘了自己是怎么一步一步走过来的,对于前方未知的道路,不要轻言放弃. 今天的内容全部是MySQL里面的语句,基 ...
聚合查询+联合查询+子查询
文章目录一.聚合查询 1.聚合函数 2.GROUP BY子句 3.HAVING 二.联合查询 join on 1.内连接 2.外连接 3.自连接三.子查询 EXISTS关键字四.联合查询总结 ...
MySQL核心查询-排序分组聚合多表查询合并查询子查询
目录一.单表查询排序聚合函数分组 limit关键字二.SQL约束主键的自增 DELETE和TRUNCATE对自增长的影响三.多表查询外键约束删除外键约束多表查询的分类内连接查询 ...
oracle子查询子查询,Oracle 单行子查询和多行子查询
--什么是单行子查询? --从子查询中返回一行结果的查询 select e.employee_id,e.last_name,e.salary from employees e where e.depa ...
分组分页连接查询子查询9202-0422
分组查询查询当前宠物有哪些组分组成功后,就不要再使用数据行的字段来查询了获得分组后的数据求和 limit分页显示内连接查询宠物表与主人表是有关联的有的宠物是有主人的获得宠物与主人的关系 ...
mysql求和子查询_MYSQL 查询方法统计查询链接查询子查询
mysql表格查询方法: 查询: 1.简单查询 select * from Info --查所有数据 select Code,Name from Info --查指定列的数据 select Code ...
SQL查询,子查询作为结果字段
SQL查询,子查询作为结果字段, SELECT DISTINCTsp.comcode,sp.projectname,sp.projecttime,sp.busnature,sp.bustype,sl. ...
数据库学习之MySQL (十七）—— SQL99 主查询与子查询子查询分类之WHERE的子查询
文章目录主查询子查询纲举目张--子查询的分类 WHERE语句后的子查询主查询子查询概念集中于SELECT语句之前我们所学习的所有,都是SELECT作为独立的一句是主干,是爸爸后面跟 ...

JPA 链表查询，子查询操作

JPA 链表查询，子查询操作相关推荐

最新文章

热门文章