春リポジトリ方式が近いJDBC接続

Question

をしない私はSpring dataリポジトリがあります。

@Repository 
interface SomeRepository extends CrudRepository<Entity, Long> { 
    Stream<Entity> streamBySmth(String userId); 
} 

を私はいくつかのSpring Beanにそのメソッドを呼び出しています：

@Scheduled(fixedRate = 10000) 
private void someMethod(){ 
    someRepository.streamBySmth("smth").forEach(this::callSomeMethod); 
} 

私はMySQLデータベースを使用します。

に思え

o.h.engine.jdbc.spi.SqlExceptionHelper : SQL Error: 0, SQLState: 08001 
o.h.engine.jdbc.spi.SqlExceptionHelper : Could not create connection to database server. 
o.s.s.s.TaskUtils$LoggingErrorHandler : Unexpected error occurred in scheduled task. 

org.springframework.dao.DataAccessResourceFailureException: Unable to acquire JDBC Connection; nested exception is org.hibernate.exception.JDBCConnectionException: Unable to acquire JDBC Connection 

、その接続は春で適切に閉じられていませんでした：私はいくつかの成功メソッド呼び出しの後にアプリケーションを実行していたときに、それが例外をスローします。メソッドの戻り値をListからStreamに変更した場合、正しく動作します。

UPDATE： 春ブートバージョンreference documentation clearly states、Stream sが試し-と、リソースブロックと一緒に使用する必要があるとして1.4.1.RELEASE

Answer 1

です。

また、周囲のメソッドに@Transactionalと注釈を付けることによって、ストリームの消費時間の間、（読み取り専用の）トランザクションを開いたままにしておきます。それ以外の場合は、デフォルト設定が適用され、リポジトリメソッドのリターン時にリソースが解放されようとします。

@Transactional 
public void someMethod() { 

    try (Stream<User> stream = repository.findAllByCustomQueryAndStream()) { 
    stream.forEach(…); 
    } 
}