自定义数据类型聚合函数：Criteria API如何处理Duration类型avg运算？

好问题！完全理解你不想把实体字段改成Long的想法——毕竟Duration在业务代码里更具语义性，能清晰表达时间长度的含义。下面是几种不用修改字段类型就能实现需求的方案：

1. 类型转换绕过JPA类型检查（最简单直接） #

你的DurationConverter已经把Duration映射为数据库中的Long类型，所以数据库层面这个字段本身就是数值类型。我们可以通过CriteriaBuilder的as()方法，把Duration表达式强制转换为Long类型，这样就能正常使用avg()等聚合函数了：

CriteriaBuilder cb = entityManager.getCriteriaBuilder();
CriteriaQuery<Duration> query = cb.createQuery(Duration.class);
Root<MyClassName> root = query.from(MyClassName.class);

// 将Duration表达式转为Long类型，再执行avg聚合
Expression<Number> avgNumber = cb.avg(root.get(MyClassName_.duration).as(Long.class));
// 把聚合结果转为Long，再在查询中直接转成Duration
Expression<Duration> avgDuration = cb.selectCase()
    .when(avgNumber.isNull(), null)
    .otherwise(cb.function("java.time.Duration.ofMillis", Duration.class, avgNumber.as(Long.class)));

query.select(avgDuration);

或者如果不需要在查询语句里直接转成Duration，也可以先查询聚合后的数值结果，再在业务代码里转换：

CriteriaQuery<Long> query = cb.createQuery(Long.class);
Root<MyClassName> root = query.from(MyClassName.class);

query.select(cb.avg(root.get(MyClassName_.duration).as(Long.class)).as(Long.class));

Long avgMillis = entityManager.createQuery(query).getSingleResult();
Duration avgDuration = avgMillis != null ? Duration.ofMillis(avgMillis) : null;

2. 封装自定义工具方法（提升代码复用性） #

如果你的项目中经常需要对Duration字段做聚合操作，可以封装一个工具方法，把类型转换和聚合逻辑封装起来，让业务代码更简洁：

public class CriteriaDurationUtils {
    public static Expression<Duration> avgDuration(CriteriaBuilder cb, Expression<Duration> durationExpr) {
        Expression<Number> avgNumber = cb.avg(durationExpr.as(Long.class));
        return cb.selectCase()
            .when(avgNumber.isNull(), null)
            .otherwise(cb.function("java.time.Duration.ofMillis", Duration.class, avgNumber.as(Long.class)));
    }
}

调用时就可以直接用：

query.select(CriteriaDurationUtils.avgDuration(cb, root.get(MyClassName_.duration)));

3. 利用JPA函数调用适配数据库特性（可选） #

如果你的数据库支持直接对数值类型转换为时间间隔（比如PostgreSQL的make_interval函数），也可以直接调用数据库函数来完成聚合后的类型转换：

// PostgreSQL示例：把avg得到的毫秒数转成interval，再映射为Duration
Expression<Number> avgMillis = cb.avg(root.get(MyClassName_.duration).as(Long.class));
Expression<Duration> avgDuration = cb.function("make_interval", Duration.class, 
    cb.literal(0), cb.literal(0), cb.literal(0), cb.literal(0), 
    cb.literal(0), cb.literal(0), avgMillis.as(Double.class)/1000);

注意事项 #

• 不同数据库的avg函数返回类型可能不同（比如MySQL返回Double，PostgreSQL返回numeric），所以需要根据数据库类型调整as()的目标类型。
• 确保你的DurationConverter是双向正确的：能把Duration转成Long存库，也能把数据库的Long转回Duration。

内容的提问来源于stack exchange，提问作者Felix S