JPA自定义对象接收查询结果集操作

最近使用JPA的时候,碰到需要自定义查询结果集的场景,网上搜了一下,都是需要自定义方法写一大串代码实现的,太繁琐了,有那时间还不如用mybaits。

用JPA就是要尽量通过声明接口解决持久层问题,要不然鬼用。逼得没办法去了官网看看文档,再没有就放弃了,没时间看源码。最终找到我想要的结果了。

例如,传统的JPA接口实现如下所示:

class Person {
 @Id UUID id;
 String firstname, lastname;
 Address address;
 static class Address {
 String zipCode, city, street;
 }
}
interface PersonRepository extends Repository<Person, UUID> {
 Collection<Person> findByLastname(String lastname);
}

自定义对象接收查询结果集方法如下:

(1)增加接收数据接口

interface NamesOnly {
 String getFirstname();
 String getLastname();
}

(2)增加持久层接口

interface PersonRepository extends Repository<Person, UUID> {
 Collection<NamesOnly> findByLastname(String lastname);
}

如果要对查询结果进行序列号的话就会有点问题:

{
 "errorCode": "00",
 "errorMessage": "操作成功",
 "returnObject": [
 {
  "createtime": 1526358195000,
  "id": 49,
  "lastupdatetime": 1526358195000,
  "status": "2",
  "target": {
  "createtime": 1526358195000,
  "lastupdatetime": 1526358195000,
  "check_Wicket": "1",
  "facility_name": "血压测量",
  "facility_Num": "C3",
  "id": 49,
  "status": "2",
  "check_name": "小汤154",
  "check_Num": "BY185201805140001"
  },
  "targetClass": "org.springframework.data.jpa.repository.query.AbstractJpaQuery$TupleConverter$TupleBackedMap"
 }
 ]
}

会出现targetClass这个字段,不能直接把结果拿来用,很恶心,又不想写代码中转下。

经过后来的摸索,其实如果只是为了返回JSON,也可以直接在Repository层直接用List<Map<String,Object>>来返回,

Map<String,Object>对应单条查询结果,完美解决序列化问题。

完毕。就这么简单。

补充:SpringBoot JPA查询结果映射到自定义实体类

场景

举一个简单的例子:

比如有一个Position实体类

@Entity
@Table(name = "position")
public class Position implements Serializable {
 private static final long serialVersionUID = 768016840645708589L;
 @Id
 @GeneratedValue(strategy = GenerationType.IDENTITY)
 private Long id;
 private String name;
 private BigDecimal salary;
 private String city;

 ...//省略getset方法
 ...//省略toString方法
} 

然后有一个PositionDetail实体类

@Entity
@Table(name = "position_detail")
public class PositionDetail implements Serializable {
 private static final long serialVersionUID = 4556211410083251360L;
 @Id
 @GeneratedValue(strategy = GenerationType.IDENTITY)
 private Long id;
 private Long pid;
 private String description;

 ...//省略getset方法
 ...//省略toString方法
}

需求:

查询职位基本信息,职位描述,因为涉及到两张表操作,简单的查询并不能满足我们的需求,因此就需要自定义查询接口并返回符合需求的结果。

接下来再定义一个实体类,用来接收查询结果

public class PositionDO {
 private Long id;
 private String name;
 private BigDecimal salary;
 private String city;
 private String description;
 public PositionDO(Long id, String name, BigDecimal salary, String city, String description) {
 this.id = id;
 this.name = name;
 this.salary = salary;
 this.city = city;
 this.description = description;
 }
 ...//省略getset方法
 ...//省略toString方法
}

编写Dao接口,用来实现CRUD操作

public interface PositionDao extends JpaRepository<Position, Long> {
 @Query(nativeQuery = true, value = "select t1.id, t1.name, t1.salary, t1.city, t2.description) \n" +
 "from position t1 left join position_detail t2 on t1.id = t2.pid \n" +
 "where t1.id = :id")
 PositionDO findPositionById(@Param("id") Long id);
}

思考:

如果这样写会不会出现问题?接下来我们编写一个测试类测试一下。

@SpringBootTest(classes = ShardingApplication.class)
@RunWith(SpringRunner.class)
public class TestShardingDatabase {
 @Resource
 PositionDao positionDao;
 @Test
 public void testQueryById() throws Exception{
 PositionDO positionDO = positionDao.findPositionById(548083053407240192L);
 System.out.println(positionDO);
 }
}

哈哈,翻车了吧,还好先测试了一波,问题不大。

Hibernate: select t1.id, t1.name, t1.salary, t1.city, t2.description
from position t1 left join position_detail t2 on t1.id = t2.pid
where t1.id = ?
org.springframework.core.convert.ConverterNotFoundException: No converter found capable of converting from type [org.springframework.data.jpa.repository.query.AbstractJpaQuery$TupleConverter$TupleBackedMap] to type [com.lsp.dto.PositionDO]

分析原因:

那么到底是为什么造成这样的原因呢?相信小伙伴们一眼就能看出来了,是因为Jpa找不到能够从类型转换的转换器,而抛出这样的异常。

现在问题来了,既然这样不行,那么我们想要实现映射到自定义结果集该如何实现呢?

实现:

JPA可以自定义SQL语句进行查询,然后查询语句可以通过原生SQL语句(原生SQL语句也就是在@Query注解里加上nativeQuery = true)进行查询。当然了,也可以通过JPQL进行查询。

我们这里就是通过JPQL进行查询,它的特征就是与原生SQL语句类似,完全面向对象,通过类名和属性访问,而不是表名和表属性。

由此PositionDao修改之后就像这样

public interface PositionDao extends JpaRepository<Position, Long> {
 @Query(value = "select new com.lsp.domain.PositionDO(t1.id, t1.name, t1.salary, t1.city, t2.description) \n" +
  "from Position t1 left join PositionDetail t2 on t1.id = t2.pid \n" +
  "where t1.id = :id")
 PositionDO findPositionById(@Param("id") Long id);
}

接下来我们再运行测试方法看一下。

Hibernate: select position0_.id as col_0_0_, position0_.name as col_1_0_, position0_.salary as col_2_0_, position0_.city as col_3_0_, positionde1_.description as col_4_0_ from position position0_ left outer join position_detail positionde1_ on (position0_.id=positionde1_.pid) where position0_.id=?
PositionDO{id=548083053407240192, name='Jerry5', salary=10000.00, city='beijing5', description='this is message 5'}

ok了,结果已经正确查询出来。

总结:

注意上面的SQL语句是面向对象的,对应的字段也都是实体类里面的属性。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。如有错误或未考虑完全的地方,望不吝赐教。

(0)

相关推荐

  • Spring Data Jpa实现自定义repository转DTO

    近期项目中需要 关联 几张表再把字段转出来,在这里记录以下,我感觉网上写的都不太规范和清晰. @Entity @SqlResultSetMapping( name="TestMapping", entities = { @EntityResult( entityClass = com.xxx.xx.data.model.TestEntity.class, fields = { @FieldResult(name="id",column="id")

  • SpringBoot Jpa 自定义查询实现代码详解

    这篇文章主要介绍了SpringBoot Jpa 自定义查询实现代码详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 持久层Domain public interface BaomingDao extends JpaRepository<BaomingBean,Integer> { @Query(value = "select distinct t.actid from BaomingBean t where t.belongs=?

  • Spring Boot JPA中使用@Entity和@Table的实现

    本文中我们会讲解如何在Spring Boot JPA中实现class和数据表格的映射. 默认实现 Spring Boot JPA底层是用Hibernate实现的,默认情况下,数据库表格的名字是相应的class名字的首字母大写.命名的定义是通过接口ImplicitNamingStrategy来定义的: /** * Determine the implicit name of an entity's primary table. * * @param source The source inform

  • springboot 之jpa高级查询操作

    springboot的jpa可以根据方法名自动解析sql 非常方便, 只需要在 dao接口中定义方法即可; 下面是一个 demo package com.bus365.root.dao; import java.io.Serializable; import java.util.List; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.reposi

  • JPA自定义对象接收查询结果集操作

    最近使用JPA的时候,碰到需要自定义查询结果集的场景,网上搜了一下,都是需要自定义方法写一大串代码实现的,太繁琐了,有那时间还不如用mybaits. 用JPA就是要尽量通过声明接口解决持久层问题,要不然鬼用.逼得没办法去了官网看看文档,再没有就放弃了,没时间看源码.最终找到我想要的结果了. 例如,传统的JPA接口实现如下所示: class Person { @Id UUID id; String firstname, lastname; Address address; static class

  • 使用JPA自定义VO接收返回结果集(unwrap)

    目录 JPA自定义VO接收返回结果集(unwrap) JPA返回自定义VO JPA自定义VO接收返回结果集(unwrap) JPA跟mybitis比较,简单的业务搜索是方便的,但是设计到复杂的SQL搜索时,我们需要自定义SQL. 1.@Query直接写SQL,缺点是无法动态的组装条件 2.JPA的Specification对象动态组装where搜索条件 3.entityManager执行CriteriaBuilder 4.entityManger直接使用createNativeQuery,执行原

  • Spring Data Jpa返回自定义对象的3种方法实例

    目录 方法一.简单查询直接new对象 方法二.Service层使用EntityManager 方法三.Dao层使用Map接收自定义对象 总结 tasks表对应的Entity @Entity @NoArgsConstructor @AllArgsConstructor @Table(name = "tasks") @Data public class Tasks extends BaseEntity { @Id @GeneratedValue(strategy = GenerationT

  • Mybatis查询语句返回对象和泛型集合的操作

    Mybatis查询语句返回对象和泛型集合 EmpMapper映射接口: package cn.et.mybatis.lesson03; import java.util.List; import org.apache.ibatis.annotations.Result; import org.apache.ibatis.annotations.Results; import org.apache.ibatis.annotations.Select; public interface EmpMap

  • 使用JPA自定义SQL查询结果

    目录 JPA自定义SQL查询结果 直接上代码 最后跑一下demo代码 JPA的SQL查询 一 点睛 二 JPA的NamedQuery查询 三 使用@Query查询 JPA自定义SQL查询结果 很多时候都会遇到自定义sql,自定义返回字段,而不是pojo类.这个情况要通过接口定义返回. 直接上代码 @Query(value = "select m.field AS field,COUNT(m.field) AS size from MigrationObject m where m.xmlName

  • JPA原生SQL(自定义SQL)分页查询逻辑详解

    目录 JPA原生SQL(自定义SQL)分页查询 经过测试下面方法可以 pageable对象里定义排序的字段 JPA原生SQL分页查询踩坑记录 1.问题简述 2.解决方案 JPA原生SQL(自定义SQL)分页查询 JPA自己写SQL查询的话,分页还稍微麻烦 经过测试下面方法可以 @Query(nativeQuery = true, value = "select * from goods where " + " codeName like CONCAT('%',?1,'%')

  • asp sqlserver 执行存储过程返回记录集报对象关闭时不允许操作

    如果要得到返回值,需要用Command的方法. 首先说明,返回值有两种.一种是在存储过程中直接return一个值,就象C和VB的函数返回值那样:另一种是可以返回多个值,存储这些值的变量名称需要在调用参数中先行指定. 这个例子要处理多种参数,输入参数,输出参数,返回记录集以及一个直接返回值(够全了吧?) 存储过程如下: 复制代码 代码如下: use pubs GO -- 建立存储过程 create procedure sp_PubsTest -- 定义三个参数变量,注意第三个,特别标记是用于输出

  • 使用jdbcTemplate查询返回自定义对象集合代码示例

    1.在UserInfo.java中添加一个Map转换为UserInfo的方法 public static UserInfo toObject(Map map) { UserInfo userInfo = new UserInfo(); userInfo.setId((Integer) map.get(id)); userInfo.setUname((String) map.get(uname)); userInfo.setUnumber((Integer) map.get(unumber));

  • Java反射 JavaBean对象自动生成插入,更新,删除,查询sql语句操作

    通过反射根据提供的表名.POJO类型.数据对象自动生成sql语句. 如名为 User 的JavaBean与名为 user 的数据库表对应,可以提供一个封装有数据的User对象user,根据user中含有的数据自动生成sql语句. 1.生成插入语句(插入user中包含的非空数据的语句): String insertSql = getInsertSql("user", User.class, user); 2.生成更新语句(user中id不能为空): String updateSql =

随机推荐