Frühling JpaRepository findAll, Java 8 Strom, Verbindung aufgegeben wurde

Question

ich mit Spring-Boot und versuchen, eine findAll Abfrage in mu-Repository zu tun, die einen Strom von Ergebnissen zurückgeben sollte:

public interface MyThingRepository extends JpaRepository<MyThing, String> { 
    Stream<MyThing> findAll(); 
} 

public class MyScheduledJobRunner { 

    @Autowired 
    private MyThingRepository myThingRepository; 

    public void run() { 
     try (Stream<MyThing> myThingsStream : myThingRepository.findAll()) { 
     myThingsStream.forEach(myThing -> { 
      // do some stuff 
     }); 
     // myThingsStream.close(); // <- at one point even tried that, though the stream is wrapped in an auto-closing block. anyway, it did not help 
     System.out.println("All my things processed."); 
    } 
    System.out.println("Exited the auto-closing block."); 
    } 
} 

Ausgabe, die ich bekommen ist:

All my things processed. 
Exited the auto-closing block. 
o.a.tomcat.jdbc.pool.ConnectionPool  : Connection has been abandoned PooledConnection[com.mysql.jdbc.JDBC4Connection@2865b7d5]:java.lang.Exception 
| at org.apache.tomcat.jdbc.pool.ConnectionPool.getThreadDump(ConnectionPool.java:1061) 
... 
at MyScheduledJobRunner.run(MyScheduledJobRunner:52) 

MyScheduledJobRunner: 52:

try (Stream<MyThing> myThingsStream : myThingRepository.findAll()) { 

per Dokumentation, wenn St mit In JpaRepositories sollten Sie diese nach der Verwendung immer wieder schließen. Da sie AutoCloseable implementieren, können Sie try with resources block verwenden. http://docs.spring.io/spring-data/jpa/docs/current/reference/html/#repositories.query-streaming

Ein Stream-Wraps potenziell zugrunde liegenden Datenspeicher spezifische Ressourcen und damit nach Gebrauch geschlossen werden müssen. Sie können den Stream entweder manuell mithilfe der close() -Methode oder mithilfe eines Java 7-Try-with-resources-Blocks schließen.

Es gibt sogar ein Beispiel in der Dokumentation, die es genau so macht, wie ich es tue. Also mache ich die ganze Dokumentation, sagt, soweit ich das beurteilen kann, aber trotzdem bekomme ich 30 Sekunden nach der Operation eine Ausnahme. Offensichtlich ist die Verbindung also nicht geschlossen und bleibt hängen. Warum ist das und wie könnte ich das überwinden?

Ich habe mit Postgres 9.5 und MariaDB als Datenbank versucht. Ich verwende die neuesten möglichen Anschlüsse/Treiber und Tomcat Connection Pooling, die durch Federstiefel Eigenschaften wie das konfiguriert ist:

spring: 
    datasource: 
    driverClassName: com.mysql.jdbc.Driver 
    url: jdbc:mysql://localhost/mydb?useSSL=false 
    username: user 
    password: password 
    initial-size: 10 
    max-active: 100 
    max-idle: 50 
    min-idle: 10 
    max-wait: 15000 
    test-while-idle: true 
    test-on-borrow: true 
    validation-query: SELECT 1 
    validation-query-timeout: 5 
    validationInterval: 30000 
    time-between-eviction-runs-millis: 30000 
    min-evictable-idle-time-millis: 60000 
    removeAbandonedTimeout: 60 
    remove-abandoned: true 
    log-abandoned: true 

Answer 1

in Pool-Konfiguration nur u hinzufügen müssen: „org.apache.tomcat.jdbc.pool .interceptor.ResetAbandonedTimer "