méthode de dépôt de printemps qui reviennent flux Java 8 ne ferme pas la connexion JDBC

Question

J'ai un dépôt Spring data:

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

J'appelle cette méthode dans une fève de printemps:

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

Je suis en utilisant la base de données MySQL. Et quand je demande en cours d'exécution après quelques invocations de méthode avec succès, il lance une exception:

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 

Il semble que la connexion n'a pas été fermée correctement au printemps. Si j'ai changé la valeur de retour de méthode à List de Stream cela fonctionne correctement.

MISE À JOUR: la version Spring Boot est 1.4.1.RELEASE

Answer 1

Comme le reference documentation clearly states, Stream s doivent être utilisés avec un essai avec-ressources bloc.

De même, assurez-vous de garder une transaction (en lecture seule) ouverte pendant le temps de consommation du flux en annotant la méthode environnante avec @Transactional. Sinon, les paramètres par défaut s'appliquent et les ressources sont tentées d'être libérées lors du retour de la méthode du référentiel.

@Transactional 
public void someMethod() { 

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