diff --git a/src/main/java/com/commafeed/backend/dao/GenericDAO.java b/src/main/java/com/commafeed/backend/dao/GenericDAO.java index f2217971..3a449a27 100644 --- a/src/main/java/com/commafeed/backend/dao/GenericDAO.java +++ b/src/main/java/com/commafeed/backend/dao/GenericDAO.java @@ -27,6 +27,14 @@ public abstract class GenericDAO extends AbstractDAO models.forEach(m -> persist(m)); } + public void update(T model) { + currentSession().update(model); + } + + public void update(Collection models) { + models.forEach(m -> update(m)); + } + public void merge(T model) { currentSession().merge(model); } diff --git a/src/main/java/com/commafeed/backend/feed/FeedQueues.java b/src/main/java/com/commafeed/backend/feed/FeedQueues.java index 88adccaa..8be30e2f 100644 --- a/src/main/java/com/commafeed/backend/feed/FeedQueues.java +++ b/src/main/java/com/commafeed/backend/feed/FeedQueues.java @@ -136,7 +136,7 @@ public class FeedQueues { // update all feeds in the database List feeds = map.values().stream().filter(c -> config.getApplicationSettings().getHeavyLoad() ? !c.isUrgent() : true) .map(c -> c.getFeed()).collect(Collectors.toList()); - UnitOfWork.run(sessionFactory, () -> feedDAO.merge(feeds)); + UnitOfWork.run(sessionFactory, () -> feedDAO.update(feeds)); } /**