java - 如何在 java EE 8 中使用相同的实体管理器实现通用 DAO

Question

我是 Java EE 和 JPA 的初学者。过去，我一直在创建一个简单的 Web 项目，并且在没有 CDI 的情况下实现了通用 DAO 模式，处理 Enitiry Manager。我知道不同的 EntityManager 可以使用相同的持久上下文，但因为持久上下文对我来说是一个黑匣子，我在 DAO 构造函数中注入(inject)一个 EntityManager，并将其作为参数传递。我使用这种方法有两个原因:

1. 将与不同相关的操作分开实体。
2. 处理并发问题，因为所有操作将在同一个 EntityManager 中处理并且交易

这是通用 DAO 的代码:

通用DAO

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 注入(inject)来实现相同的模式。经过一番搜索后，我发现了相同的解决方案，如下所示:

Java ee 中的 GenericDAO

    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 中注入(inject) EntityManager，我就会有两个不同的 EntityManager 实例。如果我想保留用户并更新标签，这会成为问题吗？我能举个这样的例子吗？包括优点和缺点。

Answer 1

首先，您可以将 @Inject 私有(private) EntityManager 添加到您的 GenericDAO 类中，应用 DRY 概念。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伪作用域。在这种情况下，注入(inject)的每个entityManager对于注入(inject)的bean来说都是唯一的。请查看this和 this 。由于 EntityManager 是一个轻量级实体(与 EntityManagerFactory 相对)，因此使用此类范围的开销很小，并且与 @RequestScoped beans 相比，我们有一个优势，可以在非请求操作中使用相同的 bean，例如异步或自动服务器端调用。

我已经使用 @Depended 作用域实体管理器有一段时间了，使用不同的 JPA 实现(Eclipselink 和 OpenJPA)没有任何问题，但当一个给定的实体实例被太多线程更新时，会出现普通的乐观锁异常。同时。当情况危急时，你可能会用悲观的态度来处理这些情况。