java.sql.Result Iterator on Scala

resultSetItr.scala

import java.sql._

def resultSetItr[T](res: ResultSet)(f: ResultSet => T): Stream[T] = {
  new Iterator[T] {
    def hasNext = res.next()
    def next() = f(res)
  }.toStream
}

def query[T](conn: Connection, sql: String)(f: ResultSet => T): List[T] = {
  val s = conn.createStatement
  try {
    val res = s.executeQuery(sql)
    val it = resultSetItr(res)(f)
    it.toList
  } finally {
    s.close
  }
}