前言
- 有一个需求,需要将oracle数据库里的一些数据先连表查询出来(假设这些表叫做table1、table2),然后存到另一张表里(table3)
- 新建了table3的Table3PO实体类,使用jpa的方式,直接从table1、table2里查出了所需要的数据,存在了List<Table3PO>里
@Query(value = "select u.user_name, u.sex, a.address " +
" from JPA_USERS u " +
" left join JPA_ADDRESS a on u.user_name=a.user_name",nativeQuery = true)
List<UsersAddPO> nativeQueryData();
- 直接遍历List<Table3PO>,调用jpa自有的saveAndFlush方法,发现数据不存表
原因分析
- 看调用日志,发现saveAndFlush方法执行的时候,并没有调用insert语句,说明要存的数据在表中已经存在了且无需update,但是table3是空的,不可能出现有相同数据的情况
- 全程调用都没报错,问了大佬,说jpa有缓存一说,那可能就是因为这个
- 数据类型全程是Table3PO,刚开始把数据查出来了之后,或许存在了jpa 的缓存里,然后再使用同样的数据类型进行插入的时候,默认在jpa的缓存里插入,而缓存里是有这些数据的,而且数据一模一样,所以甚至连update方法都没有调用
解决
- 查数据的时候直接用map或者构造VO类接收
- 将map类型/VO的数据转化成Table3PO类型
- 调用jpa的saveAndFlush
@Query(value = "select u.user_name as userName, u.sex as sex, a.address as address " +
" from JPA_USERS u " +
" left join JPA_ADDRESS a on u.user_name=a.user_name",nativeQuery = true)
List<Map<String, Object>> mapQueryData();
@Query(value = "select new com.yang.po.UsersAddPO(u.userName, u.sex, a.address) " +
" from UsersPO u " +
" left join AddressPO a on u.userName=a.userName")
List<UsersAddPO> queryData();
源码
springboot+oracle+jpa https://github.com/always404/my-spring-boot
|