gistfile1.scala

object JPASpec extends Specification {
  object EM extends LocalEMF("jpaSample") with ThreadLocalEM

  "EntityManager" should {
    setSequential() // Make sure that the following specs execute in order

    "Add users" in {
      println("running add users")
      val user1 = new User("Ted")
      val user2 = new User("Fred")
      
      EM.persist(user1)
      EM.persist(user2)
      
      EM.flush

      val users = EM.createQuery[User]("from User").findAll
      println(users.size)

      users.size must_== 2
    }

    "Retrieve users" in {
      println("running retrieve users")
      val users = EM.createQuery[User]("from User").findAll
      println(users.size)

      users.size must_== 2
    }

    "Delete users" in {        
      println("running delete users")    
      val users = EM.createQuery[User]("from User").findAll
      println(users.size)
      
      users.foreach { 
        user ⇒ EM.remove(user)
      }

      EM.flush

      val empty = EM.createQuery[User]("from User").findAll
      println(empty.size)

      empty.size must_== 0
    }
  }
}