Doobie с настройкой Hikari

Question

Эй, ребята, пытаясь заставить настройку Hikari Transactor действовать так же, как стандартный Transactor

val xa = HikariTransactor.newHikariTransactor[IO](
  "com.mysql.jdbc.Driver",
  JdbcUrl,
  Username,
  Password
)

sql"""select DISTINCT gcpProject FROM JobStatus"""
     .query[String]    // Query0[String]
     .stream           // Stream[ConnectionIO, String]
     .take(5)          // Stream[ConnectionIO, String]
     .compile.toList   // ConnectionIO[List[String]]
     .transact(xa)     // IO[List[String]]
     .unsafeRunSync    // List[String]
     .foreach(println) // Unit

К сожалению, это дает мне:

Type mismatch, expected: tansactor.Transactor[NotInferedM], actual: IO[hikari.HikariTransactor[IO]]

Любые идеи о том, как можно заставить это работать должным образом?

Просто обратите внимание, что предыдущее решение использовало одно соединение каждый раз и работает правильно:

val xa = Transactor.fromDriverManager[IO](
  "com.mysql.jdbc.Driver",
  JdbcUrl,
  Username,
  Password
)

Но я действительно мог бы использовать пул соединений

Answer 1

Хорошо, после нескольких испытаний, я наконец-то решил это!

Я опубликую свое решение здесь на тот случай, если кто-то еще посчитает это полезным:

val config = new HikariConfig()
config.setJdbcUrl(JdbcUrl)
config.setUsername(Username)
config.setPassword(Password)
config.setMaximumPoolSize(databaseConnectionPoolSize)

val DbTransactor: IO[HikariTransactor[IO]] =
  IO.pure(HikariTransactor.apply[IO](new HikariDataSource(config)))

sql"""select DISTINCT gcpProject FROM JobStatus"""
     .query[String]
     .stream
     .take(5)
     .compile.toList

val prog = for {
  xa <- transactor
  result <- query.transact(xa)
} yield result
prog.unsafeRunSync()