每个Spring Batch作业调用都会打开一个新的数据库连接池吗？

huangapple
go评论124阅读模式
英文:

Does every job call in Spring Batch open a new database connection pool?

问题

以下是您提供的内容的翻译部分：

主要方法（为每个商店运行作业）：

  1. public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException,
  2.     JobInstanceAlreadyCompleteException, JobParametersInvalidException {
  4.     SpringApplication app = new SpringApplication(MainApp.class);
  5.     ConfigurableApplicationContext ctx = app.run(args);
  7.     JobLauncher jobLauncher = ctx.getBean(JobLauncher.class);
  8.     Job job = ctx.getBean("customerJob", Job.class);
  10.     storeRepository = ctx.getBean(StoreRepository.class);
  11.     customerRepository = ctx.getBean(CustomerRepository.class);
  13.     List<Store> stores = storeRepository.findAll();
  15.     for (Store store: stores) {
  16.         int customerCount = customerRepository.countCustomer(store.getStoreID(), reportDate);
  17.         System.out.println("Count: " + customerCount);
  18.         if (customerCount != 0) {
  19.             JobParameters jobParameters = new JobParametersBuilder()
  20.                 .addString("reportDate", reportDate)
  21.                 .addString("ID", store.getStoreID())
  22.                 .toJobParameters();
  23.             JobExecution jobExecution = jobLauncher.run(job, jobParameters);
  24.             BatchStatus batchStatus = jobExecution.getStatus();
  25.             System.out.println("Batch Status " + batchStatus);
  26.         }
  27.     }
  28. }

批处理作业配置：

  1. @Bean
  2. public Step generateReport() throws Exception {
  3.     return this.stepBuilderFactory
  4.         .get("generateReport")
  5.         .<Customer, Customer>chunk(10)
  6.         .reader(itemReader(null, null))
  7.         .writer(itemWriter())
  8.         .build();
  9. }
  11. @Bean
  12. public Job customerReportJob() throws Exception {
  13.     return this.jobBuilderFactory
  14.         .get("customerReportJob")
  15.         .start(generateReport())
  16.         .build();
  17. }

仓库：

  1. @Repository
  2. public class CustomerRepositoryImpl implements CustomerRepository {
  4.     private final JdbcTemplate jdbcTemplate;
  6.     @Autowired
  7.     public CustomerRepositoryImpl(JdbcTemplate jdbcTemplate) {
  8.         this.jdbcTemplate = jdbcTemplate;
  9.     }
  11.     @Override
  12.     public List<Customer> findByIDAndReportDate(String ID, String reportDate) {
  13.         String sqlQuery = "SELECT * " +  
  14.             "FROM CUSTOMER_REPORT " +
  15.             "WHERE ID = " +  ID + "  " +
  16.             "AND TO_CHAR(REPORT_DATE, 'MM/DD/YYYY') = '" + reportDate + "'";
  18.         return jdbcTemplate.query(sqlQuery, 
  19.             (rs, rowNum) -> 
  20.             new Customer(mapper(rs)));
  21.     }
  22. }

application.properties：

  1. # Oracle 设置
  2. spring.datasource.url=##
  3. spring.datasource.username=##
  4. spring.datasource.password=##
  5. spring.datasource.driver-class-name=##
  7. # Hikari
  8. spring.datasource.hikari.maximum-pool-size=5
  9. spring.datasource.hikari.minimumIdle=5
  10. spring.datasource.hikari.idleTimeout=30000
  12. logging.level.com.zaxxer.hikari=debug
  14. # Spring Batch
  15. spring.batch.job.enabled=false
英文:

I'm querying rows from a database using JDBC template and for each rows, I'm programmatically running a job which executes a chunk-based step. I'm worried that each job call will create a new set of connection pool. Does it create a new set of connection pool or just connect to the current pool?

Main Method (Runs the job for each stores):

  1. public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException,
  2.     JobInstanceAlreadyCompleteException, JobParametersInvalidException {
  4. SpringApplication app = new SpringApplication(MainApp.class);
  5. ConfigurableApplicationContext ctx = app.run(args);
  7. JobLauncher jobLauncher = ctx.getBean(JobLauncher.class);
  8. Job job = ctx.getBean(&quot;customerJob&quot;, Job.class);
  10. storeRepository = ctx.getBean(StoreRepository.class);
  11. customerRepository = ctx.getBean(CustomerRepository.class);
  13. List&lt;Store&gt; stores = storeRepository.findAll();	
  16. for (Store store: stores) {
  17.     int customerCount = customerRepository.countCustomer(store.getStoreID(), reportDate);
  18.     System.out.println(&quot;Count: &quot;+ customerCount);
  19.     if (customerCount != 0) {
  20. 	JobParameters jobParameters = new JobParametersBuilder()
  21. 		.addString(&quot;reportDate&quot;, reportDate)
  22. 		.addString(&quot;ID&quot;, store.getStoreID())
  23. 		.toJobParameters();
  24. 	JobExecution jobExecution = jobLauncher.run(job, jobParameters);
  25. 	BatchStatus batchStatus = jobExecution.getStatus();
  26. 	System.out.println(&quot;Batch Status &quot; + batchStatus);
  27.     }
  28.     
  30. }
  31. }

Batch Job Configuration:

  1. @Bean
  2. public Step generateReport() throws Exception {
  3. return this.stepBuilderFactory
  4. 	.get(&quot;generateReport&quot;)
  5. 	.&lt;Customer, Customer&gt;chunk(10)
  6. 	.reader(itemReader(null, null))
  7. 	.writer(itemWriter())
  8. 	.build();
  9. }
  11. @Bean
  12. public Job customerReportJob() throws Exception {
  13. return this.jobBuilderFactory
  14. 	.get(&quot;customerReportJob&quot;)
  15. 	.start(generateReport())
  16. 	.build();
  17. }

Repository:

  1. @Repository
  2. public class CustomerRepositoryImpl implements CustomerRepository {
  4. private final JdbcTemplate jdbcTemplate;
  6. @Autowired
  7.     public CustomerRepositoryImpl(JdbcTemplate jdbcTemplate) {
  8.     this.jdbcTemplate = jdbcTemplate;
  9. }
  11. @Override
  12. public List&lt;Customer&gt; findByIDAndReportDate(String ID, String reportDate) {
  13. String sqlQuery = &quot;SELECT * &quot; +  
  14. 	&quot;FROM CUSTOMER_REPORT &quot; +
  15. 	&quot;WHERE ID = &quot; +  ID + &quot;  &quot; +
  16. 	&quot;AND TO_CHAR(REPORT_DATE, &#39;MM/DD/YYYY&#39;) = &#39;&quot; + reportDate + &quot;&#39;&quot;;
  18. return jdbcTemplate.query(sqlQuery, 
  19. 	(rs, rowNum) -&gt; 
  20. 	new Customer(mapper(rs)));
  21. }
  22. }

application.properties:

  1. # Oracle settings
  2. spring.datasource.url=##
  3. spring.datasource.username=##
  4. spring.datasource.password=##
  5. spring.datasource.driver-class-name=##
  7. # Hikari
  8. spring.datasource.hikari.maximum-pool-size=5
  9. spring.datasource.hikari.minimumIdle=5
  10. spring.datasource.hikari.idleTimeout=30000
  12. logging.level.com.zaxxer.hikari=debug
  14. # Spring Batch
  15. spring.batch.job.enabled=false

答案1

得分: 0

根据您的配置，您的作业将使用相同的数据源/连接池。您可以通过查看日志来确认这一点。

英文:

According to your configuration, your jobs will use the same datasource/connection pool. You should be able to confirm that by looking at the logs.

huangapple
  • 本文由 发表于 2020年9月25日 10:43:23
  • 转载请务必保留本文链接：https://go.coder-hub.com/64057059.html
  • java
  • jdbc
  • jdbctemplate
  • spring-batch
  • spring-boot
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定