faster cleanup query

src/main/java/com/commafeed/backend/DatabaseCleaner.java

@@ -12,14 +12,11 @@ public class DatabaseCleaner {
 	@Inject
 	FeedEntryStatusDAO feedEntryStatusDAO;
 
-	public void cleanOlderThan(long value, TimeUnit unit) {
+	public int cleanOlderThan(long value, TimeUnit unit) {
 		Calendar cal = Calendar.getInstance();
 		cal.add(Calendar.MINUTE, -1 * (int) unit.toMinutes(value));
 
-		int deleted = -1;
-		do {
-			deleted = feedEntryStatusDAO.delete(cal.getTime(), 1000);
-		} while (deleted != 0);
+		return feedEntryStatusDAO.delete(cal.getTime());
 
 	}
 }

src/main/java/com/commafeed/backend/dao/FeedEntryStatusDAO.java

@@ -307,24 +307,10 @@ public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> {
 		query.setHint("javax.persistence.query.timeout", 20000);
 	}
 
-	public int delete(Date olderThan, int max) {
-		CriteriaQuery<FeedEntryStatus> query = builder.createQuery(getType());
-		Root<FeedEntryStatus> root = query.from(getType());
-		Join<FeedEntryStatus, FeedEntry> entryJoin = root
-				.join(FeedEntryStatus_.entry);
-
-		Predicate p1 = builder.lessThan(entryJoin.get(FeedEntry_.inserted),
-				olderThan);
-		Predicate p2 = builder.isFalse(root.get(FeedEntryStatus_.starred));
-
-		query.where(p1, p2);
-
-		TypedQuery<FeedEntryStatus> q = em.createQuery(query);
-		q.setMaxResults(max);
-
-		List<FeedEntryStatus> list = q.getResultList();
-		int deleted = list.size();
-		delete(list);
+	public int delete(Date olderThan) {
+		Query query = em.createNamedQuery("EntryStatus.deleteOlderThan");
+		query.setParameter("olderThan", olderThan);
+		int deleted = query.executeUpdate();
 		return deleted;
 	}
 

src/main/java/com/commafeed/frontend/rest/resources/AdminREST.java

@@ -194,8 +194,8 @@ public class AdminREST extends AbstractResourceREST {
 	@Path("/cleanup")
 	@GET
 	public Response cleanup() {
-		cleaner.cleanOlderThan(30, TimeUnit.DAYS);
-		return Response.ok("ok").build();
+		int deleted = cleaner.cleanOlderThan(30, TimeUnit.DAYS);
+		return Response.ok("ok: " + deleted).build();
 	}
 
 }

src/main/resources/META-INF/orm.xml

@@ -9,4 +9,8 @@
 		<query>select sub.id, count(s) from FeedEntryStatus s LEFT JOIN s.subscription sub where sub.user=:user and s.read=false group by sub.id</query>
 	</named-query>
 	
+	<named-query name="EntryStatus.deleteOlderThan">
+		<query>delete from FeedEntryStatus s where s in (select s2 from FeedEntryStatus s2 where s2.starred = false and s2.entry.inserted &lt; :olderThan)</query>
+	</named-query>
+	
 </entity-mappings>