object BasicExample {def main(args: Array[String]) {// 这个Parser我发现好像用不了。。val configuration = URLParser.parse("")val connection: Connection = new PostgreSQLConnection(configuration)//阻塞等待连接Await.result(connection.connect, 5 seconds)//sendQuery直接就执行了，不像slick那样，还要单独的runval future: Future[QueryResult] = connection.sendQuery("SELECT * FROM USERS")val mapResult: Future[Any] = future.map(queryResult => queryResult.rows match {case Some(resultSet) => {val row: RowDat = resultSet.headrow(0)}//注意，这里的-1是Any而不是Future[Any]case None => -1})val result = Await.result(mapResult, 5 seconds)println(result)//关闭数据库链接
        connection.disconnect}
}

// 需要提前创建好数据库，id应该是自增的
case class Message(id: Option[Long], content: String: LocalDate = LocalDate.now())object MessageRepository {val Insert = "INSERT INTO messages (content, moment) VALUES(?, ?)"val Update = "UPDATE messages SET content = ?, moment = ? WHERE id = ?"val Select = "SELECT id, content, moment FROM messages ORDER BY id asc"val SelectOne = "SELECT id, content, momment FROM messages WHERE id = ?"
}// 这个有点dependency injection的意思
class MessageRepository（pool: Content) {import MessageRepository._def save(m: Message): Future[Message] = {// queryResult => m 是什么意思case Some(id) => pool.sendPreparedStatement(Update, Array(m.content, m.moment, id)).map { queryResult => m }case None => pool.sendPreparedStatement(Insert, Array(m.content, m.moment)).map { queryResult => m }}def list: Future[IndexSeq[Message]] = {pool.sendQuery(Select). map {//rows 返回resultSet, get返回什么呢，返回的是 Iterator 类型的东西么queryResult => queryResult.rows.get.map {item => rowToMessage(item)}}}def find(id: Long): Future[Option[Message]] = {//[Any] 非得加么
        pool.sendPreparedStatement(SelectOne, Array[Any](id)).map {queryResult =>queryResult.rows match {case Some(rows) => Some(rowToMessage(rows.apply(0)))case None => None}}}private def rowToMessage(row: RowData): Message = {new Message(id = Some(row("id".asInstanceOf[Long]))content = row("content").asInstanceOf[String]moment = row("moment").asInstanceOf[LocalDate])}
}

object Global extends GlobalSettings {private val databaseConfiguration = System.getenv("DATABASE_URL") match {case url: String => URLParser.parse(url)case _ => new Configuration(username = "postgres"database = Some("databasename")port     = 5433)}// factory 还有mysql专用版么private val factory = new PostgreSQLFactory(databaseConfiguration)private val pool    = new ConnectionPool(factory, PoolConfiguration.Default)val messageRepository = new MessageRepository( pool )//    play 的东西，普通的程序不晓得如何处理close问题override def onStop(app: Application)pool.close
}