RESOLVED - BATCH-643: Create database type of 'map' in JobRepositoryFactoryBean

created separate factory bean for repository with map daos
This commit is contained in:
robokaso
2008-06-09 10:51:11 +00:00
parent 7a67464374
commit 9eb654c790
5 changed files with 218 additions and 100 deletions

View File

@@ -105,6 +105,11 @@ public class JobRepositoryFactoryBeanTests extends TestCase {
factory.setTransactionManager(null);
try {
incrementerFactory.isSupportedIncrementerType(null);
incrementerControl.setReturnValue(true);
incrementerFactory.getSupportedIncrementerTypes();
incrementerControl.setReturnValue(new String[0]);
incrementerControl.replay();
factory.afterPropertiesSet();
fail();
}

View File

@@ -0,0 +1,45 @@
package org.springframework.batch.core.repository.support;
import junit.framework.TestCase;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.job.JobSupport;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.repository.JobRestartException;
import org.springframework.batch.support.transaction.ResourcelessTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
/**
* Tests for {@link MapJobRepositoryFactoryBean}.
*/
public class MapJobRepositoryFactoryBeanTests extends TestCase {
private MapJobRepositoryFactoryBean tested = new MapJobRepositoryFactoryBean();
private PlatformTransactionManager transactionManager = new ResourcelessTransactionManager();
protected void setUp() throws Exception {
tested.setTransactionManager(transactionManager);
tested.afterPropertiesSet();
}
/**
* Use the factory to create repository and check the repository remembers
* created executions.
*/
public void testCreateRepository() throws Exception {
JobRepository repository = (JobRepository) tested.getObject();
Job job = new JobSupport("jobName");
JobParameters jobParameters = new JobParameters();
repository.createJobExecution(job, jobParameters);
try {
repository.createJobExecution(job, jobParameters);
}
catch (JobRestartException e) {
// expected
}
}
}