# 光速上手 - JPA 原生 sql DTO 投影

                                                                     前言

        使用 JPA 时，我们一般通过 @Entity 进行实体类映射，从数据库中查询出对象。然而，在实际开发中，有时须要自定义查询结果并将其直接映射到 DTO，而不是实体类。这种需求可以通过 JPA 原生 SQL 查询和 DTO 投影 来实现。博主将以实际开发场景 为例，快速摘要如安在 JPA 中实现基于原生 SQL 的 DTO 投影

---

                                                                    开始 - 实现步骤

                                   以下是实现 DTO 投影的完整步骤，包括实体类、SQL 映射配置、接口调用和 DTO 设计。




一、配置实体类及映射

       首先在实体类中定义 @SqlResultSetMapping，用于将原生 SQL 查询结果映射到 DTO 类。在这个例子中，我们定义了 IssueVideo 实体，并通过 @SqlResultSetMapping 和 @NamedNativeQuery 配置了一个纯sql查询

---

两个注解 详解 (已理解可以跳过)

• 1. @NamedNativeQuery
  ​ 焦点作用
  
  
  
  • @NamedNativeQuery 是用来定义 原生 SQL 查询 的。
    
  • 尽管JPA 中已经为sql 提供了许多方便的办理方式，但是某些场景下，我们照旧须要直接使用原生 SQL , 例如：
    
    
    
    • 数据查询逻辑复杂，无法用 JPQL 表达
      
    • 涉及数据库特定的功能（如窗口函数、分区排序等）
      
    • 查询结果无法直接映射到实体类（如 DTO、聚合结果）
      
    
    
  
  

       通过 @NamedNativeQuery，我们可以直接在实体类中绑定一个原生 SQL 查询，并为这个查询定名。在调用时，可以通过指定这个定名的查询名称直接执行该 SQL

---

• 2. @SqlResultSetMapping
  焦点作用
  
  
  
  • @SqlResultSetMapping 是用来定义 查询结果的映射 规则的。
    
  • 当我们使用原生 SQL 查询时，返回的结果是数据库的行列数据，与实体类的属性或 DTO 的结构未必完全匹配。
    
    1. @SqlResultSetMapping(name = "", ...) -> 它长这样

    复制代码
    它用来告诉 JPA：
    
    
    
    • 查询返回的列和 DTO 的字段如何一一对应
      
    • 如何将原生 SQL 查询的结果映射为自定义的类（DTO）
      
    ​         没有 @SqlResultSetMapping 时，JPA 会尝试将查询结果映射到实体类，但如果结果不是直接对应实体类那么映射就会失败。这时，我们就须要 @SqlResultSetMapping 来自定义映射规则。
    
    
  
  

---

• 3. 为什么须要将它们写在实体类上？
  
  
  
  • 实体类是 SQL 映射的入口
           在 JPA 中，实体类是我们与数据库表交互的焦点对象。因此：
    
    
    
    • 将 @NamedNativeQuery 和 @SqlResultSetMapping 写在实体类上，可以明确这段查询与该实体相关，方便维护和查阅。
      
    • JPA 的原生查询和结果映射机制依赖于实体类的原数据，通过注解绑定的方式，可以让这些查询和映射规则作为实体类的一部分，便于复用。
      
    
    
  • 关联性强
    
    
    
    • @NamedNativeQuery
             定义了原生 SQL 查询，而 @SqlResultSetMapping 定义了如何映射这个查询的结果，它们是 成对使用的。二者写在同一个实体类上，能清晰地表达“该查询和该实体类相关”的逻辑。
      
    • 如果你把它们分散到其他地方，大概会增长代码复杂性和维护成本。
      
    
    
  
  

---

• 4. 总结
  

简朴来说，@NamedNativeQuery 和 @SqlResultSetMapping 分别办理了两个差别的问题：

• @NamedNativeQuery 负责“如何查询”
         它定义了 SQL 的逻辑以及参数。
  
• @SqlResultSetMapping 负责“如何处理查询结果”
         它定义了如何将 SQL 返回的数据映射到 DTO中
  

二者通过查询名称（name 属性）接洽在一起。例如：

1. @NamedNativeQuery(
2.     name = "IssueRecommendRespDTOQuery", // 查询名称
3.     resultSetMapping = "IssueRecommendRespDTOResult", // 映射↓
4.     query = """
5.         SELECT ... -- 原生 SQL 查询
6.     """
7. )
8. @SqlResultSetMapping(
9.     name = "IssueRecommendRespDTOResult", // 映射名称 对应↑
10.     classes = @ConstructorResult(
11.         targetClass = IssueRecommendRespDTO.class, // 映射到的 DTO
12.         columns = {
13.             @ColumnResult(name = "isdId", type = Integer.class),
14.             ...
15.         }
16.     )
17. )

复制代码

两个注解表明 - end

---

实体类代码示例

1. @AllArgsConstructor
2. @NoArgsConstructor
3. @Data
4. @Entity
5. @Table(name = "issue_video")
6. // region jpa 投影主页查询目标dto (可以通过 "region <> endregion" 将其折叠起来)
7. @SqlResultSetMapping(
8.     name = "IssueRecommendRespDTOResult",
9.     classes = @ConstructorResult(
10.         targetClass = IssueRecommendRespDTO.class,
11.         columns = {
12.             @ColumnResult(name = "isdId", type = Integer.class),
13.             @ColumnResult(name = "videoUrl", type = String.class),
14.             @ColumnResult(name = "duration", type = Integer.class),
15.             @ColumnResult(name = "issId", type = Integer.class),
16.             @ColumnResult(name = "title", type = String.class),
17.             @ColumnResult(name = "cover", type = String.class),
18.             @ColumnResult(name = "watchNum", type = BigInteger.class),
19.             @ColumnResult(name = "commentNum", type = Integer.class),
20.             @ColumnResult(name = "creTime", type = LocalDateTime.class),
21.             @ColumnResult(name = "authorId", type = Integer.class),
22.             @ColumnResult(name = "authorName", type = String.class)
23.         }
24.     )
25. )
26. // endregion
28. // region jpa 投影主页推荐查询sql
29. @NamedNativeQuery(
30.     name = "IssueRecommendRespDTOQuery",
31.     resultSetMapping = "IssueRecommendRespDTOResult",
32.     query = """
33. SELECT
34.         sub.isd_id AS isdId,
35.         sub.video_url AS videoUrl,
36.         sub.duration AS duration,
37.         sub.iss_id AS issId,
38.         sub.title AS title,
39.         sub.cover AS cover,
40.         sub.watch_num AS watchNum,
41.         sub.comment_num AS commentNum,
42.         sub.cre_time AS creTime,
43.         sub.u_id AS authorId,
44.         sub.name AS authorName
45.       FROM (
46.                SELECT
47.                    i.score,
48.                    v.isd_id,
49.                    v.video_url,
50.                    v.duration,
51.                    i.iss_id,
52.                    i.title,
53.                    i.cover,
54.                    i.watch_num,
55.                    i.comment_num,
56.                    i.cre_time,
57.                    author.u_id,
58.                    author.name,
59.                    case
60.                        when ROW_NUMBER() OVER (
61.                            PARTITION BY i.su_id
62.                            ORDER BY
63.                                CASE
64.                                    WHEN sp.su_id IS NOT NULL THEN (i.score + sp.score)
65.                                    ELSE i.score
66.                                    END DESC
67.                            ) <= 3 then 1
68.                       else 2
69.                       end AS rank_within_partition,
70.                    RANK() OVER (
71.                        PARTITION BY i.su_id
72.                        ORDER BY
73.                            CASE
74.                                WHEN sp.su_id IS NOT NULL THEN (i.score + sp.score)
75.                                ELSE i.score
76.                                END DESC
77.                        ) as global_rank
78.                FROM issue_video v
79.                         JOIN issue i ON i.iss_id = v.iss_id
80.                         JOIN user author ON author.u_id = i.u_id
81.                         LEFT JOIN subarea_preference sp
82.                             ON sp.su_id = i.su_id
83.                             and sp.u_id = :uId
84.               order by (i.score + sp.score) desc
85.            ) sub
86.       order by rank_within_partition, global_rank
87. """
88. )
89. // endregion
90. public class IssueVideo {
91.     @GeneratedValue(strategy = GenerationType.IDENTITY)
92.     @Id
93.     private Integer isdId;
95.     private String videoUrl;
96.     private int duration;
97.     private int size;
98.     private LocalDateTime updTime;
99.     private String remark;
100.     private LocalDateTime issueTime;
101.     private String permission;
102.     private Boolean isDeclare;
103.     private Boolean offDanmu;
104.     private Boolean offComm;
105.     private Boolean onGretestComm;
106.     private Boolean isDel;
108.     @ManyToOne
109.     @JoinColumn(name = "vd_id")
110.     private VideoDeclare videoDeclare;
112.     private BigInteger danmuNum;
114.     @OneToOne
115.     @JoinColumn(name = "iss_id")
116.     private Issue issue;
117. }

复制代码

二、配置对应 JPA 接口

       在 JPA 接口中，直接通过 @Query 注解调用刚刚定义的原生 SQL 查询，并将结果映射成期望的 DTO 返回类型
Repository 代码示例

1. public interface IssueVideoRepo extends JpaRepository<IssueVideo, Integer> {
2.     /**
3.      * 获取主页推荐视频
4.      * @param uId 用户 ID
5.      * @return DTO 列表
6.      */
7.     @Query(name = "IssueRecommendRespDTOQuery", nativeQuery = true)
8.     List<IssueRecommendRespDTO> getRecommendVideos(@Param("uId") Integer uId);
9. }

复制代码

三、事件层调用接口

       事件层负责调用 Repository 接口，并将返回的结果处理为终极服务层须要的数据。以下为服务实现代码：
Service 代码示例

1. @Service
2. public class IssueVideoServiceImpl implements IssueVideoService {
3.     @Autowired
4.     private IssueVideoRepo issueVideoRepo;
6.     @Override
7.     public List<IssueRecommendRespDTO> getRecommendVideos(Integer uId) {
8.         List<IssueRecommendRespDTO> recommendVideos = null;
9.         try {
10.             recommendVideos = issueVideoRepo.getRecommendVideos(uId);
11.         } catch (Exception exception) {
12.             exception.printStackTrace();
13.         }
14.         return recommendVideos;
15.     }
16. }

复制代码

四、定义 DTO 类

       最后，定义与查询结果对应的 DTO 类。DTO 结构须要与 @SqlResultSetMapping 中的字段一一对应。
DTO 代码示例

1. @Data // 主dto 不需要lombok 全参数注解 @AllArgsConstructor, 因为要额外配置
2. public class IssueRecommendRespDTO {
3.     private Integer isdId;
4.     private String videoUrl;
5.     private Integer duration;
6.     private IssueRecommendInDTO issue;
8.     public IssueRecommendRespDTO() {}
10.     public IssueRecommendRespDTO(Integer isdId, String videoUrl, Integer duration,
11.                                  Integer issId, String title, String cover,
12.                                  BigInteger watchNum, Integer commentNum, LocalDateTime creTime,
13.                                  Integer authorId, String authorName) {
15.         this.isdId = isdId;
16.         this.videoUrl = videoUrl;
17.         this.duration = duration;
18.         this.issue = new IssueRecommendInDTO(
19.                 issId, title, cover,
20.                 watchNum, commentNum, creTime,
21.                 new AuthorInDTO(authorId, authorName)
22.         );
23.     }
24. }
26. @AllArgsConstructor
27. @NoArgsConstructor
28. @Data
29. public class IssueRecommendInDTO { // In命名表示 该dto 很可能处于内部使用 > internal : 内部的
30.     private Integer issId;
31.     private String title;
32.     private String cover;
33.     private BigInteger watchNum;
34.     private Integer commentNum;
35.     private LocalDateTime creTime;
36.     private AuthorInDTO author;
37. }
39. @AllArgsConstructor
40. @NoArgsConstructor
41. @Data
42. public class AuthorInDTO {
43.     private Integer authorId;
44.     private String authorName;
45. }

复制代码

总结

       上述步骤以颠末实际开发测试，保证有效！

• 高效性：直接通过原生 SQL 查询所需数据，减少不须要字段的查询和映射。
  
• 灵活性：可以自由定义 DTO 结构，满意复杂查询的需求。
  
• 可维护性：使用 @SqlResultSetMapping 将 SQL 与 Java 类关联，便于后续维护。
  

       该文章适用于须要自定义复杂查询且无需将查询结果绑定到实体类的场景。如果你也有类似需求，不妨以文章为参照上手试试！


end…
如果这篇文章帮到你, 帮忙点个关注呗, 不想那那那点赞或收藏也行鸭 (｡•̀ᴗ-)✧ ~

                                                                                                                                   '(இ﹏இ`｡)

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。