使用jpa操作多張表進(jìn)行關(guān)聯(lián)查詢時(shí)，有重復(fù)數(shù)據(jù)需要分組去重

1)確定主表：將有重復(fù)數(shù)據(jù)的表格作為主表，表明關(guān)系

public class AttendanceRuleTypeItem implements Serializable {

@Id

@GeneratedValue(strategy = GenerationType.IDENTITY)

private Long itemId;

private String name;

private Integer code;

private String dictionaryCode;

@OneToMany

@JoinColumn(name = "typesCode",referencedColumnName = "code")

private List attendanceRules;

}

2.副表兩張

public class AttendanceRuleModel {

@Id

@GenericGenerator(name = "guid", strategy = "guid")

@GeneratedValue(generator = "guid")

private String id;

//規(guī)則類型code

private Integer ruleCode;

//請(qǐng)假類型code

private Integer typesCode;

//扣罰天數(shù)code

private Integer resultNumberCode;

private String rankName;

@OneToOne

@JoinColumn(name = "resultNumberCode", referencedColumnName = "code", insertable = false, updatable = false,

foreignKey = @ForeignKey(value =ConstraintMode.NO_CONSTRAINT ))

private AttendanceRuleTypeItem resultNumber;

@OneToMany(cascade = {CascadeType.PERSIST,CascadeType.REFRESH,CascadeType.MERGE})

@JoinColumn(name = "rule_id",referencedColumnName = "id",foreignKey = @ForeignKey(value =ConstraintMode.NO_CONSTRAINT ))

private List departmentRelation;

@OneToMany(cascade = {CascadeType.PERSIST,/*CascadeType.REMOVE,*/CascadeType.REFRESH})

@JoinColumn(name = "attendance_rule_id",referencedColumnName = "id",foreignKey = @ForeignKey(value =ConstraintMode.NO_CONSTRAINT ))

private List relationAttendanceRanks;

}

public class RelationAttendanceDepartment extends BaseEntity {

@Id

@GeneratedValue(generator = "guid")

@GenericGenerator(strategy = "guid",name = "guid")

private String ruleDeptId;

@Column(name = "rule_id")

private String ruleId;

private Integer departmentId;

public RelationAttendanceDepartment(Integer departmentId) {

this.departmentId = departmentId;

}

public RelationAttendanceDepartment(String ruleId, Integer departmentId) {

this.ruleId = ruleId;

this.departmentId = departmentId;

}

}

3)。確定每張表的關(guān)系之后? 表連接查詢

public PageResultVO> ruleList(QueryPageVO attendance) {

Specification reSpec = (Specification) (root, cq, cb) -> {

Join ruleJoin = root.join("attendanceRules", JoinType.LEFT); //表關(guān)聯(lián)查詢 AttendanceRuleTypeItem 為主表

Join deptJoin = ruleJoin.join("departmentRelation", JoinType.LEFT); //兩張副表之間的關(guān)聯(lián)關(guān)系

Predicate predicate = cb.conjunction();

predicate = cb.and(predicate, cb.equal(deptJoin.get("departmentId"), attendance.getQuery().getId())); //拼接副表中的查詢條件

predicate = cb.and(predicate, cb.equal(root.get("dictionaryCode"), "1002")); //拼接朱表中的查詢條件

predicate = cb.and(predicate, cb.equal(ruleJoin.get("ruleCode"), 2001)); //拼接副表中的查詢條件

cq.where(predicate);

return cq.getRestriction();

};

Page ruleTypeItemPage = ruleTypeItemRepository.findAll(Specification

.where(reSpec)

.and(distinct()), PageRequest.of(attendance.getPages().getPage(), attendance.getPages().getSize()));

List attendanceRuleResultVOS = ruleTypeItemPage.stream().map(r->{

AttendanceRuleResultVO ruleResultVO =new AttendanceRuleResultVO();

ruleResultVO.setTypesName(r.getName());

List ruleVOS = r.getAttendanceRules().stream().map(a-> new RuleVO(a.getId(),getRankName(a),

a.getResultNumber().getName())).collect(Collectors.toList());

ruleResultVO.setRule(ruleVOS);

return ruleResultVO;

}).collect(Collectors.toList());

return new PageResultVO(ruleTypeItemPage.getTotalPages(),(int)ruleTypeItemPage.getTotalElements(),null, attendanceRuleResultVOS);

}

//去重

public Specification distinct() {

return (Root root, CriteriaQuery> criteriaQuery, CriteriaBuilder criteriaBuilder) -> {

criteriaQuery.distinct(true);

return criteriaQuery.getRestriction();

};

}

來(lái)源：https://www.cnblogs.com/xiaoxiaoliu/p/10190065.html

總結(jié)

以上是生活随笔為你收集整理的jpa 去重_spring boot jpa 表关联查询分组 group by 去重的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。