2

を使用して接続タイムアウトを設定するにはDoobie?

今のところ、新しい を作成してhikari transactorから構成しています。

def buildTransactor(driver: String, uri: String, 
                    user: String, pwd: String, 
                    timeout: Long) = for {
  ce <- ExecutionContexts.fixedThreadPool[Task](10)
  te <- ExecutionContexts.cachedThreadPool[Task]
  xa <- HikariTransactor.newHikariTransactor[Task](
    driver, uri, user, pwd, ce, te)
  _ <- configure(xa, timeout)   // Configure transactor
} yield xa


def configure(xa: HikariTransactor[Task], timeout: Long) = Resource.liftF(
  xa.configure(ds => Task(ds.setConnectionTimeout(timeout)))
)

大丈夫かどうかわかりません。ドキュメントは何も言わない。

4

0 に答える 0