Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- //from log it seems that I created too many pools when I need only one
- def HikariPlayground = {
- (0 to 2000000).par.foreach {
- blah =>
- val q: ConnectionIO[Int] = DailyUpdateQuery(Features("","",Array(blah,blah))).run
- val p: Task[Int] = for {
- xa <- HikariTransactor[Task]("org.postgresql.Driver", "jdbc:postgresql:nova", "nova", "emeth") //utils.GetHikariTransactor
- _ <- xa.configure{
- hx =>
- Task.delay(hx.setMaximumPoolSize(65535))
- }
- a <- q.transact(xa) ensuring xa.shutdown
- } yield a
- p.unsafePerformSync
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement