Complete - task 89: Resurrect Quartz sample

Add unit test for JobLauncherDetails

spring-batch-samples/src/test/java/org/springframework/batch/sample/quartz/JobLauncherDetailsTests.java

@@ -0,0 +1,162 @@
+/*
+ * Copyright 2006-2007 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.batch.sample.quartz;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+import junit.framework.TestCase;
+
+import org.easymock.MockControl;
+import org.quartz.Job;
+import org.quartz.JobDetail;
+import org.quartz.JobExecutionContext;
+import org.quartz.Scheduler;
+import org.quartz.SimpleTrigger;
+import org.quartz.spi.TriggerFiredBundle;
+import org.springframework.batch.core.JobExecution;
+import org.springframework.batch.core.JobParameters;
+import org.springframework.batch.core.JobSupport;
+import org.springframework.batch.core.configuration.JobLocator;
+import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
+import org.springframework.batch.core.repository.JobRestartException;
+import org.springframework.batch.core.repository.NoSuchJobException;
+import org.springframework.batch.execution.launch.JobLauncher;
+
+/**
+ * @author Dave Syer
+ * 
+ */
+public class JobLauncherDetailsTests extends TestCase {
+
+	private JobLauncherDetails details = new JobLauncherDetails();
+	
+	private TriggerFiredBundle firedBundle;
+	
+	private List list = new ArrayList();
+	
+	protected void setUp() throws Exception {
+		details.setJobLauncher(new JobLauncher() {
+			public JobExecution run(org.springframework.batch.core.Job job, JobParameters jobParameters)
+					throws JobExecutionAlreadyRunningException, JobRestartException {
+				list.add(jobParameters);
+				return null;
+			}
+		});
+		details.setJobLocator(new JobLocator() {
+			public org.springframework.batch.core.Job getJob(String name) throws NoSuchJobException {
+				list.add(name);
+				return new JobSupport("foo");
+			}
+		});
+	}
+
+	/**
+	 * @return 
+	 * 
+	 */
+	private JobExecutionContext createContext(JobDetail jobDetail) {
+		firedBundle = new TriggerFiredBundle(jobDetail, new SimpleTrigger(), null, false, new Date(), new Date(), new Date(), new Date());
+		return new StubJobExecutionContext();
+	}
+
+	/**
+	 * Test method for
+	 * {@link org.springframework.batch.sample.quartz.JobLauncherDetails#executeInternal(org.quartz.JobExecutionContext)}.
+	 */
+	public void testExecuteWithNoJobParameters() {
+		JobDetail jobDetail = new JobDetail();
+		JobExecutionContext context = createContext(jobDetail);
+		details.executeInternal(context);
+		assertEquals(2, list.size());
+		JobParameters parameters = (JobParameters) list.get(1);
+		assertEquals(0, parameters.getParameters().size());
+	}
+
+	/**
+	 * Test method for
+	 * {@link org.springframework.batch.sample.quartz.JobLauncherDetails#executeInternal(org.quartz.JobExecutionContext)}.
+	 */
+	public void testExecuteWithJobName() {
+		JobDetail jobDetail = new JobDetail();
+		jobDetail.getJobDataMap().put(JobLauncherDetails.JOB_NAME, "FOO");
+		JobExecutionContext context = createContext(jobDetail);
+		details.executeInternal(context);
+		assertEquals(2, list.size());
+		assertEquals("FOO", list.get(0));
+	}
+
+	/**
+	 * Test method for
+	 * {@link org.springframework.batch.sample.quartz.JobLauncherDetails#executeInternal(org.quartz.JobExecutionContext)}.
+	 */
+	public void testExecuteWithSomeJobParameters() {
+		JobDetail jobDetail = new JobDetail();
+		jobDetail.getJobDataMap().put("foo", "bar");
+		JobExecutionContext context = createContext(jobDetail);
+		details.executeInternal(context);
+		assertEquals(2, list.size());
+		JobParameters parameters = (JobParameters) list.get(1);
+		assertEquals(1, parameters.getParameters().size());
+	}
+
+	/**
+	 * Test method for
+	 * {@link org.springframework.batch.sample.quartz.JobLauncherDetails#executeInternal(org.quartz.JobExecutionContext)}.
+	 */
+	public void testExecuteWithJobNameAndParameters() {
+		JobDetail jobDetail = new JobDetail();
+		jobDetail.getJobDataMap().put(JobLauncherDetails.JOB_NAME, "FOO");
+		jobDetail.getJobDataMap().put("foo", "bar");
+		JobExecutionContext context = createContext(jobDetail);
+		details.executeInternal(context);
+		assertEquals(2, list.size());
+		assertEquals("FOO", list.get(0));
+		JobParameters parameters = (JobParameters) list.get(1);
+		assertEquals(1, parameters.getParameters().size());
+	}
+
+	/**
+	 * Test method for
+	 * {@link org.springframework.batch.sample.quartz.JobLauncherDetails#executeInternal(org.quartz.JobExecutionContext)}.
+	 */
+	public void testExecuteWithJobNameAndComplexParameters() {
+		JobDetail jobDetail = new JobDetail();
+		jobDetail.getJobDataMap().put(JobLauncherDetails.JOB_NAME, "FOO");
+		jobDetail.getJobDataMap().put("foo", this);
+		JobExecutionContext context = createContext(jobDetail);
+		details.executeInternal(context);
+		assertEquals(2, list.size());
+		assertEquals("FOO", list.get(0));
+		JobParameters parameters = (JobParameters) list.get(1);
+		// Silently ignore parameters that are not simple types
+		assertEquals(0, parameters.getParameters().size());
+	}
+
+	private final class StubJobExecutionContext extends JobExecutionContext {
+		/**
+		 * @param scheduler
+		 * @param firedBundle
+		 * @param job
+		 */
+		private StubJobExecutionContext() {
+			super((Scheduler) MockControl.createNiceControl(Scheduler.class).getMock(), firedBundle, (Job) MockControl.createNiceControl(Job.class)
+					.getMock());
+		}
+	}
+
+}