ebean/src/test/java/com/avaje/tests/transaction/TransactionNotTerminatedAfterRollback.java

package com.avaje.tests.transaction;

import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;

import java.util.List;

import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.PersistenceException;

import org.avaje.agentloader.AgentLoader;
import org.junit.BeforeClass;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.avaje.ebean.Ebean;
import com.avaje.ebean.annotation.Transactional;

/**
 * It shows the issue that the user record does NOT rolback when there is an exception thrown
 */
public class TransactionNotTerminatedAfterRollback {
	private static final Logger LOG = LoggerFactory.getLogger(TransactionNotTerminatedAfterRollback.class);

	@BeforeClass public static void preStart() {
		LOG.debug("... preStart");
		// display the log message to see if the UserService is enhanced
		AgentLoader.loadAgentFromClasspath("avaje-ebeanorm-agent", "debug=1");
	}

	@Test public void test() {
		try {
			new UserService().create(new User(1L, "David"));
			fail("Exception should be thrown");
		} catch (PersistenceException pe) {
			LOG.error("e: " + pe);
		}
		List<User> users = Ebean.find(User.class).findList();
		LOG.debug("users: {}", users);
		assertTrue("users should be empty", users.isEmpty());
	}

	@Transactional(rollbackFor = PersistenceException.class) public class UserService {
		public void create(User i) {
			Ebean.save(i);
			Ebean.save(new User(1L, "Peter")); // make it throw exception and rollback
		}
	}

	@Entity public class User {
		@Id Long id;
		String name;

		public User() {}

		public User(Long id, String name) {
			this.id = id;
			this.name = name;
		}

		@Override public String toString() {
			StringBuilder s = new StringBuilder();
			s.append("{");
			s.append("id: ").append(id).append(", ");
			s.append("name: ").append(name);
			s.append("}");
			return s.toString();
		}
	}
}