14 Nisan 2023 Cuma

SpringBatch JobRepositoryFactoryBean Arayüzü

Giriş
Şu satırı dahil ederiz 
import org.springframework.batch.core.repository.support.JobRepositoryFactoryBean;
JobRepository nesnesi yaratır

Örnek
Şöyle yaparız
@Bean
 public JobRepository hazelCastJobRepo(DataSource dataSource, 
  HazelcastTransactionManager hazelcastTransactionManager) {

  JobRepositoryFactoryBean jobRepositoryFactoryBean = new JobRepositoryFactoryBean();
  jobRepositoryFactoryBean.setDataSource(dataSource);
  jobRepositoryFactoryBean.setDatabaseType("POSTGRES");
  jobRepositoryFactoryBean.setTransactionManager(hazelcastTransactionManager);
  return jobRepositoryFactoryBean.getObject();
}
Örnek
Şöyle yaparız
@Autowired
private DataSource dataSource;

@Bean
public JobRepository jobRepository() throws Exception {
  JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
  factory.setDataSource(dataSource);
  factory.setTransactionManager(transactionManager());
  factory.afterPropertiesSet();
  return factory.getObject();
}

@Bean
public PlatformTransactionManager transactionManager() {
  return new DataSourceTransactionManager(dataSource);
}

@Bean
public JobLauncher jobLauncher() throws Exception {
  SimpleJobLauncher launcher = new SimpleJobLauncher();
  launcher.setJobRepository(jobRepository());
  launcher.setTaskExecutor(new SimpleAsyncTaskExecutor());
  launcher.afterPropertiesSet();
  return launcher;
}

Hiç yorum yok:

Yorum Gönder