У меня возникла проблема, из-за которой я не могу правильно отфильтровать таблицу, используя querydsl, который имеет обнуляемый внешний ключ.Я сократил свой вариант использования до очень простого сценария.
Скажем, у нас есть 2 сущности, MyEntity и TimeRangeEntity.У моей сущности есть только идентификатор и внешний ключ для TimeRangeEntity.TimeRangeEntity имеет только время начала и окончания и идентификатор.BaseEntity, от которого они оба выходят, имеет только идентификатор, установленный с аннотацией @Id.
@Entity
@Table(name = "TEST_OBJECT")
public class MyEntity extends BaseEntity {
@OneToOne(cascade = { CascadeType.MERGE, CascadeType.PERSIST })
private TimeRangeEntity actionTime;
public TimeRangeEntity getActionTime() {
return actionTime;
}
public void setActionTime(TimeRangeEntity actionTime) {
this.actionTime = actionTime;
}
}
@Entity
@DiscriminatorValue("static")
public class TimeRangeEntity extends BaseEntity {
@Column(name = "START_TIME")
private Instant startTime;
@Column(name = "END_TIME")
private Instant endTime;
public Instant getStartTime() {
return startTime;
}
public void setStartTime(Instant startTime) {
this.startTime = startTime;
}
public Instant getEndTime() {
return endTime;
}
public void setEndTime(Instant endTime) {
this.endTime = endTime;
}
}
Я создал метод по умолчанию в своем репозитории для запуска findAll с предикатом с использованием querydsl для построения синтаксиса SQL
@Repository
public interface MyRepository extends JpaRepository<MyEntity, Long>, QueryDslPredicateExecutor<MyEntity> {
default Page<MyEntity> paginateFilter(PaginationInfo info, String filter){
int page = info.getOffset() > 0 ? info.getOffset() / info.getLimit() : 0;
PageRequest pageRequest = new PageRequest(page, info.getLimit(), new Sort(new Sort.Order(info.getSortDirection(), info.getSortProperty())));
return findAll(createFilterPredicate(filter, myEntity), pageRequest);
}
default Predicate createFilterPredicate(String filter, QMyEntity root){
BooleanBuilder filterBuilder = new BooleanBuilder();
filterBuilder.or(root.id.stringValue().containsIgnoreCase(filter));
filterBuilder.or(root.actionTime.startTime.isNotNull());
return filterBuilder.getValue();
}
}
Я также написал тест, который должен работатьучитывая представленный код.То, что я пытаюсь сделать, это просто фильтр на основе идентификатора.Предостережение заключается в том, что FK для TimeRange может быть нулевым.Я отмечу, что это надуманный пример, чтобы донести свою точку зрения, и решение не может быть «просто принудить FK не иметь значение».
@RunWith(SpringRunner.class)
@DataJpaTest(showSql = false)
@ContextConfiguration(classes = TestConfig.class)
@ActiveProfiles("test")
public class MyRepositoryTest {
@Autowired
private MyRepository sut;
private static final int count = 3;
@Before
public void setup(){
for (int i = 0; i < count; i++){
sut.save(new MyEntity());
}
}
@Test
public void testPaginationWithStringFilter(){
PaginationInfo info = new PaginationInfo();
info.setOffset(0);
info.setLimit(10);
info.setSortDirection(Sort.Direction.ASC);
info.setSortProperty("id");
Page<MyEntity> page = sut.paginateFilter(info, "1");
assertEquals(1, page.getTotalElements());
page = sut.paginateFilter(info, "10");
assertEquals(0, page.getTotalElements());
}
}
Проблема, с которой я сталкиваюсь, заключается вчто он не фильтрует по идентификатору, если FK равен нулю.Все, что я делаю, когда я сохраняю, это установка идентификатора.Я знаю, что проблема в том, что я вижу, как фильтрация работает правильно, когда я закомментирую строку filterBuilder.or(root.actionTime.startTime.isNotNull());, но она не работает, когда у меня это есть.
Это генерирует следующие запросы.Первый - для «работающей» фильтрации, где я могу фильтровать по идентификатору (строка закомментирована).Второй - для фильтрации с включенным actionTime.
select myentity0_.id as id2_38_, myentity0_.action_time_id as action_t3_38_ from test_object myentity0_ where lower(cast(myentity0_.id as char)) like ? escape '!' order by myentity0_.id asc limit ?
select myentity0_.id as id2_38_, myentity0_.action_time_id as action_t3_38_ from test_object myentity0_ cross join time_range_entity timerangee1_ where myentity0_.action_time_id=timerangee1_.id and (lower(cast(myentity0_.id as char)) like ? escape '!' or timerangee1_.start_time is not null) order by myentity0_.id asc limit ?
Глядя на это, я почти уверен, что это из-за перехватчика cross join time_range_entity timerangee1_ where myentity0_.action_time_id=timerangee1_.id, поскольку он проверяет соответствие сущностей, чего они не могут, если внешний ключ диапазона равен нулю.
Я потянул свои волосы, пытаясь заставить эту условную работу, которая только проверяет свойства таблицы временного диапазона, ЕСЛИ FK не нуль, но я не могу найти способ, используя querydsl.Любые советы / рекомендации / фрагменты кода будут звездными.
EDIT : просто переводя на прямой SQL, я получил этот запрос для сгенерированного JPQL (переведенный в этот пример, поскольку я использовал его с реальными данными):
select * from test_object cross join time_range range where test_object.action_time_id=range.id and lower(cast(test_object.id as char)) like '%1%';
С нулевым FK, который не вернул строку, как ожидалось.Смена этого соединения на левое с перекрестного соединения сработало должным образом.
select * from test_object left join time_range on test_object.action_time_id=time_range.id where lower(cast(test_object.id as char)) like '%1%';
При этом, есть ли способ указать левое соединение с исполнителем предиката querydsl?Кажется, это решение моей проблемы!