Impossible to bypass caches with Hibernate EntityManager

Question

Is there a problem in my code ? I cannot retrieve the changes on my User entity without restarting the application.

Here is my persistence.xml:

<persistence xmlns="http://java.sun.com/xml/ns/persistence"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://java.sun.com/xml/ns/persistence 
             http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd"
             version="2.0">
    <persistence-unit name="pu" transaction-type="RESOURCE_LOCAL">
    <properties>
        <property name = "hibernate.show_sql" value = "true" />
    </properties>
</persistence-unit>

</persistence>

I create my EntityManagerFactory this way:

public static EntityManagerFactory entityManagerFactory(String driver, String url, String user, String password, DataSource datasource) {
    LocalContainerEntityManagerFactoryBean entityManagerFactory = new LocalContainerEntityManagerFactoryBean();

    DBPoolDataSource dataSource = new DBPoolDataSource();

    dataSource.setName("pool-ds");
    dataSource.setDescription("Pooling DataSource");
    dataSource.setDriverClassName(driver);
    dataSource.setUrl(url);
    dataSource.setUser(user);
    dataSource.setPassword(password);
    dataSource.setMinPool(5);
    dataSource.setMaxPool(10);
    dataSource.setMaxSize(30);
    dataSource.setIdleTimeout(3600);
    dataSource.setValidationQuery("SELECT id FROM test");

    entityManagerFactory.setDataSource(datasource);
    entityManagerFactory.setPersistenceUnitName("pu");
    entityManagerFactory.setJpaDialect(new HibernateJpaDialect());
    entityManagerFactory.setJpaVendorAdapter(new HibernateJpaVendorAdapter());
    Map<String, Object> props = entityManagerFactory.getJpaPropertyMap();
    props.put("hibernate.cache.use_second_level_cache", "false");
    props.put("hibernate.cache.use_query_cache", "false");

    entityManagerFactory.afterPropertiesSet();

    return entityManagerFactory.getObject();
}

Here is my Entity:

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

@Entity
@Table(name = "USER")
public class User {

    @Id
    private String trigram;

    @Column(name = "FIRST_NAME")
    private String firstName;

    @Column(name = "LAST_NAME")
    private String lastName;

    public String getTrigram() {
        return trigram;
    }

    public void setTrigram(String trigram) {
        this.trigram = trigram;
    }

    public String getFirstName() {
        return firstName;
    }

    public void setFirstName(String firstName) {
        this.firstName = firstName;
    }

    public String getLastName() {
        return lastName;
    }

    public void setLastName(String lastName) {
        this.lastName = lastName;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;

        User user = (User) o;

        if (!trigram.equals(user.trigram)) return false;
        if (firstName != null ? !firstName.equals(user.firstName) : user.firstName != null) return false;
        return lastName != null ? lastName.equals(user.lastName) : user.lastName == null;
    }

    @Override
    public int hashCode() {
        int result = trigram.hashCode();
        result = 31 * result + (firstName != null ? firstName.hashCode() : 0);
        result = 31 * result + (lastName != null ? lastName.hashCode() : 0);
        return result;
    }
}

Here is my repository:

import javax.persistence.EntityManager;
import javax.persistence.NoResultException;
import javax.persistence.TypedQuery;

public class UserDao {

    private EntityManager entityManager;

    public UserDao(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    public User getByTrigram(String trigram) throws NoResultException {

        entityManager.getEntityManagerFactory().getCache().evictAll();

        TypedQuery<User> q = entityManager.createQuery(
                "select u from User u where u.trigram = :trigram", User.class);
        q.setParameter("trigram", trigram);
        q.setHint("javax.persistence.cache.retrieveMode", CacheRetrieveMode.BYPASS);
        return q.getSingleResult();
    }
}

-> So the entity doesn't come from L1.

entityManagerFactory.getJpaPropertyMap() contains both:

• hibernate.cache.use_second_level_cache=false
• hibernate.cache.use_query_cache=false

-> So there should be no L2 nor from query cache.

But still, the changes made directly in my database are retrieved by my repository only after a restart.

Someone has an idea? Thank you!

Answer 1

By default, Hibernate 4 has disabled L2 cache and query cache, so it's useless to configure hibernate.cache.use_second_level_cache=false and hibernate.cache.use_query_cache=fals.

The entity is cached in the hibernate Session (L1), and if you want to refresh this particular entity according to the underlying database, you can create a method like this:

public void refresh(User user) {
    org.hibernate.Session session = entityManager.unwrap(Session.class);
    session.refresh(user);
}

and call it after you retrieve the user, this way:

User currentUser = userDao.getByTrigram(login);
userDao.refresh(currentUser);

Hope it helped!