forked from Archives/Athou_commafeed
75 lines
2.3 KiB
Java
75 lines
2.3 KiB
Java
package com.commafeed.backend.dao;
|
|
|
|
import java.util.List;
|
|
|
|
import javax.ejb.Stateless;
|
|
import javax.persistence.TypedQuery;
|
|
import javax.persistence.criteria.CriteriaQuery;
|
|
import javax.persistence.criteria.JoinType;
|
|
import javax.persistence.criteria.Root;
|
|
import javax.persistence.criteria.SetJoin;
|
|
|
|
import org.apache.commons.codec.digest.DigestUtils;
|
|
import org.hibernate.Hibernate;
|
|
|
|
import com.commafeed.backend.model.Feed;
|
|
import com.commafeed.backend.model.FeedEntry;
|
|
import com.commafeed.backend.model.FeedEntry_;
|
|
import com.commafeed.backend.model.Feed_;
|
|
import com.google.common.collect.Lists;
|
|
|
|
@Stateless
|
|
public class FeedEntryDAO extends GenericDAO<FeedEntry> {
|
|
|
|
public List<FeedEntry> findByGuid(String guid) {
|
|
String hash = DigestUtils.sha1Hex(guid);
|
|
|
|
CriteriaQuery<FeedEntry> query = builder.createQuery(getType());
|
|
Root<FeedEntry> root = query.from(getType());
|
|
|
|
query.distinct(true);
|
|
query.where(builder.equal(root.get(FeedEntry_.guidHash), hash));
|
|
|
|
TypedQuery<FeedEntry> q = em.createQuery(query);
|
|
List<FeedEntry> list = q.getResultList();
|
|
for (FeedEntry entry : list) {
|
|
Hibernate.initialize(entry.getFeeds());
|
|
}
|
|
return list;
|
|
}
|
|
|
|
public List<FeedEntry> findByGuids(List<String> guids) {
|
|
List<String> hashes = Lists.newArrayList();
|
|
for (String guid : guids) {
|
|
hashes.add(DigestUtils.sha1Hex(guid));
|
|
}
|
|
|
|
CriteriaQuery<FeedEntry> query = builder.createQuery(getType());
|
|
Root<FeedEntry> root = query.from(getType());
|
|
|
|
query.distinct(true);
|
|
query.where(root.get(FeedEntry_.guidHash).in(hashes));
|
|
root.fetch(FeedEntry_.feeds, JoinType.LEFT);
|
|
|
|
TypedQuery<FeedEntry> q = em.createQuery(query);
|
|
List<FeedEntry> list = q.getResultList();
|
|
for (FeedEntry entry : list) {
|
|
Hibernate.initialize(entry.getFeeds());
|
|
}
|
|
return list;
|
|
}
|
|
|
|
public List<FeedEntry> findByFeed(Feed feed, int offset, int limit) {
|
|
CriteriaQuery<FeedEntry> query = builder.createQuery(getType());
|
|
Root<FeedEntry> root = query.from(getType());
|
|
SetJoin<FeedEntry, Feed> feedsJoin = root.join(FeedEntry_.feeds);
|
|
|
|
query.distinct(true);
|
|
query.where(builder.equal(feedsJoin.get(Feed_.id), feed.getId()));
|
|
query.orderBy(builder.desc(root.get(FeedEntry_.updated)));
|
|
TypedQuery<FeedEntry> q = em.createQuery(query);
|
|
limit(q, offset, limit);
|
|
return q.getResultList();
|
|
}
|
|
}
|