关于使用jpa聚合函数遇到的问题

 更新时间:2022年02月23日 14:34:47   作者:你怎么不笑了  
这篇文章主要介绍了关于使用jpa聚合函数遇到的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

使用jpa聚合函数遇到的问题

spring data jpa 可以通过在接口中按照规定语法创建一个方法进行增删改查,可以快速开发。

但是一些特殊情况,如按条件查询统计,这个时候通过规定语法还是直接@Query写原生sql都不能解决,因为这个统计的条件不好添加。

百度之后,可以使用EntityManager来解决。

EntityManager 对象在一组实体类与底层数据源之间进行 O/R 映射的管理。它可以用来管理和更新 Entity Bean, 根椐主键查找 Entity Bean, 还可以通过JPQL语句增删改查实体。

首先通过@PersistenceContext注入EntityManager

@PersistenceContext
private EntityManager em;

使用如下

BigDecimal totals = new BigDecimal(0);
StringBuffer sql= new StringBuffer("SELECT SUM(total) FROM Order WHERE state = 1");
if (StringUtils.isNotBlank(order.getOrderNo())) {
    sql.append(" AND orderNo = ").append(order.getOrderNo());
}
if (StringUtils.isNotBlank(orderTime)) {
    sql.append(" AND orderPayTime LIKE '").append(orderTime).append("%'");
}
if (order.getCustomer() != null) {
    //where条件后面是对象信息,不能直接传入对象拼成sql,会报错.
    sql.append(" AND customer = :customer");
}
Query query = em.createQuery(sql.toString());
if (order.getCustomer() != null) {
    //通过setParameter,给参数赋值.
    query.setParameter("customer", order.getCustomer());
}
Object result = query.getSingleResult();
if (result != null) {
    totals = new BigDecimal(result.toString());
}
return totals;

jpa聚合函数(适用于联合查询)

最近帮老同事解决一个问题,场景是这样的,查询条件比较多,也就是我们说的联合查询,比如下面的,时间可以选不同的,状态和来源也可以选不同,而且可选可不选

如果这个时候写sql,是不是要各种条件判断,各种纠结,各种难写,各种sql,这个时候大家一般都想到了springdata的jpa貌似很好用,可以直接拼接sql,但是怎么拼接呢,又怎么支持非表字段的展示呢,比如表中一个字段 aaa 好展示,但是查总和sum(aaa) ,怎么把这个作为一个字段展示呢。

不罗嗦了,直接上代码

以下语句对应的sql大概是

select count(***) from *** where *** group by ***
private List<Tuple> getCountByStatusOrSource(Integer status, Integer source, Integer userId, String startTime, String endTime, Integer timeSlot, String type) throws Exception {
        CriteriaBuilder cb = entityManager.getCriteriaBuilder();
        Date sTime = new Date(), eTime = new Date();
        CriteriaQuery<Tuple> query = cb.createTupleQuery();
        Root<AAA> root = query.from(AAA.class);//AAA是对应数据库的类名,替换成自己的
        Path<Integer> statusPath = root.get("status");
        Path<String> statusNamePath = root.get("status").get("name");
        Path<Integer> sourcePath = root.get("source");
        Path<Date> operatorPath = root.get("operator");
 
        List<Predicate> predicateList = new ArrayList<>();
        if (source != null) {
            predicateList.add(
                cb.equal(sourcePath, source)
            );
        }
        if (userId != null) {
            predicateList.add(
                cb.equal(operatorPath, userId)
            );
        }
        Map timeMap = getChangedTime(startTime, endTime, timeSlot);//获取时间的方法,具体代码我就不沾了,自己写个就行了
        sTime = (Date) timeMap.get("sTime");
        eTime = (Date) timeMap.get("eTime");
       
            Expression<Date> startDateExpression = cb.literal(sTime);
            Expression<Date> endDateExpression = cb.literal(eTime);
            predicateList.add(
                cb.between(updateTimePath, startDateExpression, endDateExpression)
            );      
 
        Predicate[] predicates = new Predicate[predicateList.size()];
        predicates = predicateList.toArray(predicates);
        query.where(predicates);//where条件加上
        if ("status".equals(type)) {
            query.select(cb.tuple(statusPath, cb.count(root)));
            query.groupBy(statusPath);
        }
        
        //query.multiselect(statusPath, cb.count(root));//
        TypedQuery<Tuple> q = entityManager.createQuery(query);
        List<Tuple> result = q.getResultList();
        return result;
    }

这个sql,我们分别查到了两个值 status 和数量,那么怎么获取呢

循环一下那个获取的list

Tuple tuple = list.get(i);
(long)tuple.get(0)获取的是数量
(Integer)tuple.get(1)获取的是状态id

到这是否全部清晰了呢,这个例子也适用sum,max等其他聚合函数

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Java Elastic-Job分布式定时任务使用方法介绍

    Java Elastic-Job分布式定时任务使用方法介绍

    xxl-job 通过一个中心式的调度平台,调度多个执行器执行任务,调度中心通过 DB 锁保证集群分布式调度的一致性,这样扩展执行器会增大 DB 的压力,然而大部分公司的任务数,执行器并不多;xxl-job 提供了非常好用的监控页面甚至还有任务失败的邮件告警功能
    2023-01-01
  • 获取Java加载器和类完整结构的方法分享

    获取Java加载器和类完整结构的方法分享

    这篇文章主要为大家详细介绍了获取Java加载器和类完整结构的方法,文中的示例代码讲解详细,对我们学习Java有一定的帮助,需要的可以参考一下
    2022-12-12
  • 使用spring框架中的组件发送邮件功能说明

    使用spring框架中的组件发送邮件功能说明

    Spring使用的是基本的JavaBean来完成以前只可能由EJB完成的事情。这篇文章主要介绍了使用spring框架中的组件发送邮件,需要的朋友可以参考下
    2017-11-11
  • JavaWeb Servlet实现文件上传与下载功能实例

    JavaWeb Servlet实现文件上传与下载功能实例

    因自己负责的项目中需要实现文件上传,所以下面下面这篇文章主要给大家介绍了关于JavaWeb Servlet实现文件上传与下载功能的相关资料,需要的朋友可以参考下
    2022-04-04
  • java中的多态和继承示例分析

    java中的多态和继承示例分析

    这篇文章主要介绍了java中的多态和继承,结合实例形式分析了java中的多态和继承原理、实现方法及相关操作注意事项,需要的朋友可以参考下
    2020-05-05
  • java实现小球碰撞功能

    java实现小球碰撞功能

    这篇文章主要为大家详细介绍了java实现小球碰撞功能,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-01-01
  • 关于使用swagger整合springMVC的方法

    关于使用swagger整合springMVC的方法

    在平时开发写接口文档的工作时,一般都是word文档,带来书写麻烦、维护麻烦的问题,比如改了源代码忘了更新文档、解释不明确带来歧义、无法在线尝试等等,swagger可以有效解决这类问题,需要的朋友可以参考下
    2023-04-04
  • JAVA实现监测tomcat是否宕机及控制重启的方法

    JAVA实现监测tomcat是否宕机及控制重启的方法

    这篇文章主要介绍了JAVA实现监测tomcat是否宕机及控制重启的方法,可实现有效的检测及控制tomcat服务器运行,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-08-08
  • linux部署出现java文件操作报错:java.io.FileNotFoundException解决办法

    linux部署出现java文件操作报错:java.io.FileNotFoundException解决办法

    这篇文章主要g介绍了linux部署出现java文件操作报错:java.io.FileNotFoundException解决的相关资料,这个错误通常表示你的Spring Boot应用程序无法找到指定的文本文件,需要的朋友可以参考下
    2023-12-12
  • JDBC获取数据库连接的5种方式实例

    JDBC获取数据库连接的5种方式实例

    JDBC是一种用于执行SQL语句的JavaAPI,为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成,提供了诸如查询和更新数据库中数据的方法,这篇文章主要给大家介绍了关于JDBC获取数据库连接的5种方式,需要的朋友可以参考下
    2022-06-06

最新评论