in genie-web/src/integTest/java/com/netflix/genie/web/data/services/impl/jpa/JpaPersistenceServiceImplJobsIntegrationTest.java [823:997]
void canFindJobsByClusterAndCommand() {
final String clusterId = "cluster1";
final String clusterName = "h2query";
final String commandId = "command1";
final String commandName = "spark";
final Pageable page = PageRequest.of(0, 10, Sort.Direction.DESC, "updated");
Page<JobSearchResult> jobs = this.service.findJobs(
null,
null,
null,
null,
null,
null,
UUID.randomUUID().toString(),
null,
null,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(0L);
Assertions.assertThat(jobs.getContent()).isEmpty();
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
null,
null,
null,
UUID.randomUUID().toString(),
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(0L);
Assertions.assertThat(jobs.getContent()).isEmpty();
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
null,
clusterId,
null,
null,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(5L);
Assertions.assertThat(jobs.getContent().size()).isEqualTo(5);
jobs = this.service
.findJobs(
null,
null,
null,
null,
null,
null,
null,
null,
commandId,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(5L);
Assertions.assertThat(jobs.getContent().size()).isEqualTo(5);
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
null,
clusterId,
null,
commandId,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(5L);
Assertions.assertThat(jobs.getContent().size()).isEqualTo(5);
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
clusterName,
clusterId,
commandName,
commandId,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(5L);
Assertions.assertThat(jobs.getContent().size()).isEqualTo(5);
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
UUID.randomUUID().toString(),
clusterId,
commandName,
commandId,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(0L);
Assertions.assertThat(jobs.getContent()).isEmpty();
jobs = this.service.findJobs(
null,
null,
null,
null,
null,
clusterName,
clusterId,
UUID.randomUUID().toString(),
commandId,
null,
null,
null,
null,
null,
null,
page
);
Assertions.assertThat(jobs.getTotalElements()).isEqualTo(0L);
Assertions.assertThat(jobs.getContent()).isEmpty();
}