QueryDSL Predicate — это мощный и чрезвычайно гибкий инструмент для работы с БД и просто подарок для Java-разработчиков, которые не очень хорошо разбираются в SQL (или совсем не разбираются), поскольку предикаты позволяют работать с БД при помощи привычного объектного представления сущностных зависимостей.
Предикаты позволяют работать с элементами базы данных как с обычными полями класса. При сборке gradle создаёт специальные классы зависимостей, через которые и происходит поиск нужных записей в БД.
Если Вы уже успешно работаете с QueryDSL и у Вас есть конструктивные замечания и предложения по статье — я буду рад их прочитать и, при необходимости, дополнить ими статью.
В конце статьи есть ссылка на репозиторий, из которого Вы сможете клонировать (или даже форкнуть) пример. Честно предупреждаю — я его не тестировал на базе, но если у Вас он поднимется (а он поднимется), то точно будет работать. Даже тесты начал писать, но, я уверен, тесты Вы напишете не хуже, а сегодня хотелось бы разобрать тему статьи — предикаты.
Мы создадим сущности, с которыми будем работать. Пусть это будут User с полями name и age и UserGroup, которые будут наследоваться от AbstractEntity. Создадим между ними связь один-ко-многим — в одной группе может находиться много юзеров. Предикаты будем разбирать только на User.
AbstractEntity:
package entity;
import javax.persistence.*;
@MappedSuperclass
public class AbstractEntity {
private Long id;
@Id
@Column(name = "id")
@SequenceGenerator(name = "general_seq", sequenceName = "generalSequenceGenerator")
@GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "general_seq")
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
AbstractEntity that = (AbstractEntity) o;
return id != null ? id.equals(that.id) : that.id == null;
}
@Override
public int hashCode() {
return id != null ? id.hashCode() : 0;
}
}
package entity;
import javax.persistence.*;
@Entity
@Table(name = "users")
public class User extends AbstractEntity {
private String name;
private Integer age;
private UserGroup group;
@Column(name = "name")
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Column(name = "age")
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
@ManyToOne(fetch = FetchType.LAZY)
@JoinColumn(name = "category")
public UserGroup getGroup() {
return group;
}
public void setGroup(UserGroup group) {
this.group = group;
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
if (!super.equals(o)) return false;
User user = (User) o;
if (name != null ? !name.equals(user.name) : user.name != null) return false;
if (age != null ? !age.equals(user.age) : user.age != null) return false;
return group != null ? group.equals(user.group) : user.group == null;
}
@Override
public int hashCode() {
int result = super.hashCode();
result = 31 * result + (name != null ? name.hashCode() : 0);
result = 31 * result + (age != null ? age.hashCode() : 0);
result = 31 * result + (group != null ? group.hashCode() : 0);
return result;
}
}
package entity;
import javax.persistence.*;
import java.util.List;
@Entity
@Table(name = "user_groups")
public class UserGroup extends AbstractEntity {
private String name;
private List<User> users;
@Column(name = "name")
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@OneToMany(cascade = CascadeType.ALL, fetch = FetchType.LAZY, mappedBy = "group")
public List<User> getUsers() {
return users;
}
public void setUsers(List<User> users) {
this.users = users;
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
if (!super.equals(o)) return false;
UserGroup userGroup = (UserGroup) o;
if (name != null ? !name.equals(userGroup.name) : userGroup.name != null) return false;
return users != null ? users.equals(userGroup.users) : userGroup.users == null;
}
@Override
public int hashCode() {
int result = super.hashCode();
result = 31 * result + (name != null ? name.hashCode() : 0);
result = 31 * result + (users != null ? users.hashCode() : 0);
return result;
}
}
@NoRepositoryBean
public interface ExCustomRepository<T extends AbstractEntity, P extends EntityPathBase<T>, ID extends Serializable>
extends JpaRepository<T, ID>, QuerydslPredicateExecutor<T>, QuerydslBinderCustomizer<P> {
@Override
default void customize(QuerydslBindings bindings, P root) {
}
}
@Repository
public interface UserRepository extends ExCustomRepository<User, QUser, Long> {
}
@Service
public class UserService {
@Autowired
UserRepository repository;
//ищем по возрасту, исключая границы
public List<User> getByAgeExcluding(Integer minAge, Integer maxAge) {
}
//ищем по возрасту, включая границы
public List<User> getByAgeIncluding(Integer minAge, Integer maxAge) {
}
//ищем по ID
public User getById(Long id) {
}
//ищем по группам
public List<User> getByGroups(List<UserGroup> groups) {
}
//ищем по имени
public List<User> get(String name) {
}
}
SELECT u FROM User u WHERE u.age BETWEEN :minAge AND :maxAge
public List<User> getByAgeExcluding(Integer minAge, Integer maxAge) {
return Lists.newArrayList(repository.findAll(QUser.user.age.between(minAge, maxAge)));
}
public List<User> getByAgeIncluding(Integer minAge, Integer maxAge) {
return Lists.newArrayList(repository.findAll(QUser.user.age.goe(minAge).and(QUser.user.age.loe(maxAge))));
}
public User getById(Long id) {
return repository.findOne(QUser.user.id.eq(id)).orElse(new User());
}
public List<User> getByGroups(List<UserGroup> groups) {
return Lists.newArrayList(repository.findAll(QUser.user.group.in(groups)));
}
public List<User> get(String name) {
return Lists.newArrayList(repository.findAll(QUser.user.name.ne(name)));
}
К сожалению, не доступен сервер mySQL