Akka SQL first try

gistfile1.scala

package sql.akka

import akka.actor.Actor
import akka.dispatch.Future

import java.sql._

import sql._

// messages
case class ExecQuery(query: String, onComplete: ResultSet => Unit)

// information carriers
case class Process(user: String, submitted: Date, result: Future[Any])

object Database {
	def using[A, B <: {def close(): Unit}] (closeable: B) (f: B => A): A = {
		try { f(closeable) } 
		finally { closeable.close() }
	}		
}

class Database extends Actor {
	import Database._
	
	var queries: List[Process] = Nil
	
	def receive = {
		case ExecQuery(sql, onComplete) =>
			// TODO: use using {} blocks
			val future = Future {
				// get connection from pool
				using (Config.getConnection) {  connection =>
					using (connection.createStatement) { statement =>
						using (statement.executeQuery(sql)) { resultset =>
							onComplete(resultset)
						}
					}
				}
			}
			
			queries ::= Process("default", new Date(System.currentTimeMillis()), future)
	}
}