[writing-async-app-in-scala-part-3] blocking dao 1

BlockingDao1.scala

implicit val blockingExecutionContext =
  ExecutionContext.fromExecutorService(Executors.newFixedThreadPool(50))

class MyDao(jdbcTemplate: JdbcTemplate)(implicit ec: ExecutionContext) {
  def get(id: String): Future[Option[RichDomainObject]] =
    Future(getBlocking(id))

  private def getBlocking(id: String): Option[RichDomainObject] =
    jdbcTemplate.queryForObject(
      "SELECT blob FROM table WHERE id = ?",
      Array(id),
      rs => parseJson(rs.getString(1))
    )

  private def parseJson(s: String): RichDomainObject = ???
}