removed easycriteria

This commit is contained in:
Athou
2013-06-08 16:15:11 +02:00
parent 2d880c92d0
commit ec163da9db
8 changed files with 166 additions and 107 deletions

View File

@@ -162,12 +162,6 @@
</exclusions> </exclusions>
</dependency> </dependency>
<dependency>
<groupId>uaihebert.com</groupId>
<artifactId>EasyCriteria</artifactId>
<version>2.1.0</version>
</dependency>
<dependency> <dependency>
<groupId>com.google.guava</groupId> <groupId>com.google.guava</groupId>
<artifactId>guava</artifactId> <artifactId>guava</artifactId>

View File

@@ -4,6 +4,9 @@ import java.util.List;
import javax.ejb.Stateless; import javax.ejb.Stateless;
import javax.persistence.NoResultException; import javax.persistence.NoResultException;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import org.apache.commons.lang.ObjectUtils; import org.apache.commons.lang.ObjectUtils;
@@ -12,39 +15,54 @@ import com.commafeed.backend.model.FeedCategory_;
import com.commafeed.backend.model.User; import com.commafeed.backend.model.User;
import com.google.common.collect.Iterables; import com.google.common.collect.Iterables;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.uaihebert.model.EasyCriteria;
@Stateless @Stateless
public class FeedCategoryDAO extends GenericDAO<FeedCategory> { public class FeedCategoryDAO extends GenericDAO<FeedCategory> {
public List<FeedCategory> findAll(User user) { public List<FeedCategory> findAll(User user) {
EasyCriteria<FeedCategory> criteria = createCriteria();
criteria.andEquals(FeedCategory_.user.getName(), user);
criteria.innerJoinFetch(FeedCategory_.user.getName()); CriteriaQuery<FeedCategory> query = builder.createQuery(getType());
return criteria.getResultList(); Root<FeedCategory> root = query.from(getType());
query.where(builder.equal(root.get(FeedCategory_.user), user));
root.fetch(FeedCategory_.user.getName());
return em.createQuery(query).getResultList();
} }
public FeedCategory findById(User user, Long id) { public FeedCategory findById(User user, Long id) {
EasyCriteria<FeedCategory> criteria = createCriteria(); CriteriaQuery<FeedCategory> query = builder.createQuery(getType());
criteria.andEquals(FeedCategory_.user.getName(), user); Root<FeedCategory> root = query.from(getType());
criteria.andEquals(FeedCategory_.id.getName(), id);
return Iterables.getFirst(criteria.getResultList(), null); Predicate p1 = builder.equal(root.get(FeedCategory_.user), user);
Predicate p2 = builder.equal(root.get(FeedCategory_.id), id);
query.where(p1, p2);
return Iterables.getFirst(em.createQuery(query).getResultList(), null);
} }
public FeedCategory findByName(User user, String name, FeedCategory parent) { public FeedCategory findByName(User user, String name, FeedCategory parent) {
EasyCriteria<FeedCategory> criteria = createCriteria(); CriteriaQuery<FeedCategory> query = builder.createQuery(getType());
criteria.andEquals(FeedCategory_.user.getName(), user); Root<FeedCategory> root = query.from(getType());
criteria.andEquals(FeedCategory_.name.getName(), name);
List<Predicate> predicates = Lists.newArrayList();
predicates.add(builder.equal(root.get(FeedCategory_.user), user));
predicates.add(builder.equal(root.get(FeedCategory_.name), name));
if (parent == null) { if (parent == null) {
criteria.andIsNull(FeedCategory_.parent.getName()); predicates.add(builder.isNull(root.get(FeedCategory_.parent)));
} else { } else {
criteria.andEquals(FeedCategory_.parent.getName(), parent); predicates
.add(builder.equal(root.get(FeedCategory_.parent), parent));
} }
query.where(predicates.toArray(new Predicate[0]));
FeedCategory category = null; FeedCategory category = null;
try { try {
category = criteria.getSingleResult(); category = em.createQuery(query).getSingleResult();
} catch (NoResultException e) { } catch (NoResultException e) {
category = null; category = null;
} }
@@ -52,15 +70,22 @@ public class FeedCategoryDAO extends GenericDAO<FeedCategory> {
} }
public List<FeedCategory> findByParent(User user, FeedCategory parent) { public List<FeedCategory> findByParent(User user, FeedCategory parent) {
EasyCriteria<FeedCategory> criteria = createCriteria(); CriteriaQuery<FeedCategory> query = builder.createQuery(getType());
criteria.andEquals(FeedCategory_.user.getName(), user); Root<FeedCategory> root = query.from(getType());
List<Predicate> predicates = Lists.newArrayList();
predicates.add(builder.equal(root.get(FeedCategory_.user), user));
if (parent == null) { if (parent == null) {
criteria.andIsNull(FeedCategory_.parent.getName()); predicates.add(builder.isNull(root.get(FeedCategory_.parent)));
} else { } else {
criteria.andEquals(FeedCategory_.parent.getName(), parent); predicates
.add(builder.equal(root.get(FeedCategory_.parent), parent));
} }
return criteria.getResultList(); query.where(predicates.toArray(new Predicate[0]));
return em.createQuery(query).getResultList();
} }
public List<FeedCategory> findAllChildrenCategories(User user, public List<FeedCategory> findAllChildrenCategories(User user,

View File

@@ -7,6 +7,7 @@ import java.util.List;
import javax.ejb.Stateless; import javax.ejb.Stateless;
import javax.persistence.TypedQuery; import javax.persistence.TypedQuery;
import javax.persistence.criteria.CriteriaQuery; import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.JoinType;
import javax.persistence.criteria.Predicate; import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root; import javax.persistence.criteria.Root;
@@ -18,7 +19,6 @@ import com.commafeed.backend.model.Feed;
import com.commafeed.backend.model.Feed_; import com.commafeed.backend.model.Feed_;
import com.google.common.collect.Iterables; import com.google.common.collect.Iterables;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.uaihebert.model.EasyCriteria;
@Stateless @Stateless
public class FeedDAO extends GenericDAO<Feed> { public class FeedDAO extends GenericDAO<Feed> {
@@ -78,13 +78,15 @@ public class FeedDAO extends GenericDAO<Feed> {
} }
public Feed findByIdWithEntries(Long feedId, int offset, int limit) { public Feed findByIdWithEntries(Long feedId, int offset, int limit) {
EasyCriteria<Feed> criteria = createCriteria(); CriteriaQuery<Feed> query = builder.createQuery(getType());
criteria.andEquals(Feed_.id.getName(), feedId); Root<Feed> root = query.from(getType());
criteria.leftJoinFetch(Feed_.entries.getName());
criteria.setFirstResult(offset); query.where(builder.equal(root.get(Feed_.id), feedId));
criteria.setMaxResults(limit); root.fetch(Feed_.entries, JoinType.LEFT);
return criteria.getSingleResult();
TypedQuery<Feed> q = em.createQuery(query);
limit(q, offset, limit);
return q.getSingleResult();
} }
public List<Feed> findByTopic(String topic) { public List<Feed> findByTopic(String topic) {

View File

@@ -31,23 +31,27 @@ import com.commafeed.backend.model.User;
import com.commafeed.backend.model.UserSettings.ReadingOrder; import com.commafeed.backend.model.UserSettings.ReadingOrder;
import com.google.api.client.util.Lists; import com.google.api.client.util.Lists;
import com.google.api.client.util.Maps; import com.google.api.client.util.Maps;
import com.uaihebert.model.EasyCriteria;
@Stateless @Stateless
public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> { public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> {
@SuppressWarnings("unchecked")
public FeedEntryStatus findById(User user, Long id) { public FeedEntryStatus findById(User user, Long id) {
EasyCriteria<FeedEntryStatus> criteria = createCriteria(); CriteriaQuery<FeedEntryStatus> query = builder.createQuery(getType());
criteria.andEquals(FeedEntryStatus_.id.getName(), id); Root<FeedEntryStatus> root = query.from(getType());
criteria.innerJoinFetch(FeedEntryStatus_.subscription.getName()); Join<FeedEntryStatus, FeedSubscription> join = (Join<FeedEntryStatus, FeedSubscription>) root
criteria.andJoinEquals(FeedEntryStatus_.subscription.getName(), .fetch(FeedEntryStatus_.subscription);
FeedSubscription_.user.getName(), user);
Predicate p1 = builder.equal(root.get(FeedEntryStatus_.id), id);
Predicate p2 = builder.equal(join.get(FeedSubscription_.user), user);
query.where(p1, p2);
FeedEntryStatus status = null; FeedEntryStatus status = null;
try { try {
status = criteria.getSingleResult(); status = em.createQuery(query).getSingleResult();
} catch (NoResultException e) { } catch (NoResultException e) {
status = null; status = null;
} }

View File

@@ -3,6 +3,10 @@ package com.commafeed.backend.dao;
import java.util.List; import java.util.List;
import javax.ejb.Stateless; import javax.ejb.Stateless;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.JoinType;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import com.commafeed.backend.model.Feed; import com.commafeed.backend.model.Feed;
import com.commafeed.backend.model.FeedCategory; import com.commafeed.backend.model.FeedCategory;
@@ -10,59 +14,83 @@ import com.commafeed.backend.model.FeedSubscription;
import com.commafeed.backend.model.FeedSubscription_; import com.commafeed.backend.model.FeedSubscription_;
import com.commafeed.backend.model.User; import com.commafeed.backend.model.User;
import com.google.common.collect.Iterables; import com.google.common.collect.Iterables;
import com.uaihebert.factory.EasyCriteriaFactory;
import com.uaihebert.model.EasyCriteria;
@Stateless @Stateless
public class FeedSubscriptionDAO extends GenericDAO<FeedSubscription> { public class FeedSubscriptionDAO extends GenericDAO<FeedSubscription> {
public FeedSubscription findById(User user, Long id) { public FeedSubscription findById(User user, Long id) {
EasyCriteria<FeedSubscription> criteria = createCriteria(); CriteriaQuery<FeedSubscription> query = builder.createQuery(getType());
criteria.andEquals(FeedSubscription_.user.getName(), user); Root<FeedSubscription> root = query.from(getType());
criteria.andEquals(FeedSubscription_.id.getName(), id);
criteria.leftJoinFetch(FeedSubscription_.feed.getName()); Predicate p1 = builder.equal(root.get(FeedSubscription_.user), user);
criteria.leftJoinFetch(FeedSubscription_.category.getName()); Predicate p2 = builder.equal(root.get(FeedSubscription_.id), id);
return Iterables.getFirst(criteria.getResultList(), null);
root.fetch(FeedSubscription_.feed, JoinType.LEFT);
root.fetch(FeedSubscription_.category, JoinType.LEFT);
query.where(p1, p2);
return Iterables.getFirst(em.createQuery(query).getResultList(), null);
} }
public List<FeedSubscription> findByFeed(Feed feed) { public List<FeedSubscription> findByFeed(Feed feed) {
EasyCriteria<FeedSubscription> criteria = createCriteria(); return findByField(FeedSubscription_.feed, feed);
criteria.andEquals(FeedSubscription_.feed.getName(), feed);
return criteria.getResultList();
} }
public FeedSubscription findByFeed(User user, Feed feed) { public FeedSubscription findByFeed(User user, Feed feed) {
EasyCriteria<FeedSubscription> criteria = createCriteria();
criteria.andEquals(FeedSubscription_.user.getName(), user); CriteriaQuery<FeedSubscription> query = builder.createQuery(getType());
criteria.andEquals(FeedSubscription_.feed.getName(), feed); Root<FeedSubscription> root = query.from(getType());
return Iterables.getFirst(criteria.getResultList(), null);
Predicate p1 = builder.equal(root.get(FeedSubscription_.user), user);
Predicate p2 = builder.equal(root.get(FeedSubscription_.feed), feed);
root.fetch(FeedSubscription_.feed, JoinType.LEFT);
root.fetch(FeedSubscription_.category, JoinType.LEFT);
query.where(p1, p2);
return Iterables.getFirst(em.createQuery(query).getResultList(), null);
} }
public List<FeedSubscription> findAll(User user) { public List<FeedSubscription> findAll(User user) {
EasyCriteria<FeedSubscription> criteria = createCriteria();
criteria.andEquals(FeedSubscription_.user.getName(), user);
criteria.innerJoinFetch(FeedSubscription_.feed.getName()); CriteriaQuery<FeedSubscription> query = builder.createQuery(getType());
criteria.leftJoinFetch(FeedSubscription_.category.getName()); Root<FeedSubscription> root = query.from(getType());
return criteria.getResultList();
root.fetch(FeedSubscription_.feed, JoinType.LEFT);
root.fetch(FeedSubscription_.category, JoinType.LEFT);
query.where(builder.equal(root.get(FeedSubscription_.user), user));
return em.createQuery(query).getResultList();
} }
public List<FeedSubscription> findByCategory(User user, public List<FeedSubscription> findByCategory(User user,
FeedCategory category) { FeedCategory category) {
EasyCriteria<FeedSubscription> criteria = EasyCriteriaFactory
.createQueryCriteria(em, getType());
criteria.andEquals(FeedSubscription_.user.getName(), user);
criteria.andEquals(FeedSubscription_.category.getName(), category);
return criteria.getResultList();
CriteriaQuery<FeedSubscription> query = builder.createQuery(getType());
Root<FeedSubscription> root = query.from(getType());
Predicate p1 = builder.equal(root.get(FeedSubscription_.user), user);
Predicate p2 = builder.equal(root.get(FeedSubscription_.category),
category);
query.where(p1, p2);
return em.createQuery(query).getResultList();
} }
public List<FeedSubscription> findWithoutCategories(User user) { public List<FeedSubscription> findWithoutCategories(User user) {
EasyCriteria<FeedSubscription> criteria = EasyCriteriaFactory
.createQueryCriteria(em, getType());
criteria.andEquals(FeedSubscription_.user.getName(), user);
criteria.andIsNull(FeedSubscription_.category.getName());
return criteria.getResultList();
CriteriaQuery<FeedSubscription> query = builder.createQuery(getType());
Root<FeedSubscription> root = query.from(getType());
Predicate p1 = builder.equal(root.get(FeedSubscription_.user), user);
Predicate p2 = builder.isNull(root.get(FeedSubscription_.category));
query.where(p1, p2);
return em.createQuery(query).getResultList();
} }
} }

View File

@@ -17,8 +17,6 @@ import org.hibernate.Session;
import com.commafeed.backend.model.AbstractModel; import com.commafeed.backend.model.AbstractModel;
import com.google.common.reflect.TypeToken; import com.google.common.reflect.TypeToken;
import com.uaihebert.factory.EasyCriteriaFactory;
import com.uaihebert.model.EasyCriteria;
@SuppressWarnings("serial") @SuppressWarnings("serial")
public abstract class GenericDAO<T extends AbstractModel> { public abstract class GenericDAO<T extends AbstractModel> {
@@ -73,30 +71,36 @@ public abstract class GenericDAO<T extends AbstractModel> {
} }
public List<T> findAll() { public List<T> findAll() {
return EasyCriteriaFactory.createQueryCriteria(em, getType()) CriteriaQuery<T> query = builder.createQuery(getType());
.getResultList(); query.from(getType());
return em.createQuery(query).getResultList();
} }
public List<T> findAll(int startIndex, int count) { public List<T> findAll(int startIndex, int count) {
EasyCriteria<T> criteria = EasyCriteriaFactory.createQueryCriteria(em, CriteriaQuery<T> query = builder.createQuery(getType());
getType()); query.from(getType());
criteria.setMaxResults(count); TypedQuery<T> q = em.createQuery(query);
criteria.setFirstResult(startIndex); q.setMaxResults(count);
return criteria.getResultList(); q.setFirstResult(startIndex);
return q.getResultList();
} }
public List<T> findAll(int startIndex, int count, String orderBy, public List<T> findAll(int startIndex, int count, String orderBy,
boolean asc) { boolean asc) {
EasyCriteria<T> criteria = EasyCriteriaFactory.createQueryCriteria(em,
getType()); CriteriaQuery<T> query = builder.createQuery(getType());
criteria.setMaxResults(count); Root<T> root = query.from(getType());
criteria.setFirstResult(startIndex);
if (asc) { if (asc) {
criteria.orderByAsc(orderBy); query.orderBy(builder.asc(root.get(orderBy)));
} else { } else {
criteria.orderByDesc(orderBy); query.orderBy(builder.desc(root.get(orderBy)));
} }
return criteria.getResultList();
TypedQuery<T> q = em.createQuery(query);
q.setMaxResults(count);
q.setFirstResult(startIndex);
return q.getResultList();
} }
public long getCount() { public long getCount() {
@@ -107,10 +111,12 @@ public abstract class GenericDAO<T extends AbstractModel> {
return em.createQuery(query).getSingleResult(); return em.createQuery(query).getSingleResult();
} }
public <V> List<T> findByField(Attribute<T, V> field, V value) { protected <V> List<T> findByField(Attribute<T, V> field, V value) {
EasyCriteria<T> criteria = createCriteria(); CriteriaQuery<T> query = builder.createQuery(getType());
criteria.andEquals(field.getName(), value); Root<T> root = query.from(getType());
return criteria.getResultList();
query.where(builder.equal(root.get(field.getName()), value));
return em.createQuery(query).getResultList();
} }
protected void limit(TypedQuery<?> query, int offset, int limit) { protected void limit(TypedQuery<?> query, int offset, int limit) {
@@ -126,8 +132,4 @@ public abstract class GenericDAO<T extends AbstractModel> {
protected Class<T> getType() { protected Class<T> getType() {
return (Class<T>) type.getRawType(); return (Class<T>) type.getRawType();
} }
public EasyCriteria<T> createCriteria() {
return EasyCriteriaFactory.createQueryCriteria(em, getType());
}
} }

View File

@@ -4,25 +4,28 @@ import java.util.List;
import java.util.Set; import java.util.Set;
import javax.ejb.Stateless; import javax.ejb.Stateless;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.JoinType;
import javax.persistence.criteria.Root;
import com.commafeed.backend.model.User; import com.commafeed.backend.model.User;
import com.commafeed.backend.model.UserRole; import com.commafeed.backend.model.UserRole;
import com.commafeed.backend.model.UserRole.Role; import com.commafeed.backend.model.UserRole.Role;
import com.commafeed.backend.model.UserRole_; import com.commafeed.backend.model.UserRole_;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
import com.uaihebert.factory.EasyCriteriaFactory;
import com.uaihebert.model.EasyCriteria;
@Stateless @Stateless
public class UserRoleDAO extends GenericDAO<UserRole> { public class UserRoleDAO extends GenericDAO<UserRole> {
@Override @Override
public List<UserRole> findAll() { public List<UserRole> findAll() {
EasyCriteria<UserRole> criteria = EasyCriteriaFactory CriteriaQuery<UserRole> query = builder.createQuery(getType());
.createQueryCriteria(em, getType()); Root<UserRole> root = query.from(getType());
criteria.setDistinctTrue(); query.distinct(true);
criteria.leftJoinFetch(UserRole_.user.getName());
return criteria.getResultList(); root.fetch(UserRole_.user, JoinType.LEFT);
return em.createQuery(query).getResultList();
} }
public List<UserRole> findAll(User user) { public List<UserRole> findAll(User user) {

View File

@@ -2,25 +2,26 @@ package com.commafeed.backend.dao;
import javax.ejb.Stateless; import javax.ejb.Stateless;
import javax.persistence.NoResultException; import javax.persistence.NoResultException;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Root;
import com.commafeed.backend.model.User; import com.commafeed.backend.model.User;
import com.commafeed.backend.model.UserSettings; import com.commafeed.backend.model.UserSettings;
import com.commafeed.backend.model.UserSettings_; import com.commafeed.backend.model.UserSettings_;
import com.uaihebert.factory.EasyCriteriaFactory;
import com.uaihebert.model.EasyCriteria;
@Stateless @Stateless
public class UserSettingsDAO extends GenericDAO<UserSettings> { public class UserSettingsDAO extends GenericDAO<UserSettings> {
public UserSettings findByUser(User user) { public UserSettings findByUser(User user) {
EasyCriteria<UserSettings> criteria = EasyCriteriaFactory CriteriaQuery<UserSettings> query = builder.createQuery(getType());
.createQueryCriteria(em, getType()); Root<UserSettings> root = query.from(getType());
criteria.andEquals(UserSettings_.user.getName(), user);
query.where(builder.equal(root.get(UserSettings_.user), user));
UserSettings settings = null; UserSettings settings = null;
try { try {
settings = criteria.getSingleResult(); settings = em.createQuery(query).getSingleResult();
} catch (NoResultException e) { } catch (NoResultException e) {
settings = null; settings = null;
} }