Управление сеансом Squeryl с использованием

Я изучаю Squeryl и пытаюсь понять синтаксис using, но не могу найти по нему документацию.

В следующем примере создаются две базы данных: A содержит слово Hello , а B содержит Goodbye . Намерение состоит в том, чтобы запросить содержимое A, затем добавить слово World и записать результат в B.

Ожидаемый вывод консоли: Inserted Message (2, HelloWorld)

object Test {
    def main(args: Array[String]) {
        Class.forName("org.h2.Driver");
        import Library._

        val sessionA = Session.create(DriverManager.getConnection(
                "jdbc:h2:file:data/dbA","sa","password"),new H2Adapter)
        val sessionB = Session.create(DriverManager.getConnection(
                "jdbc:h2:file:data/dbB","sa","password"),new H2Adapter)

        using(sessionA){
            drop; create
            myTable.insert(Message(0,"Hello"))
        }
        using(sessionB){
            drop; create
            myTable.insert(Message(0,"Goodbye"))
        }

        using(sessionA){
            val results = from(myTable)(s => select(s))//.toList

            using(sessionB){
                results.foreach(m => {
                    val newMsg = m.copy(msg = (m.msg+"World"))
                    myTable.insert(newMsg)
                    println("Inserted "+newMsg)
                })
            }
        }
    }

    case class Message(val id: Long, val msg: String) extends KeyedEntity[Long]
    object Library extends Schema { val myTable = table[Message] }
}

As it стоит, код печатает Inserted Message (2, GoodbyeWorld) , если только toList не добавлен в конец строки val results .

Есть ли способ привязать запрос results к использованию sessionA даже при оценке внутри с использованием (sessionB) ? Это кажется предпочтительным, чем использование toList , чтобы заставить запрос оценивать и сохранять содержимое в памяти.

Обновление

Благодаря ответу Дэйва Уиттакера следующий фрагмент исправляет его, не прибегая к toList, и исправляет мое понимание как «использования», так и выполнения запросов.

val results = from(myTable)(s => select(s))

using(sessionA){            
    results.foreach(m => {
        val newMsg = m.copy(msg = (m.msg+"World"))
        using(sessionB){myTable.insert(newMsg)}
        println("Inserted "+newMsg)
    })
}
5
задан Pengin 6 December 2011 в 20:14
поделиться