resolvers += Resolver.jcenterRepo
libraryDepenencies += "com.kyleu" %% "jdub-async" % "1.0"

val db = new Database("localhost", "mydatabase", "myaccount", "mypassword").open()

// Query returning an optional single result.
case class GetAge(name: String) extends FlatSingleRowQuery[Int] {
  override val sql = "SELECT age FROM people WHERE name = ?"
  override val values = Seq(name)
  override def flatMap(row: Row) = {
    row.as[Int]("age")
  }

}

val age = db.query(GetAge("Old Guy")).getOrElse(-1)

// Query returning a Person object for each row.
case object GetPeople extends Query[Seq[Person]] {
  override val sql = "SELECT name, email, age FROM people"
  override val values = Nil
  override def reduce(rows: Iterator[Row]) = rows.map { row =>
    val name = row.as[String]("name").getOrElse(throw new IllegalStateException())
    val email = row.as[String]("email").getOrElse("")
    val age = row.as[Int]("age").getOrElse(0)
    Person(name, email, age)
  }.toSeq
}

val people = db.query(GetPeople)

case class UpdateEmail(name: String, newEmail: String) extends Statement {
  override val sql = trim("UPDATE people SET email = ? WHERE name = ?")
  override val values = Seq(newEmail, name)
}

val affectedRowCount = db.execute(UpdateEmail("Old Guy", "[email protected]"))

case object UserQueries extends BaseQueries {
  override protected val tableName = "users"
  override protected val columns = Seq("id", "username", "full_name", "password")
  override protected val searchColumns = Seq("username", "full_name")

  val insert = Insert
  val getById = GetById
  val search = Search
}

Database.execute(UserQueries.insert(User(1, "kyle", "Kyle U", "password")))
val searchResults = Database.query(UserQueries.search("kyle"))