使用 Querydsl 和 Spring Boot JPA 查询最新版本的记录-java教程-PHP中文网

使用 Querydsl 和 Spring Boot JPA 查询最新版本的记录

DDD

发布： 2025-10-28 14:15:01

原创

693人浏览过

使用 querydsl 和 spring boot jpa 查询最新版本的记录

本文旨在解决在使用 Querydsl 和 Spring Boot JPA 时，如何通过分组查询获取具有最新版本的记录。我们将探讨如何构建一个查询，该查询能够从数据库中检索每个类型和编号组合的最新记录，避免重复数据并仅返回最新版本。本文将提供代码示例，并解释如何使用 `group by` 以及子查询来实现这一目标。

在使用 Spring Boot JPA 和 Querydsl 进行数据查询时，经常会遇到需要获取特定类型数据的最新版本记录的需求。例如，数据库中存在多个版本的数据，需要根据类型和编号进行分组，并检索每个组中版本号最高的记录。以下将介绍如何使用 Querydsl 实现这一目标。

构建 Querydsl 查询

首先，我们需要定义 Querydsl 的实体类和对应的 Q 类。假设我们有一个名为 Record 的实体类，包含 id、type、number 和 version 等字段。

@Entity
@Table(name = "record")
public class Record {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private Integer type;

    private Integer number;

    private Integer version;

    // Getters and setters
    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public Integer getType() {
        return type;
    }

    public void setType(Integer type) {
        this.type = type;
    }

    public Integer getNumber() {
        return number;
    }

    public void setNumber(Integer number) {
        this.number = number;
    }

    public Integer getVersion() {
        return version;
    }

    public void setVersion(Integer version) {
        this.version = version;
    }
}

登录后复制

然后，我们需要使用 Querydsl 的 QRecord 类来构建查询。

使用子查询获取最新版本

蓝心千询

蓝心千询是vivo推出的一个多功能AI智能助手

查看详情

核心思路是使用子查询来找到每个 type 和 number 组合的最大 version，然后使用主查询来检索具有这些最大版本的记录。

import com.querydsl.jpa.impl.JPAQueryFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.persistence.EntityManager;
import java.util.List;
import static com.example.demo.entity.QRecord.record; // 确保路径正确

@Service
public class RecordService {

    @Autowired
    private EntityManager entityManager;

    public List<Record> findNewestRecordsByType(Integer type) {
        JPAQueryFactory queryFactory = new JPAQueryFactory(entityManager);

        return queryFactory
                .selectFrom(record)
                .where(record.type.eq(type).and(record.version.eq(
                        new JPAQueryFactory(entityManager)
                                .select(record.version.max())
                                .from(record)
                                .where(record.type.eq(type),record.number.eq(record.number))
                )).groupBy(record.number))
                .fetch();
    }
}

登录后复制

代码解释：

JPAQueryFactory queryFactory = new JPAQueryFactory(entityManager);：创建一个 JPAQueryFactory 实例，用于构建 Querydsl 查询。
selectFrom(record)：指定要查询的实体是 Record。
where(record.type.eq(type).and(record.version.eq(...)))：使用 where 子句来过滤记录。
- record.type.eq(type)：筛选指定类型的记录。
- record.version.eq(...)：使用子查询来获取每个 type 和 number 组合的最大 version。
new JPAQueryFactory(entityManager).select(record.version.max()).from(record).where(record.type.eq(type),record.number.eq(record.number))：子查询，用于获取每个 type 和 number 组合的最大 version。
groupBy(record.number)：对结果按照number进行分组
.fetch()：执行查询并返回结果列表。

注意事项