在关联实体内使用规格弹簧数据 Jpa 进行多列搜索



我正在回答这个问题 对单个表的日期、整数和字符串数据类型字段执行多列搜索? 并且此方法必须在 Java 8 中返回类型为 Specification 的结果。

实际上,我想在关联实体内进行搜索,以及全局搜索的一部分。使用JPA 2 Specifications API可以吗?

我已经EmployeeDepartment@OneToMany bi-directional关系。

员工.java

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Entity
public class Employee implements Serializable {
    private static final long serialVersionUID = 1L;
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "EMPLOYEE_ID")
    private Long employeeId;
    @Column(name = "FIRST_NAME")
    private String firstName;
    @Column(name = "LAST_NAME")
    private String lastName;
    @Column(name = "EMAIL_ID")
    private String email;
    @Column(name = "STATUS")
    private String status;
    @Column(name = "BIRTH_DATE")
    private LocalDate birthDate;
    @Column(name = "PROJECT_ASSOCIATION")
    private Integer projectAssociation;
    @Column(name = "GOAL_COUNT")
    private Integer goalCnt;
    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumn(name = "DEPT_ID", nullable = false)
    @JsonIgnore
    private Department department;
}

部门.java

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Entity
public class Department implements Serializable {
    private static final long serialVersionUID = 1L;
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "DEPT_ID")
    private Long departmentId;
    @Column(name = "DEPT_NAME")
    private String departmentName;
    @Column(name = "DEPT_CODE")
    private String departmentCode;
    @OneToMany(fetch = FetchType.LAZY, mappedBy = "department")
    @JsonIgnore
    private Set<Employee> employees;
}

我保存了如下所示的数据。我的分页应用程序.java

@SpringBootApplication
public class MyPaginationApplication implements CommandLineRunner {
    public static void main(String[] args) {
        SpringApplication.run(MyPaginationApplication.class, args);
    }
    @Autowired
    private EmployeeRepository employeeRepository;
    @Autowired
    private DepartmentRepository departmentRepository;
    @Override
    public void run(String... args) throws Exception {
        saveData();
    }
    private void saveData() {
        Department department1 = Department.builder()
                .departmentCode("AD")
                .departmentName("Boot Depart")
                .build();
        departmentRepository.save(department1);
        Employee employee = Employee.builder().firstName("John").lastName("Doe").email("john.doe@gmail.com")
                .birthDate(LocalDate.now())
                .goalCnt(1)
                .projectAssociation(2)
                .department(department1)
                .build();
        Employee employee2 = Employee.builder().firstName("Neha").lastName("Narkhede").email("neha.narkhede@gmail.com")
                .birthDate(LocalDate.now())
                .projectAssociation(4)
                .department(department1)
                .goalCnt(2)
                .build();
        Employee employee3 = Employee.builder().firstName("John").lastName("Kerr").email("john.kerr@gmail.com")
                .birthDate(LocalDate.now())
                .projectAssociation(5)
                .department(department1)
                .goalCnt(4)
                .build();
        employeeRepository.saveAll(Arrays.asList(employee, employee2, employee3));
    }
}

员工控制.java

@GetMapping("/employees/{searchValue}")
    public ResponseEntity<List<Employee>> findEmployees(@PathVariable("searchValue") String searchValue) {
        List<Employee> employees = employeeService.searchGlobally(searchValue);
        return new ResponseEntity<>(employees, HttpStatus.OK);
    }

员工规格.java

public class EmployeeSpecification {
    public static Specification<Employee> textInAllColumns(Object value) {
        return (root, query, builder) -> builder.or(root.getModel().getDeclaredSingularAttributes().stream()
                .filter(attr -> attr.getJavaType().equals(value.getClass()))
                .map(attr -> map(value, root, builder, attr))
                .toArray(Predicate[]::new));
    }
    private static Object map(Object value, Root<?> root, CriteriaBuilder builder, SingularAttribute<?, ?> a) {
        switch (value.getClass().getSimpleName()) {
            case "String":
                return builder.like(root.get(a.getName()), getString((String) value));
            case "Integer":
                return builder.equal(root.get(a.getName()), value);
            case "LocalDate":
                return builder.equal(root.get(a.getName()), value);//date mapping
            default:
                return null;
        }
    }
    private static String getString(String text) {
        if (!text.contains("%")) {
            text = "%" + text + "%";
        }
        return text;
    }
}

当我点击/employees/{searchValue}时,我希望搜索与Employee表一起Department表中进行(可能正在使用类似Joins(。这可能吗?如果是,我们该怎么做?

或:这会是像这里一样的好方法吗?从使用@Query获得参考

@Query("SELECT t FROM Todo t WHERE " +
            "LOWER(t.title) LIKE LOWER(CONCAT('%',:searchTerm, '%')) OR " +
            "LOWER(t.description) LIKE LOWER(CONCAT('%',:searchTerm, '%'))")
    List<Todo> findBySearchTerm(@Param("searchTerm") String searchTerm);

有什么指示吗?

如果你看看我的帖子,实际上我有一个加入的解决方案

@Override
public Specification<User> getFilter(UserListRequest request) {
    return (root, query, cb) -> {
        query.distinct(true); //Important because of the join in the addressAttribute specifications
        return where(
            where(firstNameContains(request.search))
                .or(lastNameContains(request.search))
                .or(emailContains(request.search))
        )
            .and(streetContains(request.street))
            .and(cityContains(request.city))
            .toPredicate(root, query, cb);
    };
}
private Specification<User> firstNameContains(String firstName) {
    return userAttributeContains("firstName", firstName);
}
private Specification<User> lastNameContains(String lastName) {
    return userAttributeContains("lastName", lastName);
}
private Specification<User> emailContains(String email) {
    return userAttributeContains("email", email);
}
private Specification<User> userAttributeContains(String attribute, String value) {
    return (root, query, cb) -> {
        if(value == null) {
            return null;
        }
        return cb.like(
            cb.lower(root.get(attribute)),
            containsLowerCase(value)
        );
    };
}
private Specification<User> cityContains(String city) {
    return addressAttributeContains("city", city);
}
private Specification<User> streetContains(String street) {
    return addressAttributeContains("street", street);
}
private Specification<User> addressAttributeContains(String attribute, String value) {
    return (root, query, cb) -> {
        if(value == null) {
            return null;
        }
        ListJoin<User, Address> addresses = root.joinList("addresses", JoinType.INNER);
        return cb.like(
            cb.lower(addresses.get(attribute)),
            containsLowerCase(value)
        );
    };
}
private String containsLowerCase(String searchField) {
    return "%" + searchField.toLowerCase() + "%";
}

在这里,您可以看到我如何按地址列(城市和街道(搜索用户。

编辑:您也不能动态地使用@Query注释(您可以动态地插入参数值,但不能插入参数。这就是Specificaion很方便的地方(

EDIT2:我知道这不是2.x.x Spring版本,而是1.5.x,但连接的想法是一样的。

相关内容

  • 没有找到相关文章

最新更新