标签：scala hikaricp mysql database 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()

标签：scala,hikaricp,mysql,database,doobie
来源： https://codeday.me/bug/20191025/1927933.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。