TimeoutProblem.scala

package com.ssn

import cats.effect.{Blocker, ExitCode, IO, IOApp}
import cats.implicits._
import doobie.implicits._
import doobie.hikari.HikariTransactor
import doobie.util.ExecutionContexts
import doobie.util.transactor.Transactor

import scala.concurrent.duration._

object TimeoutProblem extends IOApp {

  val url  = "jdbc:postgresql://localhost:5432/my_db"
  val user = "my_user"
  val pass = "my_pass"

  val transactor = for {
    b <- Blocker[IO]
    xa = Transactor
      .fromDriverManager[IO]("org.postgresql.Driver",url,user,pass, b)
  } yield xa
  val hikariTransactor = for {
    be <- Blocker[IO]
    ce <- ExecutionContexts.fixedThreadPool[IO](16)
    xa <- HikariTransactor.newHikariTransactor[IO](
      "org.postgresql.Driver",
      url,
      user,
      pass,
      ce,
      be
    )
  } yield xa

  override def run(args: List[String]): IO[ExitCode] =
    transactor
      .use(t => {
        sql"select 42"
          .query[Int]
          .unique
          .transact(t)
          .timeout(2.seconds)
          .attempt
          .flatTap(e => IO(println(e)))
          .as(ExitCode.Success)
      })

}