关于Spring-JPA框架下使用多表查询的应用实例记录

谁借莪１个温暖的怀抱￠ 2022-07-28 01:57 119阅读 0赞

1.目的：记录如何 用jpa来实现快速的多表查询， 暂不深入探究jpa的内部实现

2. 说明情形：

@1所涉及的表为t\_user(id,name,date,...)；t\_factory\_user(id,factory\_id,user\_id,...), 其中表s\_factory\_user\[user\_id\]==t\_user\[id\]， 为主外键的关联关系

@2现状 在entity类User中， 如下代码：

@OneToMany(mappedBy = "s\_factory\_user", fetch = FetchType.LAZY, cascade = \{CascadeType.ALL\})  
private FactoryUser fu = new FactoryUser();

在entity类FactoryUser中， 如下代码：

@ManyToOne(cascade = \{CascadeType.MERGE, CascadeType.REFRESH\})  
@JoinColumn(name = "user\_id")  
private User user;

添加代码后， 在启动项目后会报错， “org.hibernate.MappingException: Could not determine type for:”， 即为在不能在Use实体类中，定义属性fu(fu属性类型为factoryUser)；

解决：在查询了相关文章后， “mappingexception”是指配置hibernate配置文件时错误或没有加载上hbm配置文件。现在该项目中用到的是jpa的注解方式来配置hibernate映射关系，还是我在属性的注解上有错误。 尝试直接在属性上添加属性@Transient， 加载依然报错，那么现在简单了解一下@OneToMany的使用；

@1.其中的mappedBy指的是关联类FactoryUser中的属性名user

@2. 在factoryUser类中，@JoinColumn中的name属性为‘userId’， 是对应的factoryUser的属性userId

则正常的应该为：

在factoryUser类中

private User user;

@OneToOne(cascade = \{CascadeType.MERGE, CascadeType.REFRESH\})  
@JoinColumn(name = "userId")  
public User getUser() \{  
return user;  
\}

在User类中

private FactoryUser fu;

@OneToOne(cascade = CascadeType.ALL, fetch = FetchType.EAGER, mappedBy = "user")  
public FactoryUser getFu() \{  
return fu;  
\}

ok, 这样项目可以正常启动了。

3.使用jpa的查询

@1 要集成接口类JpaSpecificationExecutor， 该类提供了几个方法

T findOne(Specification<T> spec);

List<T> findAll(Specification<T> spec);

Page<T> findAll(Specification<T> spec, Pageable pageable);

@2 具体的使用

<span>	</span>Specification<User> spec = new Specification<User>() {
                
                @Override
                public Predicate toPredicate(Root<User> root, CriteriaQuery<?> query, CriteriaBuilder cb) {
                    Predicate p1 = cb.equal(root.get("userCategory").as(Integer.class), 2);
                    // 设置sql链接
                    Join<User, FactoryUser> fuJoin = root.join(root.getModel().getSingularAttribute("fu", FactoryUser.class), JoinType.INNER);
                    Predicate p2 = cb.equal(fuJoin.get("factoryId").as(Long.class), factoryIdFinal);
                    query.where(cb.and(p1, p2));
                    // 添加排序的功能
                    query.orderBy(cb.desc(root.get("id").as(Long.class)));
                    return query.getRestriction();
                }
            };
            return userDao.findAll(spec);

待续