@Test(dependsOnMethods = {"testUpdate"}) public void testQueryByJobName() throws IOException { JobExecutionQuery queryByJobName = new JobExecutionQuery(); queryByJobName.setIdType(QueryIdTypeEnum.JOB_NAME); queryByJobName.setId(JobExecutionQuery.Id.create(this.expectedJobExecutionInfos.get(0).getJobName())); List<JobExecutionInfo> result = this.jobHistoryStore.get(queryByJobName); Assert.assertEquals(result.size(), 1); JobExecutionInfo actual = result.get(0); JobExecutionInfo expected = this.expectedJobExecutionInfos.get(0); assertJobExecution(actual, expected); }
@Override public synchronized List<JobExecutionInfo> get(JobExecutionQuery query) throws IOException { return this.versionedStore.get(query); }
DatabaseJobHistoryStore implements JobHistoryStore { @Override public synchronized List<JobExecutionInfo> get(JobExecutionQuery query) throws IOException { return this.versionedStore.get(query); } }
DatabaseJobHistoryStore implements JobHistoryStore { @Override public synchronized List<JobExecutionInfo> get(JobExecutionQuery query) throws IOException { return this.versionedStore.get(query); } @Inject  DatabaseJobHistoryStore(DataSource dataSource); }
DatabaseJobHistoryStore implements JobHistoryStore { @Override public synchronized List<JobExecutionInfo> get(JobExecutionQuery query) throws IOException { return this.versionedStore.get(query); } @Inject  DatabaseJobHistoryStore(DataSource dataSource); @Override synchronized void put(JobExecutionInfo jobExecutionInfo); @Override synchronized List<JobExecutionInfo> get(JobExecutionQuery query); @Override void close(); }
DatabaseJobHistoryStore implements JobHistoryStore { @Override public synchronized List<JobExecutionInfo> get(JobExecutionQuery query) throws IOException { return this.versionedStore.get(query); } @Inject  DatabaseJobHistoryStore(DataSource dataSource); @Override synchronized void put(JobExecutionInfo jobExecutionInfo); @Override synchronized List<JobExecutionInfo> get(JobExecutionQuery query); @Override void close();  }