Since programming JEE applications I always wanted to see a two phase commit working. That is that all the changes made to transactional resources are really rolled back when an exception occurs.
I selected tomee and maven as the platform for implementing a test for two phase commits. The complete example can be found here. It is based on this example from the tomee examples.
The example contains a simple stateless EJB that contains the test method:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
@TransactionAttribute(TransactionAttributeType.REQUIRED) public void testTwoPhaseCommit2() throws Exception { Movie movie = new Movie("Quentin Tarantino", "Reservoir Dogs", 1992); twoPhaseCommitMovies.addMovie(movie, movieDatabase, false); List<Movie> movies = twoPhaseCommitMovies.getMovies(movieDatabase); assertEquals(1, movies.size()); movie = new Movie("Quentin Tarantino", "Reservoir Dogs", 1992); twoPhaseCommitMovies2.addMovie(movie, movieDatabase2, true); fail("Excpetion has not been thrown"); } |
In this method two other stateless session beans are used to write a movie object to two different databases respectively. The methods that insert the movie into the database contain a boolean parameter that indicates whether a runtime excpetion should be thrown from that method or it the method should terminate normally. The first invocation is not to throw an exception, the second one should. And it is expected that the method should not terminate normally as indicated by the fail-statement.
The unit test for this ejb looks like this:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
@Test public void test4() throws Exception { TwoPhaseCommitMoviesTestEJB testEJB = (TwoPhaseCommitMoviesTestEJB) context .lookup("java:global/two-phase-commit-2/TwoPhaseCommitMoviesTestEJB"); boolean exception = false; try { testEJB.testTwoPhaseCommit2(); } catch (EJBException e) { assertTrue(e.getCause() instanceof EJBTransactionRolledbackException); assertTrue(e.getCause().getCause() instanceof TwoPhaseCommitRuntimeException); exception = true; } assertTrue(exception); TwoPhaseCommitMoviesFacade moviesFacade = (TwoPhaseCommitMoviesFacade) context .lookup("java:global/two-phase-commit-2/TwoPhaseCommitMoviesFacade"); List<Movie> movies = moviesFacade.getMovies(DB.MOVIES1); assertEquals(0, movies.size()); } |
First an instance of the test ejb is looked up and subsequent the method described above is called. An EJBException is expected to be thrown. The last lines contain the assertions for checking that the insert to the first database actually have been rolled back.
In order to run the example simply type:
|
1 |
mvn clean install |
This example is of course very basic. But it never the less validates the powerful mechanism behind the jee transaction model.