Я создаю пакет, и все работает хорошо Я делаю юнит-тесты, и они тоже хорошо работают. Я пытаюсь выполнить интеграционное тестирование своей партии в соответствии с документацией весенней партии, но я не понимаю своих ошибок.
Вот моя пакетная конфигурация
@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: Error creating bean with name 'a.b.c.batch.TimeoutFormJobTest': Unsatisfied dependency expressed through field 'jobLauncher'; nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type 'org.springframework.batch.test.JobLauncherTestUtils' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {@org.springframework.beans.factory.annotation.Autowired(required=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());
Но я получил
No qualifying bean of type 'a.b.c.batch.config.TimeoutFormJob' available
Я не понимаю ошибку. Я пытался точно следовать весенней документации, и ничего не работает... Я пытался найти решение в stackoverflow, но не нашел примера с аннотацией пакетного объявления.
#### EDIT
Я удаляю все, чтобы начать с нуля
Я просмотрел документ 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());
}
}
Но когда я добавляю @ContextConfiguration, я больше не могу использовать встроенную базу данных... когда я пытаюсь сохраниться, я получаю
Error: no transaction in progress
Вам нужно добавить bean-компонент типа JobLauncherTestUtils в ваш тестовый контекст. Что-то типа:
@Bean
public JobLauncherTestUtils jobLauncherTestUtils() {
return new JobLauncherTestUtils();
}
Для справки: Spring Batch v4.1 представил — новая аннотация под названием @SpringBatchTest, которая автоматически добавляет JobLauncherTestUtils в ваш контекст. Дополнительные сведения см. в разделе Создание класса модульного теста справочной документации.
Надеюсь это поможет.
Новая ошибка означает, что диспетчер транзакций неправильно настроен в Spring Batch. Вам нужно добавить bean-компонент типа BatchConfigurer в свой контекст и переопределить getTransactionManager, чтобы вернуть диспетчер транзакций (см. пример здесь: docs.spring.io/spring-batch/4.1.x/reference/html/…). Обратите внимание, что это работает только для v4.1+.
Я попытался удалить свое сохранение, чтобы не выполнять транзакцию, и просто запустить пакет, но я получил ошибку «Существующая транзакция обнаружена в JobRepository, пожалуйста, исправьте это (например, удалите транзакционную аннотацию) в моей BatchConfiguration. Я создаю репозиторий заданий с автоматически подключенным источник данных, источник данных - это база данных h2, созданная аннотацией JpaDataTest
Когда я создаю бин BatchConfigurer и переопределяю getTransactionManager, я получаю ошибку StackOverFlow.
Извините, я больше не могу следить. В вашем вопросе много деталей и кода. Укажите MCVE, и я постараюсь помочь.
Спасибо, я попробовал, но у меня другая проблема... я отредактировал свой пост