fix: use autocloseable on all postgresql connections

Author: marc0der

src/main/kotlin/io/sdkman/broker/adapter/secondary/persistence/PostgresHealthRepository.kt

@@ -1,10 +1,7 @@
 package io.sdkman.broker.adapter.secondary.persistence
 
 import arrow.core.Either
-import arrow.core.flatMap
 import arrow.core.getOrElse
-import arrow.core.left
-import arrow.core.right
 import arrow.core.toOption
 import io.sdkman.broker.domain.repository.HealthCheckFailure
 import io.sdkman.broker.domain.repository.HealthCheckSuccess
@@ -18,8 +15,11 @@ class PostgresHealthRepository(private val dataSource: DataSource) : HealthRepos
     private val logger = LoggerFactory.getLogger(this::class.java)
 
     override fun checkConnectivity(): Either<HealthCheckFailure, HealthCheckSuccess> =
-        Either.catch { dataSource.connection }
-            .flatMap { executeHealthCheck(it) }
+        Either.catch {
+            dataSource.connection.use { connection ->
+                executeHealthCheck(connection).getOrElse { throw it }
+            }
+        }
             .map { HealthCheckSuccess }
             .mapLeft { exception ->
                 logger.error("PostgreSQL health check failed: {}", exception.message, exception)
@@ -35,11 +35,13 @@ class PostgresHealthRepository(private val dataSource: DataSource) : HealthRepos
     private fun ResultSet.isHealthCheckSuccessful(): Boolean = this.next() && this.getInt(1) == 1
 
     private fun executeHealthCheck(connection: Connection): Either<RuntimeException, Unit> =
-        Either.catch { connection.prepareStatement("SELECT 1") }.flatMap { statement ->
-            Either.catch { statement.executeQuery() }.flatMap { resultSet: ResultSet ->
-                when {
-                    resultSet.isHealthCheckSuccessful() -> Unit.right()
-                    else -> RuntimeException("PostgreSQL health check query did not return expected result").left()
+        Either.catch {
+            connection.prepareStatement("SELECT 1").use { statement ->
+                statement.executeQuery().use { resultSet ->
+                    when {
+                        resultSet.isHealthCheckSuccessful() -> Unit
+                        else -> throw RuntimeException("PostgreSQL health check query did not return expected result")
+                    }
                 }
             }
         }.mapLeft { RuntimeException(it) }