Spring Data JPA查询SQL Server近2小时订单数分组报错求助

我需要通过Spring Data JPA从SQL Server的ORDER_REQUEST表中统计近2小时内到达的订单请求数量，并按订单来源ID（orderOriginId）分组。尝试实现时出现异常，求排查问题。

ORDER_REQUEST实体类 #

package com.accurate.metric.entity;

import java.sql.Date;

import jakarta.persistence.Column;
import jakarta.persistence.Entity;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Entity
@Table(catalog="ABCNEW_DEV", schema="dbo", name = "orderRequest")
public class OrderRequest {

    @Column(name="or_id")
    @Id
    private int id;

    @Column(name="or_oo_id")
    private int orderOriginId;

    @Column(name="or_orderdate")
    private Date orOrderDate;

    @Override
    public String toString() {
        return "OrderRequest [id=" + id + ", orderOriginId=" + orderOriginId + "]";
    }

}

OrderCount DTO类 #

package com.accurate.metric.entity;

public class OrderCount {

    private int orderOriginId;

    private int count;

    public OrderCount(int orderOriginId, int count) {
        this.orderOriginId = orderOriginId;
        this.count = count;
    }
}

Repository类及查询代码 #

package com.accurate.metric.dao;

import java.util.List;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.stereotype.Repository;

import com.accurate.metric.entity.OrderCount;
import com.accurate.metric.entity.OrderOrigin;

@Repository
public interface OrderVolumeMetricDao extends JpaRepository<OrderOrigin, Integer>{

    @Query("SELECT new com.accurate.metric.entity.OrderCount(o.orderOriginId, COUNT(o)) " 
            + "FROM OrderRequest o " 
            + "WHERE o.orOrderDate BETWEEN DATEADD('HOUR', -2, CURRENT_TIMESTAMP)      AND CURRENT_TIMESTAMP "
            + "GROUP BY o.orderOriginId "
            + "ORDER BY o.orderOriginId")
    public List<OrderCount> findCountByOoIdAndDateRange();
}

问题分析 #

1. Repository泛型不匹配：当前Repository继承JpaRepository<OrderOrigin, Integer>，但查询的是OrderRequest实体，泛型错误会导致JPA上下文逻辑混乱。
2. 日期类型无法支持小时级筛选：orOrderDate使用java.sql.Date类型，该类型仅存储年月日，不包含时分秒信息，根本无法实现“近2小时”的时间范围筛选。
3. JPQL函数用法错误：DATEADD('HOUR', -2, CURRENT_TIMESTAMP)是SQL Server原生语法，不是JPQL标准函数，直接在@Query中使用会触发语法解析异常。
4. 计数类型兼容问题：COUNT(o)返回的是Long类型，但OrderCount构造函数接收int类型，会引发类型转换异常。

修复方案 #

1. 修正Repository泛型

将Repository泛型改为对应OrderRequest实体：

@Repository
public interface OrderVolumeMetricDao extends JpaRepository<OrderRequest, Integer>{
    // 查询方法后续调整
}

2. 修改日期字段类型

将OrderRequest中的orOrderDate改为带时间的类型，推荐使用JPA 2.2+支持的java.time.LocalDateTime：

// 替换原java.sql.Date类型
@Column(name="or_orderdate")
private LocalDateTime orOrderDate;

如果必须使用JDBC原生类型，也可以改为java.sql.Timestamp。

3. 改用SQL Server原生查询

在@Query中添加nativeQuery=true，使用SQL Server原生语法编写查询：

@Query(value = "SELECT or_oo_id AS orderOriginId, COUNT(*) AS count "
        + "FROM ABCNEW_DEV.dbo.orderRequest "
        + "WHERE or_orderdate BETWEEN DATEADD(HOUR, -2, GETDATE()) AND GETDATE() "
        + "GROUP BY or_oo_id "
        + "ORDER BY or_oo_id", 
        nativeQuery = true)
public List<OrderCount> findCountByOoIdAndDateRange();

注：原生查询的字段别名需与OrderCount的字段名匹配，确保结果能正确映射。

4. 调整DTO计数类型

将OrderCount中的count字段改为Long类型，避免类型转换异常：

public class OrderCount {

    private int orderOriginId;

    private Long count;

    public OrderCount(int orderOriginId, Long count) {
        this.orderOriginId = orderOriginId;
        this.count = count;
    }
}

内容的提问来源于stack exchange，提问作者Srinivasa Subramanyam