vert.x async jdbc schließt keine Verbindungen

Question

Ich implementiere eine RESTful-API mit Vert.x. Ich habe seinen asynchronen jdbc-Client mit MySQL und c3p0 als Verbindungspool verwendet.

Mein Problem ist, dass obwohl die CloseConnection-Handler erfolgreich ist, die eigentliche Datenbankverbindung nicht geschlossen und wiederverwendet wird. Der Pool wird in Sekunden voll, was Folgendes ergibt: BasicResourcePool: 204 - Test erwerben - Pool ist bereits ausgereizt. [verwaltet: 20; max: 20]

client.getConnection(connectionAsyncResult -> { 
SQLConnection connection = connectionAsyncResult.result(); 
connection.queryWithParams("SELECT * FROM AIRPORTS WHERE ID = ?", new JsonArray().add(id), select -> { 
    ResultSet resultSet = select.result(); 
    Airport $airport = resultSet.getRows() 
      .stream() 
      .map(Airport::new) 
      .findFirst() 
      .get(); 

    asyncResultHandler.handle(Future.succeededFuture($airport)); 
    connection.close(closeHandler -> { 
     if (closeHandler.succeeded()) { 
      LOG.debug("Database Connection closed"); 
     } 
     else if (closeHandler.failed()) { 
      LOG.error("Database Connection failed to close!"); 
     } 
    }); 
}); 

});

Irgendeine Idee, was ich vermisse?

Alles Gute!

Answer 1

Sie haben wahrscheinlich eine Ausnahme in Ihrem Handler, wenn so etwas passiert, dann wird die letzte Zeile nicht ausgeführt, daher wird der Abschluss nicht aufgerufen und die Verbindung zum Pool zurückgegeben.

Sie sollten Ihren Code mit einem tryfinally Block umwickeln, um sicherzustellen, dass die Verbindung an den Pool zurückgegeben wird.