gistfile1.scala

object x {
  
  // stream a sql query
  def sql( str:String ):Stream[ResultSet] = withStatement { s =>
    val rs = s executeQuery str
    new Iterator[ResultSet] { def hasNext = rs.next ;  def next = rs }.toStream
  }
  
  // loan a sql statement
  def withStatement[R]( f:(Statement) => R ): R =
    withConn { c => f( c.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY) ) }
  
  // loan a sql connection
  def withConn[R]( f:(java.sql.Connection) => R ):R = {
    val conn = DriverManager getConnection "jdbc://..."
    try f(conn) finally conn.close()
  }
  
}