scala – Squeryl：显式运行查询

>懒惰的数据计算;这里：数据库结果
>隐藏在计算完成时必须触发的后处理操作的需要;这里：从控制器中隐藏或查看必须关闭数据库会话

由于你的计算是懒惰的,并且因为你没有义务将它执行到最后(这里：迭代整个结果集),所以没有明显的钩子可以触发后处理步骤.

您调用Query [T] .toList的建议不会出现此问题,因为计算是在最后执行的,并且请求结果集的最后一个元素可以用作关闭会话的触发器.

也就是说,我能想到的最好的是以下内容,它是org.squeryl.dsl.QueryDsl._using中代码的改编：

class IterableQuery[T](val q: Query[T]) extends Iterable[T] {
  private var lifeCycleState: Int = 0
  private var session: Session = null
  private var prevSession: Option[Session] = None

  def start() {
    assert(lifeCycleState == 0,"Queries may not be restarted.")
    lifeCycleState = 1

    /* Create a new session for this query. */
    session = SessionFactory.newSession

    /* Store and unbind a possibly existing session. */
    val prevSession = Session.currentSessionOption
    if(prevSession != None) prevSession.get.unbindFromCurrentThread

    /* Bind newly created session. */
    session.bindToCurrentThread
  }

  def iterator = {
    assert(lifeCycleState == 1,"Query is not active.")
    q.toStream.iterator
  }

  def stop() {
    assert(lifeCycleState == 1,"Query is not active.")
    lifeCycleState = 2

    /* Unbind session and close it. */
    session.unbindFromCurrentThread
    session.close

    /* Re-bind previous session,if it existed. */
    if(prevSession != None) prevSession.get.bindToCurrentThread
  }
}

客户端可以使用查询包装器,如下所示：

var manualIt = new IterableQuery(booksQuery)
manualIt.start()
manualIt.foreach(println)
manualIt.stop()
//      manualIt.foreach(println) /* Fails,as expected */

manualIt = new IterableQuery(booksQuery) /* Queries can be reused */
manualIt.start()
manualIt.foreach(b => println("Book: " + b))
manualIt.stop()

在创建对象时,即在IterableQuery的构造函数内,或者在将对象传递给控制器??之前,可以完成对manualIt.start()的调用.

但是,以这种方式处理资源(文件,数据库连接等)非常脆弱,因为在异常的情况下不会触发后处理.如果你看一下org.squeryl.dsl.QueryDsl._using的实现,你会看到IterableQuery中缺少的几个try … finally块.