spring-batch - Spring Batch : HikariPool-1 - Connection is not available, 请求在 30000 毫秒后超时

Question

我在 SpringBatch 中遇到以下错误:

org.springframework.transaction.CannotCreateTransactionException: Could not open JDBC Connection for transaction; nested exception is java.sql.SQLTransientConnectionException: HikariPool-1 - Connection is not available, request timed out after 30000ms.

鉴于我有很多文件要加载，我认为错误是因为我的 TaskExecutor :

@Bean
    public TaskExecutor MyTE() {
             ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
             executor.setCorePoolSize(64);
             executor.setMaxPoolSize(64);
             executor.setQueueCapacity(64);
             executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
             executor.setThreadNamePrefix("MyTE-");
             return executor;
        }

我对 CorePoolSize、MaxPoolSize 和 QueueCapacity 使用了“Integer.MAX_VALUE”(而不是 64)，但错误仍然发生。

编辑:最终，我的问题的原因似乎是对存储过程的调用 在之前的工作中。事实上，当我在下面评论这段代码时，它起作用了。

@Override
public void beforeJob(JobExecution jobExecution) {
        
CallableStatement cs=null; 

cs=MyDataSource.getConnection().prepareCall("CALL my_proc(?,?)");
cs.setString(1, "my_arg1");
cs.setString(2,"my_arg2"); 
cs.execute();
cs.close();

但是，我想做这个调用，但我不明白为什么它会产生问题。使用 cs.close();

似乎可以很好地关闭连接

问题是什么？

问候。

解决方案:

Connection con = null;
CallableStatement cs = null; 

con=MyDataSource.getConnection();
                         
cs=con.prepareCall("CALL my_proc(?,?)");
cs.setString(1, "my_arg1");
cs.setString(2,"my_arg2"); 
cs.execute();

cs.close();
con.close();

Answer 1

您正在耗尽数据库连接池，因为您没有关闭连接以将它们释放回池中。您只是在 CallableStatement 上调用 close。尝试这样的事情......

try (Connection conn = MyDataSource.getConnection()) {
  CallableStatement cs= conn.prepareCall("CALL my_proc(?,?)");
  cs.setString(1, "my_arg1");
  cs.setString(2,"my_arg2"); 
  cs.execute();
  cs.close();
}

这将自动关闭 Connection 对象并将其释放回 DataSource 连接池。