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

How to implement a generic DAO with the same Entity Manager in java EE 8

我是 Java EE 和 JPA 的初学者。过去我一直在创建一个简单的 web 项目,我已经实现了一个没有 CDI 的 generci DAO 模式,处理 Enitiry Manager.I 知道不同的 EntityManager 可以使用相同的持久上下文但是因为持久上下文是一个黑盒子对我来说,我在 DAO 构造器中注入一个 EntityManager 将其作为 argument.I 传递,使用此方法有两个原因:

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

下面是泛型 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);
    }
}

现在我想使用 Java EntityManager 的 EE 注入来实现相同的模式。经过一番搜索后,我发现了如下相同的解决方案:

GenericDAO 在 Javaee

    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 实例。如果我想保留用户并更新标签,这会成为问题吗?我可以举这样的例子吗?包括优点和缺点。

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

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