Spring 中的每个作业调用是否都打开一个新的数据库连接池？

Question

我正在使用 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

Answer 1

根据您的配置，您的作业将使用相同的 datasource/connection 池。您应该可以通过查看日志来确认这一点。

Spring 中的每个作业调用是否都打开一个新的数据库连接池？

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

java

jdbc

jdbctemplate

spring-batch

spring-boot