Add support for wildcard searching/listing of job executions by name

Checkstyle and testcases

Author: sylank

spring-cloud-dataflow-server-core/src/main/java/org/springframework/cloud/dataflow/server/batch/JdbcSearchableJobExecutionDao.java

@@ -64,7 +64,7 @@ public class JdbcSearchableJobExecutionDao extends JdbcJobExecutionDao implement
 			+ " from %PREFIX%JOB_EXECUTION E, %PREFIX%JOB_INSTANCE I "
 			+ "where E.JOB_INSTANCE_ID=I.JOB_INSTANCE_ID and E.END_TIME is NULL";
 
-	private static final String NAME_FILTER = "I.JOB_NAME=?";
+	private static final String NAME_FILTER = "I.JOB_NAME LIKE ?";
 
 	private PagingQueryProvider allExecutionsPagingQueryProvider;
 

spring-cloud-dataflow-server-core/src/main/java/org/springframework/cloud/dataflow/server/batch/JdbcSearchableJobInstanceDao.java

@@ -26,7 +26,7 @@
 public class JdbcSearchableJobInstanceDao extends JdbcJobInstanceDao implements SearchableJobInstanceDao {
 
 	private static final String GET_COUNT_BY_JOB_NAME = "SELECT COUNT(1) from %PREFIX%JOB_INSTANCE "
-			+ "where JOB_NAME=?";
+			+ "where JOB_NAME LIKE ?";
 
 	/**
 	 * @see JdbcJobExecutionDao#afterPropertiesSet()

spring-cloud-dataflow-server-core/src/main/java/org/springframework/cloud/dataflow/server/batch/SimpleJobService.java

@@ -471,8 +471,7 @@ public Collection<JobExecution> listJobExecutionsForJob(String jobName, int star
 	public Collection<JobExecutionWithStepCount> listJobExecutionsForJobWithStepCount(String jobName, int start, int count)
 			throws NoSuchJobException {
 		checkJobExists(jobName);
-		List<JobExecutionWithStepCount> jobExecutions = jobExecutionDao.getJobExecutionsWithStepCount(jobName, start, count);
-		return jobExecutions;
+		return jobExecutionDao.getJobExecutionsWithStepCount(jobName, start, count);
 	}
 
 	@Override
@@ -530,14 +529,18 @@ public Collection<String> getStepNamesForJob(String jobName) throws NoSuchJobExc
 	}
 
 	private void checkJobExists(String jobName) throws NoSuchJobException {
-		if(getJsrJobNames().contains(jobName) ||
-				jobLocator.getJobNames().contains(jobName) ||
-				jobInstanceDao.countJobInstances(jobName) > 0) {
+		if (collectionContainsJobName(jobName, getJsrJobNames()) ||
+			collectionContainsJobName(jobName, jobLocator.getJobNames()) ||
+			jobInstanceDao.countJobInstances(jobName) > 0) {
 			return;
 		}
 		throw new NoSuchJobException("No Job with that name either current or historic: [" + jobName + "]");
 	}
 
+	private boolean collectionContainsJobName(String jobName, Collection<String> collection) {
+		return collection.stream().anyMatch(e -> e.contains(jobName));
+	}
+
 	/**
 	 * Stop all the active jobs and wait for them (up to a time out) to finish
 	 * processing.

spring-cloud-dataflow-server-core/src/main/java/org/springframework/cloud/dataflow/server/controller/JobExecutionController.java

@@ -96,7 +96,7 @@ public PagedModel<JobExecutionResource> list(Pageable pageable,
 	/**
 	 * Retrieve all task job executions with the task name specified
 	 *
-	 * @param jobName name of the job
+	 * @param jobName name of the job. SQL server specific wildcards are enabled (eg.: myJob%, m_Job, ...)
 	 * @param pageable page-able collection of {@code TaskJobExecution}s.
 	 * @param assembler for the {@link TaskJobExecution}s
 	 * @return list task/job executions with the specified jobName.

spring-cloud-dataflow-server-core/src/test/java/org/springframework/cloud/dataflow/server/controller/JobExecutionControllerTests.java

@@ -210,6 +210,25 @@ public void testGetExecutionsByNameNotFound() throws Exception {
 				.andExpect(status().isNotFound());
 	}
 
+	@Test
+	public void testWildcardMatchMultipleResult() throws Exception {
+		mockMvc.perform(get("/jobs/executions/")
+				.param("name", JobExecutionUtils.BASE_JOB_NAME + "_FOO_ST%").accept(MediaType.APPLICATION_JSON))
+				.andExpect(status().isOk())
+				.andExpect(jsonPath("$.content[0].jobExecution.jobInstance.jobName", is(JobExecutionUtils.JOB_NAME_STOPPED)))
+				.andExpect(jsonPath("$.content[1].jobExecution.jobInstance.jobName", is(JobExecutionUtils.JOB_NAME_STARTED)))
+				.andExpect(jsonPath("$.content", hasSize(2)));
+	}
+
+	@Test
+	public void testWildcardMatchSingleResult() throws Exception {
+		mockMvc.perform(get("/jobs/executions/")
+				.param("name", "m_Job_ORIG").accept(MediaType.APPLICATION_JSON))
+				.andExpect(status().isOk())
+				.andExpect(jsonPath("$.content[0].jobExecution.jobInstance.jobName", is(JobExecutionUtils.JOB_NAME_ORIG)))
+				.andExpect(jsonPath("$.content", hasSize(1)));
+	}
+
 	private void createDirtyJob() {
 		JobInstance instance = jobRepository.createJobInstance(JobExecutionUtils.BASE_JOB_NAME + "_NO_TASK", new JobParameters());
 		JobExecution jobExecution = jobRepository.createJobExecution(