Блог

Я запрашиваю строки из базы данных, используя шаблон JDBC, и для каждой строки я программно запускаю задание, которое выполняет шаг на основе фрагментов. Я обеспокоен тем, что каждый вызов задания создаст новый набор пула подключений. Создает ли он новый набор пулов подключений или просто подключается к текущему пулу?

Основной метод (запускает задание для каждого хранилища):

 public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException,
    JobInstanceAlreadyCompleteException, JobParametersInvalidException {

SpringApplication app = new SpringApplication(MainApp.class);
ConfigurableApplicationContext ctx = app.run(args);

JobLauncher jobLauncher = ctx.getBean(JobLauncher.class);
Job job = ctx.getBean("customerJob", Job.class);

storeRepository = ctx.getBean(StoreRepository.class);
customerRepository = ctx.getBean(CustomerRepository.class);

List<Store> stores = storeRepository.findAll(); 


for (Store store: stores) {
    int customerCount = customerRepository.countCustomer(store.getStoreID(), reportDate);
    System.out.println("Count: "  customerCount);
    if (customerCount != 0) {
    JobParameters jobParameters = new JobParametersBuilder()
        .addString("reportDate", reportDate)
        .addString("ID", store.getStoreID())
        .toJobParameters();
    JobExecution jobExecution = jobLauncher.run(job, jobParameters);
    BatchStatus batchStatus = jobExecution.getStatus();
    System.out.println("Batch Status "   batchStatus);
    }
    

}
}
  

Конфигурация пакетного задания:

 @Bean
public Step generateReport() throws Exception {
return this.stepBuilderFactory
    .get("generateReport")
    .<Customer, Customer>chunk(10)
    .reader(itemReader(null, null))
    .writer(itemWriter())
    .build();
}

@Bean
public Job customerReportJob() throws Exception {
return this.jobBuilderFactory
    .get("customerReportJob")
    .start(generateReport())
    .build();
}
  

Репозиторий:

 @Repository
public class CustomerRepositoryImpl implements CustomerRepository {

private final JdbcTemplate jdbcTemplate;

@Autowired
    public CustomerRepositoryImpl(JdbcTemplate jdbcTemplate) {
    this.jdbcTemplate = jdbcTemplate;
}

@Override
public List<Customer> findByIDAndReportDate(String ID, String reportDate) {
String sqlQuery = "SELECT * "    
    "FROM CUSTOMER_REPORT "  
    "WHERE ID = "    ID   "  "  
    "AND TO_CHAR(REPORT_DATE, 'MM/DD/YYYY') = '"   reportDate   "'";

return jdbcTemplate.query(sqlQuery, 
    (rs, rowNum) -> 
    new Customer(mapper(rs)));
}
}
  

application.properties:

 # Oracle settings
spring.datasource.url=##
spring.datasource.username=##
spring.datasource.password=##
spring.datasource.driver-class-name=##

# Hikari
spring.datasource.hikari.maximum-pool-size=5
spring.datasource.hikari.minimumIdle=5
spring.datasource.hikari.idleTimeout=30000

logging.level.com.zaxxer.hikari=debug

# Spring Batch
spring.batch.job.enabled=false
  

В соответствии с вашей конфигурацией ваши задания будут использовать один и тот же пул источников данных / подключений. Вы должны быть в состоянии подтвердить это, просмотрев журналы.