微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

mysql-使用Hikari设置的Doobie

大家好,我想让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()

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐