NestedTransactionExceptionTest.scala

NestedTransactionExceptionTest.scala

class Foo(val value: String) extends KeyedEntity[Long] {
  val id: Long = 0
}

object FooSchema extends Schema {
  val foos = table[Foo]

  def reset() = {
    drop // its protected for some reason
    create
  }
}
  
def doSomething(except: Boolean) : Int = {
  transaction{
    if(except) throw new Exception()
    return 1
  }
}

test("Excepting out of nested transaction") {
  transaction{
    FooSchema.reset
    val foo1 = FooSchema.foos.insert(new Foo("test"))
    FooSchema.foos.where(f => f.value === "test").size should equal(1)
    
    intercept[Exception]{
      doSomething(true)
    }
    
    // fails with "no session exception"
    FooSchema.foos.where(f => f.value === "test").size should equal(1)
  }
}

test("Returning out of nested transaction") {
  transaction{
    FooSchema.reset
    val foo1 = FooSchema.foos.insert(new Foo("test"))
    FooSchema.foos.where(f => f.value === "test").size should equal(1)
    
    doSomething(false)
    // fails with "no session exception"    
    FooSchema.foos.where(f => f.value === "test").size should equal(1)
  }
}

test("Returning out of sibling transaction") {
  transaction{
    FooSchema.reset
    val foo1 = FooSchema.foos.insert(new Foo("test"))
    FooSchema.foos.where(f => f.value === "test").size should equal(1)
    
    doSomething(false)
  }
  transaction{
    // works!
    FooSchema.foos.where(f => f.value === "test").size should equal(1)
  }
}