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

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

目录JPA nativequery多表关联查询返回自定义实体类JPA多表关联的实现方式优缺点对比使用sql并返回自定义实体类JPA多表关联动态查询（自定义sql语句）实体类注解解释测试类打印结果TestVo实体接收类

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 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 list = query.list();

entityManager.clear();

return list;

}

}

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语句）

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

类似如此动态查询

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

实体类

/**

* 订单表

*/

@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

}

/**

* 用户表

*/

@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

/**

* 城市表

*/

@Entity

@Table(name = "city")

@Getter

@Setter

@NoArgsConstructor

@Accessors(chain = true)

public class City {

@Id

@GeneratedValue(strategy = GenerationType.IDENTITY)

@ColFwGMtumn(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("\tSELECT\n" +

"\tcount( * ) count,\n" +

"\tci.NAME cityName\n" +

"\tFROM\n" +

"\tsignedorder s\n" +

"\tLEFT JOIN staff_signedorder t ON s.id = t.signedorder_id\n" +

"\tLEFT JOIN staff sta ON t.staff_id = sta.id\n" +

"\tLEFT JOIN city ci ON sta.city_id = ci.id\n" +

"\tWHERE\n" +

"\t1 = 1");

Map map = new HashMap<>();

//拼接动态参数

if(industryId != null){

/*第一种给参数赋值方式

1代表传进来的参数顺序,给参数赋值nativeQuery.setParameter(1, industryId);

stringBuffer.appenFwGMtd(" 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());

}*/

//http://第二种方式和第一种方式相似

/*nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP);

List

for (Map map1 :resultList

) {

System.out.println(map1);

}*/

//第三种方式：实体类接受

nativeQuery.unwrap(SQLQuery.class).setResultTransformer(Transformers.aliasToBean(TestVo.class));

List resultList = nativeQuery.getResultList();

for (TestVo svo:resultList

) {

System.out.println(svo.toString());

}

}

打印结果

第一种方式打印结果

第二种方式打印结果

第三种方式打印结果

TestVo实体接收类

@Data

public class TestVo {

private String cityName;//城市名字

private BigInteger count;//签单数量(必须使用BigInteger类型接受)

}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。