如何在Java EE 8中使用相同的Entity Manager实现通用DAO

Question

我是Java EE和JPA的入门者。过去我一直在创建一个简单的Web项目，并在不使用CDI的情况下实现了通用的DAO模式来处理Enitiry Manager。我知道不同的EntityManager可以使用相同的持久性上下文，但是因为持久性上下文对我来说是一个黑匣子，我向DAO承包商注入了一个EntityManager并将其作为参数传递。我使用此方法有两个原因：

1. 分别进行与不同操作有关的操作实体。
2. 处理并发问题，因为所有操作将在同一EntityManager中进行，Trasanction

这里是通用DAO的代码：

GenericDAO

import java.util.List ;
import javax.persistence.EntityManager ;
import javax.persistence.Query ;

public abstract class GenericDAO<T> {

    protected final Class<T> persistentClass;
    protected final EntityManager em;

    public GenericDAO(EntityManager em, Class<T> persistencClass) {
        this.persistentClass = persistencClass;
        this.em = em;
    }

    public List<T> find(int id) {
        List<T> list;
        Query query = em.createQuery("select e from " + persistentClass.getSimpleName() + " e" + " where e.id =:id").setParameter("id", id);
        list = query.getResultList();
        return list;
    }

    public List<T> findAll() {
        List<T> list;
        Query query = em.createQuery("select e from " + persistentClass.getSimpleName() + " e");
        list = query.getResultList();
        return list;
    }

    public void create(T entity) {
        em.persist(entity);
    }

    public void edit(T entity) {
        em.merge(entity);
    }

    public void remove(T entity) {
        em.remove(em.merge(entity));
    }
}

通用DAO的实际实现，下面的代码：

UserDAOImpl

import java.util.List;
import entities.User;
import javax.persistence.EntityManager;
import javax.persistence.Query;

public class UserDAOImpl extends GenericDAO<User> {
     public UserDAOImpl(EntityManager em) {
           super(em, User.class);
     } 
}

TagDAOImpl

import entities.Tag ;
import java.util.List ;
import javax.persistence.EntityManager ;
import javax.persistence.Query ;

public class TagDAOImpl extends GenericDAO<Tag> {

    public TagDAOImpl(EntityManager em) {
        super(em, Tag.class);
    }
}

现在，我想使用EntityManager的Java EE注入实现相同的模式。经过良好的搜索，我发现了如下相同的解决方案：

Java中的GenericDAO ee

    public abstract class BaseDAO<T extends AbstractEntity> {

    private Class<T> entityClass() {
        @SuppressWarnings("unchecked")
        ParameterizedType parameterizedType = (ParameterizedType) this.getClass().getGenericSuperclass();
        return (Class<T>) parameterizedType.getActualTypeArguments()[0];
    }

    protected abstract EntityManager entityManager();

    private final String SELECT_ALL = "SELECT e FROM ";
    private final String SELECT_COUNT = "SELECT COUNT(e) FROM ";
    private final String INSTANCE = " e";

    public List<T> findAll() {
        return entityManager()
                .createQuery(SELECT_ALL + entityClass().getSimpleName() + INSTANCE)
                .getResultList();
    }

    public Long count() {
        Object resulet = entityManager()
                .createQuery(SELECT_COUNT + entityClass().getSimpleName() + INSTANCE)
                .getSingleResult();
        return (Long) resulet;
    }
}

Java ee中通用DAO的实际实现，下面的代码：

UserDAO

@Stateless
public class UserDAO extends BaseDAO<User> {

    @Inject
    protected EntityManager entityManger;

    @Override
    protected EntityManager entityManager() {
        return this.entityManger;
    }
}

TagDAO

@Stateless
public class TagDAO extends BaseDAO<Tag> {

    @Inject
    protected EntityManager entityManger;

    @Override
    protected EntityManager entityManager() {
        return this.entityManger;
    }

}

我的问题是，如果我在UserDAO和TagDAO中注入EntityManager，则我有两个不同的EntityManager实例。如果我要保留用户并更新标签，会不会有问题？我可以举一个例子吗？包括优缺点。

Answer 1

首先，您可以应用DRY概念将@Inject私有EntityManager添加到您的GenericDAO类中。EntityManager的用法及其唯一性将主要取决于您在生产方法上选择的范围。如果确定所有请求都将在@RequestScoped环境中处理，则可以使用此作用域生成EntityManager，并且所有DAO将共享相同的bean（只要它们在相同的请求上）。

要生成具有请求范围的EntityManager，可以使用CDI bean和生产者字段或方法，例如：

@ApplicationScoped
public class EntityManagerProducer implements Serializable {

    @Produces
    @RequestScoped
    // @MyBusinessDatabase // A qualifier so you can select different databases
    @PersistenceContext
    private EntityManager entityManager;

}

您还可以使用@Dependent伪作用域。在这种情况下，每个注入的entityManager对注入的bean都是唯一的。请检查this和this。由于EntityManager是轻量级实体（与EntityManagerFactory相对），因此使用这种范围的开销很小，并且与@RequestScoped Bean相比，我们有一个优势，即可以在非请求操作中使用相同的Bean，例如异步或自动服务器端调用。

我已经使用@Depended作用域实体管理器已有相当长的一段时间了，它们具有不同的JPA实现（Eclipselink和OpenJPA），没有任何问题，但是当一个给定的实体实例同时被太多线程更新时，普通的乐观锁异常时间。如果情况很紧急，您可以使用悲观的方法来处理这些情况。