在 Facade 模式中创建 namedQuery 的代码应该放在哪里？

Question

我正在为我的应用程序使用 GWT、Oracle 数据库、Glassfish 服务器、JPA。客户端没有问题。也在服务器端使用 Facade 模式。

AbstractFacade.java

public abstract class AbstractFacade<T> {
private Class<T> entityClass;

public AbstractFacade(Class<T> entityClass) {
    this.entityClass = entityClass;
}

protected abstract EntityManager getEntityManager();

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

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

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

public T find(Object id) {
    return getEntityManager().find(entityClass, id);
}

public List<T> findAll() {
    javax.persistence.criteria.CriteriaQuery cq = getEntityManager().getCriteriaBuilder().createQuery();
    cq.select(cq.from(entityClass));
    return getEntityManager().createQuery(cq).getResultList();
}

public List<T> findRange(int[] range) {
    javax.persistence.criteria.CriteriaQuery cq = getEntityManager().getCriteriaBuilder().createQuery();
    cq.select(cq.from(entityClass));
    javax.persistence.Query q = getEntityManager().createQuery(cq);
    q.setMaxResults(range[1] - range[0] + 1);
    q.setFirstResult(range[0]);
    return q.getResultList();
}

public int count() {
    javax.persistence.criteria.CriteriaQuery cq = getEntityManager().getCriteriaBuilder().createQuery();
    javax.persistence.criteria.Root<T> rt = cq.from(entityClass);
    cq.select(getEntityManager().getCriteriaBuilder().count(rt));
    javax.persistence.Query q = getEntityManager().createQuery(cq);
    return ((Long) q.getSingleResult()).intValue();
}

GroupFacade.java

@Stateless
public class GroupsFacade extends AbstractFacade<Groups> implements GroupsFacadeLocal {
    @PersistenceContext(unitName = "exam_ejb_1.0PU")
    private EntityManager em;

    @Override
    protected EntityManager getEntityManager() {
        return em;
    }

    public GroupsFacade() {
        super(Groups.class);
    }
}

GroupsFacadeLocal.java

@Local
public interface GroupsFacadeLocal {

    void create(Groups groups);

    void edit(Groups groups);

    void remove(Groups groups);

    Groups find(Object id);

    List<Groups> findAll();

    List<Groups> findRange(int[] range);

    int count();

}

Groups.java

@Entity
@Table(name = "GROUPS")
@XmlRootElement
@NamedQueries({
    @NamedQuery(name = "Groups.findAll", query = "SELECT a FROM AtsTestJautajumsGrupas a"),
    @NamedQuery(name = "Grous.findByTestId", query = "SELECT a FROM Groups a WHERE a.TestId = :TestId")})
public class Groups implements Serializable {
    private static final long serialVersionUID = 1L;
    @Id
    @Basic(optional = false)
    @NotNull
    @Column(name = "GROUP_ID")
    private BigDecimal groupId;
    @Size(max = 200)
    @Column(name = "name")
    private String name;
    @Column(name = "ARCHIVE_STAT")
    private String archiveStat;
    @OneToMany(mappedBy = "GroupId")
    private Collection<Question> questionCollection;
    @JoinColumn(name = "TEST_ID", referencedColumnName = "TEST_ID")
    @ManyToOne
    private Test atsTestId;

    public Groups() {
    }

    //Getters and Setter here...
}

所以我从 db 创建或查找所有记录没有任何问题。

 public class ServiceImpl extends RemoteServiceServlet implements Service {
        @EJB
            AtsTestJautajumsGrupasFacadeLocal grupasEJB;
        @Override
            public List<Groups> getCategories() {

                List<Groups> grupas = new ArrayList<Groups>();
                grupas = grupasEJB.findAll();

                return grupas;
            }

但现在我需要选择具有相同Test_id 的组。我创建了@NamedQuery(name = "Grous.findByTestId"...，现在我有点迷路了。

所以我的问题是：如何使用 NamedQuery？我在哪里创建一个访问 db.我需要从 ServiceImpl 访问该方法。这样做的正确方法是什么？

已编辑： 还有一个问题。何时以及为什么我应该使用 CriteriaBuilder 而不是您的建议？示例：

public AtsTestJautajums getJautajums(Integer atsTestJautajumsId) {
        CriteriaBuilder cb = em.getCriteriaBuilder();
        CriteriaQuery<AtsTestJautajums> q = cb.createQuery(AtsTestJautajums.class);
        Root<AtsTestJautajums> atsTestJautajums = q.from(AtsTestJautajums.class);
        List<Predicate> predicateList = new ArrayList<Predicate>();
        Predicate atsTestJautajumsIdPredicate;
        if (atsTestJautajumsId != null) {
            atsTestJautajumsIdPredicate = cb.equal(atsTestJautajums.<String>get("atsTestJautajumsId"), atsTestJautajumsId);
            predicateList.add(atsTestJautajumsIdPredicate);
        }
        Predicate[] predicates = new Predicate[predicateList.size()];
        predicateList.toArray(predicates);
        q.where(predicates);
        TypedQuery<AtsTestJautajums> query = em.createQuery(q);
        return query.getSingleResult();
    }

Answer 1

我不知道你的项目是如何工作的以及你是如何编写代码的，但基本上我认为下面的示例包含了你需要做的一切。

public List<Groups> getCategoriesByTestId(Test test){
   return em().createNamedQuery("Grous.findByTestId", Groups .class).setParameter("TestId", test.getId()).getResultList();
}

并且您的方法应该在您使用的任何服务中调用（在您的代码中似乎是 ServiceImpl），并在 DAO 中实现您的方法，该 DAO 使用 jpa 处理所有数据库访问（在您的代码中似乎是 GroupsFacade）。不要忘记在 GroupsFacadeLocal 中声明您的方法原型。如果我能很好地理解您的代码，我想就是这样。