Archives/Athou_commafeed
1
0
Fork 1
mirror of https://github.com/Athou/commafeed.git synced 2026-03-21 21:37:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

faster inserts

Browse Source
This commit is contained in:
Athou
2013-03-25 23:33:06 +01:00
parent ef209ea321
commit def27c5f9f
2 changed files with 32 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/main/java/com/commafeed/backend/dao/FeedEntryService.java
View File

@@ -8,11 +8,14 @@ import javax.ejb.Stateless;
import javax.inject.Inject;
import javax.persistence.TypedQuery;
import org.apache.commons.lang.StringUtils;
import com.commafeed.backend.model.Feed;
import com.commafeed.backend.model.FeedEntry;
import com.commafeed.backend.model.User;
import com.commafeed.frontend.utils.ModelFactory.MF;
import com.google.common.collect.Iterables;
import com.google.common.collect.Lists;
@Stateless
@SuppressWarnings("serial")
@@ -25,18 +28,37 @@ public class FeedEntryService extends GenericDAO<FeedEntry, Long> {
Feed feed = Iterables.getFirst(
feedService.findByField(MF.i(MF.p(Feed.class).getUrl()), url),
null);
List<String> guids = Lists.newArrayList();
for (FeedEntry entry : entries) {
FeedEntry existing = Iterables.getFirst(
findByField(MF.i(MF.p(getType()).getGuid()),
entry.getGuid()), null);
if (existing == null) {
guids.add(entry.getGuid());
}
List<FeedEntry> existingEntries = getByGuids(guids);
for (FeedEntry entry : entries) {
boolean found = false;
for (FeedEntry existingEntry : existingEntries) {
if (StringUtils
.equals(entry.getGuid(), existingEntry.getGuid())) {
found = true;
break;
}
}
if (!found) {
entry.setFeed(feed);
save(entry);
}
}
feed.setLastUpdated(Calendar.getInstance().getTime());
feed.setMessage(null);
em.merge(feed);
feedService.update(feed);
}
public List<FeedEntry> getByGuids(List<String> guids) {
TypedQuery<FeedEntry> query = em.createNamedQuery("Entry.byGuids",
FeedEntry.class);
query.setParameter("guids", guids);
return query.getResultList();
}
public List<FeedEntry> getEntries(Feed feed, User user, boolean read) {