Problem with transaction commit in @Transactional methods using Java Spring and Hibernate and EntityManager

Question

I'm trying to learn Spring, Hibernate with the H2 database usinge maven to build the code. Currently I have some problems how to use the @Transactional annotation correctly to automatic start the transaction and commit the transaction when e.g. entityManager.persist is done successful or rollback.

My test project is very simple. The POJO class is Person and contains first name, family name and email address. There is a Service class PersonSerice that is an interface that offers CRUD functions to add, change, read and delete person data. There is the PersonServiceImpl that calls the methods of the DAO class. And here the sample Code of the method PersonDAOImpl::createPerson Using

public void createPerson(Person person) {
    entityManager.getTransaction().begin();
    entityManager.persist(person);
    entityManager.getTransaction().commit();
}

Everything works as expected. There is a Hibernate SQL output

"Hibernate: call next value for hibernate_sequence Hibernate: insert into person (email, nachname, vorname, id) values (?, ?, ?, ?)"

I want to get rid of manually calling entityManager.getTransaction().commit(); So I tried to write @Transactional at the ServiceImpl method that call the DAO method

    public void createPerson(Person person) {
    entityManager.getTransaction().begin();
    entityManager.persist(person);
    entityManager.getTransaction().commit();
}

Now it does not work properly. I just get. " Hibernate: call next value for hibernate_sequence " There is something written into the database but I cannot list all entries or remove them without a manually commit. So I currently don't know what is wrong and how I can get @Transactional do the commit automatically. Here part of the entityManager content shown in Eclipse debugger:

entityManager $Proxy26 (id=33) h ExtendedEntityManagerCreator$ExtendedEntityManagerInvocationHandler (id=116)
containerManaged false
exceptionTranslator null jta false synchronizedWithTransaction false
target SessionImpl (id=122)
actionQueue ActionQueue (id=306)
... autoJoinTransactions true
...

I guess my main problems could be in the xml resource files so I want to show them here. Here is my Beans.xlm (./src/main/resources/Beans.xml)




   
    
        
        
        
        
    


    
        
            
                database.properties

One line is maybe a problem. "" As I don't have aspectj dependencies in my pom. But adding them didn't change anything and I don't know what is needed to get @Transactional working as expected.

Now the other files.

Here is my persistence.xml (./src/main/resources/META-INF/persistence.xml)



  
    org.hibernate.jpa.HibernatePersistenceProvider

    maven.springhibernateh2.basic.Person

Here my pom.xml


  4.0.0
  roland.egger
  maven.springhibernateh2.basic
  0.0.1-SNAPSHOT
   
      
         
            org.apache.maven.plugins
            maven-compiler-plugin
            3.6.1
            
               1.8
               1.8
            
         
      
   
   
      1.7.30
      5.2.5.RELEASE
      5.4.15.Final
   
   
      
         org.springframework
         spring-core
         ${spring.version}
      
      
         org.springframework
         spring-context
         ${spring.version}
      
      
      
         org.springframework
         spring-orm
         ${spring.version}
      
      
      
         org.springframework
         spring-jdbc
         ${spring.version}
      
      
      
         org.springframework
         spring-aspects
         ${spring.version}
      
      
      
         org.springframework
         spring-tx
         ${spring.version}
      
      
      
         com.h2database
         h2
         1.4.200
      
      
      
         org.hibernate
         hibernate-core
         ${hibernate.version}
      
      
      
         org.hibernate
         hibernate-entitymanager
         ${hibernate.version}
      
      
      
         org.hibernate.javax.persistence
         hibernate-jpa-2.1-api
         1.0.2.Final
      
      
         org.slf4j
         slf4j-api
         ${slf4j.version}
      
      
         org.slf4j
         slf4j-log4j12
         ${slf4j.version}
      
      
      
         log4j
         apache-log4j-extras
         1.1

Here database.properties

db.driverClassName=org.h2.Driver
db.url=jdbc:h2:mem:test;DB_CLOSE_DELAY=-1
db.username=sa
db.password=

Here Person.java

package maven.springhibernateh2.basic;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;


@Entity
@Table(name="person")
public class Person {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    @Column(name="id")
    private int personId;

    @Column(name = "vorname")
    private String Vorname;

    @Column(name = "nachname")
    private String Nachname;

    @Column(name = "email")
    private String Emailadresse;
    public int getPersonId() {
        return personId;
    }
    public void setPersonId(int personId) {
        this.personId = personId;
    }
    public String getVorname() {
        return Vorname;
    }
    public void setVorname(String vorname) {
        Vorname = vorname;
    }
    public String getNachname() {
        return Nachname;
    }
    public void setNachname(String nachname) {
        Nachname = nachname;
    }
    public String getEmailadresse() {
        return Emailadresse;
    }
    public void setEmailadresse(String emailadresse) {
        Emailadresse = emailadresse;
    }

    public String toString() {
        return "Person [PersonId=" + personId + ", Vorname=" + Vorname + ", Nachname=" + Nachname + ", Emailadresse=" + Emailadresse + "]";
    }
}

PersonService.java

package maven.springhibernateh2.basic;

import java.util.List;

public interface PersonService {
    public abstract void addPerson(Person person);
    public abstract Person fetchPersonById(int personId);
    public abstract void deletePersonByID(int personId);
    public abstract void updatePersonEmailByID(String newEmail, int personId);
    public abstract List getAllPersonInfo();
}

PersonServiceImpl.java

package maven.springhibernateh2.basic;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

@Component("personService")
public class PersonServiceImpl implements PersonService {

    @Autowired
    private PersonDAO personDAO;

    public void setPersonDAO(PersonDAO personDAO) {
        this.personDAO = personDAO;
    }

    @Transactional
    public void addPerson(Person person) {
        personDAO.createPerson(person);
    }

    @Transactional
    public Person fetchPersonById(int personId) {
        return personDAO.getPersonById(personId);
    }

    @Transactional
    public void deletePersonByID(int personId) {
        personDAO.deletePersonByID(personId);
    }

    @Transactional
    public void updatePersonEmailByID(String newEmail, int personId) {
        personDAO.updatePersonEmailByID(newEmail, personId);
    }

    @Transactional
    public List getAllPersonInfo() {
        return personDAO.getAllPersonData();
    }
}

PersonDAO.java

package maven.springhibernateh2.basic;

import java.util.List;

public interface PersonDAO {
    public abstract void createPerson(Person person);
    public abstract Person getPersonById(int personId);
    public abstract void deletePersonByID(int personId);
    public abstract void updatePersonEmailByID(String newEmail, int personId);
    public abstract List getAllPersonData();

}

PersonDAOImpl.java

package maven.springhibernateh2.basic;

import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.PersistenceUnit;
import javax.persistence.TypedQuery;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Root;

import org.springframework.stereotype.Repository;


@Repository
public class PersonDAOImpl implements PersonDAO {

    @PersistenceUnit(name = "roland.egger.maven.springhibernate")
    private EntityManagerFactory entityManagerFactory;    

    private EntityManager entityManager;

    public void setEntityManager(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    public EntityManagerFactory getEntityManagerFactory() {
        return entityManagerFactory;
    }

    @PersistenceUnit
    public void setEntityManagerFactory(EntityManagerFactory entityManagerFactory) {
        this.entityManagerFactory = entityManagerFactory;
        this.entityManager = this.entityManagerFactory.createEntityManager();
    }

    public EntityManager getEntityManager() {
        return entityManager;
    }


    public void createPerson(Person person) {
        entityManager.persist(person);
    }

    public Person getPersonById(int personId) {
        Person person = entityManager.find(Person.class, personId);
        return person;
    }

    public void deletePersonByID(int personId) {
        Person person = getPersonById(personId);
        if (person != null) {
            //entityManager.getTransaction().begin();
            entityManager.remove(person);
            //entityManager.getTransaction().commit();
        }
    }

    public void updatePersonEmailByID(String newEmail, int personId) {
        Person person = getPersonById(personId);
        if (person != null)
        { 
            entityManager.getTransaction().begin();
            person.setEmailadresse(newEmail);
            entityManager.getTransaction().commit();
        }
    }

    public List getAllPersonData() {
        CriteriaBuilder cb = entityManager.getCriteriaBuilder();
        CriteriaQuery cq = cb.createQuery(Person.class);
        Root rootEntry = cq.from(Person.class);
        CriteriaQuery all = cq.select(rootEntry);
        TypedQuery allQuery = entityManager.createQuery(all);
        return allQuery.getResultList();
    }

}

Excuse me for posting the source code but I hope that it helps others to understand what I am doing and how the problem can be solved to get the transaction working without manually writing them into the code.

Ali Gelenler · Accepted Answer

When you use @PersistenceUnit you need to create/destroy EntityManager and manually manage transactions. If you want to use spring @Transactional you need to remove entityManagerFactory which is annotated by @PersistenceUnit, and instead use @PersistenceContext on your entityManager variable as below.

@PersistenceContext
private EntityManager entityManager;

The reason is, when you use @PersistenceContext you define a container managed bean(here it is spring managed) so that you don't need to explicitly commit/rollback your transactions, on the other hand with @PersistenceUnit you specify that you want to handle the transactions.

Update:

Related with the latest error which mentions about "No EntityManager with actual transaction available for current thread":

You can either remove mode="aspectj" from configuration if you don't need to use aspectj and can rely on spring default AOP. After removing mode="aspectj" from Beans.xml your code should work immediately.
Or adjust your config to correctly implement aspectj. At least you need to add aspectj dependencies to your project pom and add "context:load-time-weaver" definition to Beans.xml. Please check spring transaction management docs for aspectj usage.

Hope this helps.

Problem with transaction commit in @Transactional methods using Java Spring and Hibernate and EntityManager

Answers (2)

Related Questions