大家好,我想让hikari交易器设置为与标准交易器一样
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
)
但我真的可以使用连接池
解决方法:
好了,经过一堆测试,我终于解决了!
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()