Я создаю партию и все работает хорошо. Я провожу несколько юнит-тестов, и это тоже хорошо работает. Я пытаюсь провести интеграционное тестирование своей партии, следуя документации по весенней партии, но я не понимаю своих ошибок.
Вот мой пакетный конфиг
@Configuration
@EnableBatchProcessing
@EnableScheduling
@EnableTransactionManagement
@PropertySource(value="/batch.properties", ignoreResourceNotFound = false)
public class BatchConfiguration {
@Autowired
DataSource dataSource;
@Autowired
PlatformTransactionManager transactionManager;
@Bean
public JobRepository jobRepository() throws Exception {
JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
factory.setDataSource(dataSource);
factory.setTransactionManager(transactionManager);
factory.afterPropertiesSet();
return (JobRepository) factory.getObject();
}
@Bean
public SimpleJobLauncher jobLauncher(JobRepository jobRepository) {
SimpleJobLauncher launcher = new SimpleJobLauncher();
launcher.setJobRepository(jobRepository);
return launcher;
}
}
пример одного моего пакета
@Component
@AutomaticLogging
public class TimeoutFormJob {
@Autowired
public JobBuilderFactory jobBuilderFactory;
@Autowired
public StepBuilderFactory stepBuilderFactory;
@Autowired
private SimpleJobLauncher jobLauncher;
@Value("${batch.timeoutForm.chunk}")
int chunk;
@Autowired
TimeoutFormReader reader;
@Autowired
TimeoutFormProcessor processor;
@Autowired
public TimeoutFormWriter writer;
@Bean
public Step createStep() {
return stepBuilderFactory.get("timeoutFormStep").<MyFormEntity, MyFormEntity>chunk(chunk).reader(reader).processor(processor).writer(writer).build();
}
@Bean
public Job createJob() {
return jobBuilderFactory.get("timeoutFormJob").incrementer(new RunIdIncrementer()).flow(createStep()).end().build();
}
@Scheduled(cron = "${batch.timeoutForm.cron}")
public void perform() throws Exception {
JobParameters param = new JobParametersBuilder().addString("JobID", String.valueOf(System.currentTimeMillis())).toJobParameters();
jobLauncher.run(createJob(), param);
}
}
Конфигурация моего testConfiguration
@SpringBootConfiguration
@EnableAutoConfiguration
public class TestConfig {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
и теста
@RunWith(SpringJUnit4ClassRunner.class)
@DataJpaTest
public class TimeoutFormJobTest {
@Autowired
private JobLauncherTestUtils jobLauncher;
@Test
public void testIntegration_batch() throws Exception {
assertEquals(1, myService.findFormNotfinish().size());
jobLauncher.launchJob();
assertEquals(0, myService.findFormNotfinish().size());
}
}
Я получил ошибку
org.springframework.beans.factory.UnsatisfiedDependencyException: Ошибка создания бина с именем 'abcbatch.TimeoutFormJobTest': неудовлетворительная зависимость, выраженная через поле'jobLauncher';вложенное исключение: org.springframework.beans.factory.NoSuchBeanDefinitionException: нет доступного квалифицирующего компонента типа 'org.springframework.batch.test.JobLauncherTestUtils': ожидается как минимум 1 компонент, который квалифицируется как кандидат для автоматического подключения.Аннотации зависимостей: {@ org.springframework.beans.factory.annotation.Autowired (обязательно = true)}
Я попытался добавить в ConfigTest
@Autowired
DataSource dataSource;
@Autowired
PlatformTransactionManager transactionManager;
@Autowired
SimpleJobLauncher jobLaucher;
@Autowired
JobRepository jobRepository;
@Autowired
@Qualifier("timeoutFormJob")
Job job;
@Bean
public SimpleJobLauncher jobLauncher(JobRepository jobRepository) {
SimpleJobLauncher launcher = new SimpleJobLauncher();
launcher.setJobRepository(jobRepository);
return launcher;
}
@Bean
public JobRepository jobRepository() throws Exception {
JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
factory.setDataSource(dataSource);
factory.setTransactionManager(transactionManager);
factory.afterPropertiesSet();
return (JobRepository) factory.getObject();
}
@Bean
public JobLauncherTestUtils getJobLauncherTestUtils(){
JobLauncherTestUtils jobLauncherTestUtils = new JobLauncherTestUtils();
jobLauncherTestUtils.setJob(job);
jobLauncherTestUtils.setJobRepository(jobRepository);
jobLauncherTestUtils.setJobLauncher(jobLaucher);
return jobLauncherTestUtils;
}
и получилошибка
>***************************
>APPLICATION FAILED TO START
>***************************
>Description:
>
>Field job in a.b.c.Application >required a bean of type 'org.springframework.batch.core.Job' that could not be >found.
>
>Action:
>Consider defining a bean of type 'org.springframework.batch.core.Job' in your >configuration
Я пытался изменить
@Qualifier("timeoutFormJob)
Job job
на
@Autowired
TimeoutFormJob jobConfig;
...
jobLauncherTestUtils.setJob(jobconfig.createJob());
Но я получил
Нет подходящего компонента типа abcbatch.config.TimeoutFormJob
Я не понимаю ошибку.Я пытался точно следовать весенней документации, и ничего не работает ... Я пытался найти решение для stackoverflow, но я не нашел пример с аннотацией пакетного объявления
#### EDIT
Iудалить все, чтобы начать с нуля
Я посмотрел документ SpringBatchTest и попробовал id, но я получил несколько других ошибок, я должен добавить @EnableAutoConfiguration (даже если я уже получил его в ConfigTest)
И яувидел в весеннем документе @ContextConfiguration, чтобы добавить задание. Я должен добавить все устройства чтения / обработки / записи / служб / моих преобразователей, используемые в пакете ...
теперь это выглядит как
@RunWith(SpringJUnit4ClassRunner.class)
@DataJpaTest
@Sql({"classpath:org/springframework/batch/core/schema-drop-h2.sql", "classpath:org/springframework/batch/core/schema-h2.sql"})
@SpringBatchTest
@ContextConfiguration(classes = {BatchConfiguration.class, TimeoutFormJob.class, Reader.class, Processor.class, Writer.class, ServiceA.class, MapperA.class, HelperMapper.class, ServiceB.class})
@EnableAutoConfiguration
public class TestBatch {
@Autowired
private JobLauncherTestUtils jobLauncherTestUtils;
@Autowired
private TestEntityManager entityManager;
@Autowired
private MyRepo myRepo;
@Test
public void myBatchTest() {
assertEquals(0, myRepo.findAll().size());
entityManager.persist(new MyEntity());
assertEquals(1, myRepo.findAll().size());
JobExecution jobExecution = jobLauncherTestUtils.launchJob();
Assert.assertEquals("COMPLETED", jobExecution.getExitStatus().getExitCode());
assertEquals(0, myRepo.findAll().size());
}
}
Но когда addind @ContextConfiguration я больше не могу использовать встроенную базу данных ... когда я пытаюсь сохранить, я получаю
Ошибка: транзакция не выполняется