JPA如何使用nativequery多表关联查询返回自定义实体类

278 阅读 0 评论 184 点赞

我是靠谱客的博主哭泣小蝴蝶，这篇文章主要介绍JPA如何使用nativequery多表关联查询返回自定义实体类，现在分享给大家，希望可以做个参考。

JPA nativequery多表关联查询返回自定义实体类

JPA官方推荐的多表关联查询使用不便，接触的有些项目可能会使用JPA 做简单查询，Mybaits做复杂查询。所以想要寻找一种好用的解决方案。

JPA多表关联的实现方式

1.使用Specification实现映射关系匹配，如@ManyToOne等

2.使用NativeQuery等sql或hql来实现

优缺点对比

1.映射关系是hibernate的入门基础，很多人都会习惯去使用。个人不太喜欢这种方式，复用性太弱，且不灵活特别是在多表复杂业务情况下。

2.使用Specification方式需要继承JpaSpecificationExecutor接口，构造对应的方法后传入封装查询条件的Specification对象。逻辑上简单易懂，但是构造Specification对象需要拼接格式条件非常繁琐。

3.直接使用NativeQuery等方式实现复杂查询个人比较喜欢，直观且便利，弊端在于无法返回自定义实体类。需要手动封装工具类来实现Object到目标对象的反射。

使用sql并返回自定义实体类

个人比较喜欢的实现方式，不多说看代码

复制代码

import org.springframework.stereotype.Repository;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;
 
@Repository
public class EntityManagerDAO {
    @PersistenceContext
    private EntityManager entityManager;
     /**
     * 人员列表排序
     * @return
     */
    @Transactional
    public List<BackstageUserListDTO> listUser(){
        String sql = "select a.create_time createTime," +
                "a.mobilephone phoneNum," +
                "a.email email,a.uid uid," +
                "a.enabled enabled," +
                "c.id_number idNumber," +
                " (case b.`status` when 1 then 1 else 0 end) status " +
                "from tbl_sys_user a " +
                "LEFT JOIN user_high_qic b on a.uid=b.u_id" +
                "LEFT JOIN user_qic c on a.uid=c.uid " +
                "ORDER BY status desc";
 
        SQLQuery sqlQuery = entityManager.createNativeQuery(sql).unwrap(SQLQuery.class);
        Query query = 
     sqlQuery.setResultTransformer(Transformers.aliasToBean(BackstageUserListDTO.class));
        List<BackstageUserListDTO> list = query.list();
        entityManager.clear();
        return list;
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
import org.springframework.stereotype.Repository;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;
 
@Repository
public class EntityManagerDAO {
    @PersistenceContext
    private EntityManager entityManager;
     /**
     * 人员列表排序
     * @return
     */
    @Transactional
    public List<BackstageUserListDTO> listUser(){
        String sql = "select a.create_time createTime," +
                "a.mobilephone phoneNum," +
                "a.email email,a.uid uid," +
                "a.enabled enabled," +
                "c.id_number idNumber," +
                " (case b.`status` when 1 then 1 else 0 end) status " +
                "from tbl_sys_user a " +
                "LEFT JOIN user_high_qic b on a.uid=b.u_id" +
                "LEFT JOIN user_qic c on a.uid=c.uid " +
                "ORDER BY status desc";
 
        SQLQuery sqlQuery = entityManager.createNativeQuery(sql).unwrap(SQLQuery.class);
        Query query = 
     sqlQuery.setResultTransformer(Transformers.aliasToBean(BackstageUserListDTO.class));
        List<BackstageUserListDTO> list = query.list();
        entityManager.clear();
        return list;
    }
}

复制代码

1
2
3
4
5
6
7
8
9
10
11
public class BackstageUserListDTO implements Serializable{
    private static final long serid = 1L;
    private String createTime;
    private String phoneNum;
    private String email;
    private BigInteger uid;
    private Integer enabled;
    private String idNumber;
    private BigInteger status;
    //GETTER SETTER
}

这样一个需求如果使用前两种方式实现，无疑会非常麻烦。使用这种方式能够直接反射需要的自定义实体类。

可以根据需求整理封装成不同的方法，加入排序，分页等。我在这里主要提供一种方便的解决思路。

JPA多表关联动态查询（自定义sql语句）

项目需求，查询需求数据需要多表链接——>根据多种条件筛选查询到的数据，在网上查了很多资料最终选择这个字符串拼接查询

类似如此动态查询

以下是本人项目中使用总结：

实体类

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
/**
 * 订单表
 */
@Entity
@Table(name = "signedorder")
@Getter
@Setter
@NoArgsConstructor
@EntityListeners(AuditingEntityListener.class)
public class SignedOrder {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column
    private Integer id;//id
    @CreatedDate
    @Column(updatable = false)
    private Date createTime;//创建时间
    @LastModifiedDate
    @Column
    private Date lastModifiedTime;//修改时间
    @ManyToOne(fetch = FetchType.EAGER, cascade = {
            CascadeType.MERGE, CascadeType.PERSIST, CascadeType.REFRESH
    })
    @JoinTable(name = "staff_signedorder", joinColumns = @JoinColumn(name =
            "signedorder_id"), inverseJoinColumns = @JoinColumn(name = "staff_id"))
    private Staff staff;//所属用户
    @JoinColumn(name = "industry_id")
    private Integer industryId;//行业Id
}

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
/**
 * 用户表
 */
@Entity
@Table(name = "staff")
@Getter
@Setter
@NoArgsConstructor
public class Staff {
 
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private Integer id;//id
    @Column(name = "name", length = 25)
    private String name;//姓名
    @JoinColumn(name = "city_id")
    private Integer cityId;//城市id

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
/**
 * 城市表
 */
@Entity
@Table(name = "city")
@Getter
@Setter
@NoArgsConstructor
@Accessors(chain = true)
public class City {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private Integer id;//id
    @Column(name = "name", length = 50)
    private String name;//名称
}
//行业表和城市表一致，就不展示了

注解解释

实体类中相关注解解释：

@Entity：对实体注释。任何Hibernate映射对象都要有这个注释
@Table：声明此对象映射到数据库的数据表，该注释不是必须的，如果没有则系统使用默认值(实体的短类名)
@Getter、 @Setter、 @NoArgsConstructor：lombok提供注解，get、set方法及无参构造
@EntityListeners(AuditingEntityListener.class)：加上此注解，时间注解@LastModifiedDate 和 @CreatedDate才可以生效
@Id：声明此属性为主键
@GeneratedValue(strategy = GenerationType.IDENTITY)：指定主键，

TABLE：使用一个特定的数据库表格来保存主键；

IDENTITY：主键由数据库自动生成（主要是自动增长型）；

SEQUENCR：根据底层数据库的序列来生成主键，条件是数据库支持序列；

AUTO：主键由程序控制

@CreatedDate(updatable = false)：创建时间时间字段，在insert的时候，会设置值；update时时间不变
@LastModifiedDate：修改时间段，update时会修改值
@ManyToOne(fetch = FetchType.EAGER, cascade = {CascadeType.MERGE, CascadeType.PERSIST, CascadeType.REFRESH})：多对一，

FetchType.EAGER:立即加载, 获取关联实体；

CascadeType.MERGE: 级联更新；

CascadeType.PERSIST:级联新建；

CascadeType.REFRESH:级联刷新

@JoinTable: JoinColumn：保存关联关系的外键的字段;inverseJoinColumns：保存关系的另外一个外键字
@Column：用来标识实体类中属性与数据表中字段的对应关系

测试类

复制代码

@RunWith(SpringRunner.class)
@SpringBootTest
public class SprinBootMarketingsystemApplicationTests {
    @PersistenceContext//jpa的数据库操作类
    private EntityManager entityManger;
    @Test
    public void queryDb(){
       //给参数赋值
        Integer cityId = 1;
        Integer industryId = 2;
        Integer staffId = 16;
        Date startTime = DateUtil.parse("1970-01-01");//字符串时间转换为date类型
        Date endTime = Calendar.getInstance().getTime();//获取系统当前时间装换为date类型
        
        //创建SQL语句主体
        StringBuffer stringBuffer = new StringBuffer("tSELECTn" +
                "tcount( * ) count,n" +
                "tci.NAME cityNamen" +
                "tFROMn" +
                "tsignedorder sn" +
                "tLEFT JOIN staff_signedorder t ON s.id = t.signedorder_idn" +
                "tLEFT JOIN staff sta ON t.staff_id = sta.idn" +
                "tLEFT JOIN city ci ON sta.city_id = ci.idn" +
                "tWHEREn" +
                "t1 = 1");
         Map<String,Object> map =  new HashMap<>();
         //拼接动态参数
        if(industryId != null){
            
             /*第一种给参数赋值方式
             1代表传进来的参数顺序,给参数赋值nativeQuery.setParameter(1, industryId);
             stringBuffer.append(" and s.industryId = ?1");*/
             //industryId代表传进来的参数名称,给参数赋值nativeQuery.setParameter("industryId", industryId);
             stringBuffer.append(" and s.industry_id = :industryId");
             map.put("industryId",industryId);
        }
        if(cityId != null){
            stringBuffer.append(" and ci.id = :cityId");
            map.put("cityId",cityId);
        }
        if(staffId != null){
            stringBuffer.append(" and sta.id = :staffId");
            map.put("staffId",staffId);
        }
        if(startTime!=null && endTime!=null){
            //使用这种赋值方式，时间类型需要给三个参数，参数名称，参数值，特定映射的类型TemporalType.DATE
            //nativeQuery.setParameter("create_time", startTime,TemporalType.DATE);
            stringBuffer.append( " and s.create_time BETWEEN :startTime and :endTime ");
            map.put("startTime",startTime);
            map.put("endTime",endTime);
        }
        Query nativeQuery = entityManger.createNativeQuery(stringBuffer.toString());
        for (String key : map.keySet()) {
            nativeQuery.setParameter(key, map.get(key));
        }
        //三种接受返回结果方式(第一种方式)
        /*nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.TO_LIST);
        List resultList1 = nativeQuery.getResultList();
        for (Object o : resultList1) {
            System.out.println(o.toString());
        }*/
       //第二种方式和第一种方式相似
        /*nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
        List<Map<String, Object>> resultList = nativeQuery.getResultList();
        for (Map<String, Object> map1 :resultList
        ) {
            System.out.println(map1);
        }*/
        //第三种方式：实体类接受
        nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.aliasToBean(TestVo.class));
        List<TestVo> resultList = nativeQuery.getResultList();
        for (TestVo svo:resultList
        ) {
            System.out.println(svo.toString());
        }
    }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
@RunWith(SpringRunner.class)
@SpringBootTest
public class SprinBootMarketingsystemApplicationTests {
    @PersistenceContext//jpa的数据库操作类
    private EntityManager entityManger;
    @Test
    public void queryDb(){
       //给参数赋值
        Integer cityId = 1;
        Integer industryId = 2;
        Integer staffId = 16;
        Date startTime = DateUtil.parse("1970-01-01");//字符串时间转换为date类型
        Date endTime = Calendar.getInstance().getTime();//获取系统当前时间装换为date类型
        
        //创建SQL语句主体
        StringBuffer stringBuffer = new StringBuffer("tSELECTn" +
                "tcount( * ) count,n" +
                "tci.NAME cityNamen" +
                "tFROMn" +
                "tsignedorder sn" +
                "tLEFT JOIN staff_signedorder t ON s.id = t.signedorder_idn" +
                "tLEFT JOIN staff sta ON t.staff_id = sta.idn" +
                "tLEFT JOIN city ci ON sta.city_id = ci.idn" +
                "tWHEREn" +
                "t1 = 1");
         Map<String,Object> map =  new HashMap<>();
         //拼接动态参数
        if(industryId != null){
            
             /*第一种给参数赋值方式
             1代表传进来的参数顺序,给参数赋值nativeQuery.setParameter(1, industryId);
             stringBuffer.append(" and s.industryId = ?1");*/
             //industryId代表传进来的参数名称,给参数赋值nativeQuery.setParameter("industryId", industryId);
             stringBuffer.append(" and s.industry_id = :industryId");
             map.put("industryId",industryId);
        }
        if(cityId != null){
            stringBuffer.append(" and ci.id = :cityId");
            map.put("cityId",cityId);
        }
        if(staffId != null){
            stringBuffer.append(" and sta.id = :staffId");
            map.put("staffId",staffId);
        }
        if(startTime!=null && endTime!=null){
            //使用这种赋值方式，时间类型需要给三个参数，参数名称，参数值，特定映射的类型TemporalType.DATE
            //nativeQuery.setParameter("create_time", startTime,TemporalType.DATE);
            stringBuffer.append( " and s.create_time BETWEEN :startTime and :endTime ");
            map.put("startTime",startTime);
            map.put("endTime",endTime);
        }
        Query nativeQuery = entityManger.createNativeQuery(stringBuffer.toString());
        for (String key : map.keySet()) {
            nativeQuery.setParameter(key, map.get(key));
        }
        //三种接受返回结果方式(第一种方式)
        /*nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.TO_LIST);
        List resultList1 = nativeQuery.getResultList();
        for (Object o : resultList1) {
            System.out.println(o.toString());
        }*/
       //第二种方式和第一种方式相似
        /*nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);
        List<Map<String, Object>> resultList = nativeQuery.getResultList();
        for (Map<String, Object> map1 :resultList
        ) {
            System.out.println(map1);
        }*/
        //第三种方式：实体类接受
        nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.aliasToBean(TestVo.class));
        List<TestVo> resultList = nativeQuery.getResultList();
        for (TestVo svo:resultList
        ) {
            System.out.println(svo.toString());
        }
    }

打印结果

第一种方式打印结果

第二种方式打印结果

第三种方式打印结果

TestVo实体接收类

复制代码

1
2
3
4
5
@Data
public class TestVo {
    private String cityName;//城市名字
    private BigInteger count;//签单数量(必须使用BigInteger类型接受)
}

以上为个人经验，希望能给大家一个参考，也希望大家多多支持靠谱客。

最后

以上就是哭泣小蝴蝶最近收集整理的关于JPA如何使用nativequery多表关联查询返回自定义实体类的全部内容，更多相关JPA如何使用nativequery多表关联查询返回自定义实体类内容请搜索靠谱客的其他文章。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。

本文分类：Java编程
浏览次数：278 次浏览
发布日期：2022-06-01 18:10:13
本文链接：https://www.kaopuke.com/article/k-p-k_14_ujo_22_f1_14_j_22_3.html

JPA如何使用nativequery多表关联查询返回自定义实体类

目录

JPA nativequery多表关联查询返回自定义实体类

JPA多表关联的实现方式

优缺点对比

使用sql并返回自定义实体类

JPA多表关联动态查询（自定义sql语句）

实体类

注解解释

测试类

打印结果

TestVo实体接收类

最后

评论列表共有 0 条评论

发表评论取消回复

JPA如何使用nativequery多表关联查询返回自定义实体类

目录

JPA nativequery多表关联查询返回自定义实体类

JPA多表关联的实现方式

优缺点对比

使用sql并返回自定义实体类

JPA多表关联动态查询（自定义sql语句）

实体类

注解解释

测试类

打印结果

TestVo实体接收类

最后

相关文章

评论列表共有 0 条评论

发表评论 取消回复

微信扫一扫：分享

发表评论取消回复