asyncpools-figure2.scala

import scala.slick.driver.H2Driver.simple._

object MyRepository {

    val table = new Table[(Int, String)]("my_table") {
        def id = column[Int]("id", O.PrimaryKey)
        def name = column[String]("name")
        def * = id ~ name
    }

    def getName(id: Int): Future[String] =
        MySlickPools.myReadPool execute { implicit session =>
            Query(table).filter(_.id === id).map(_.name).first
        }

    def insert(id: Int, name: String) =
        MySlickPools.myWritePool execute { implicit session =>
            table.insert((id, name))
        }

}