database agnostic cleanup query

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

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

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

@@ -307,10 +307,30 @@ public class FeedEntryStatusDAO extends GenericDAO<FeedEntryStatus> {
 		query.setHint("javax.persistence.query.timeout", 20000);
 	}
 
-	public int delete(Date olderThan) {
-		Query query = em.createNamedQuery("EntryStatus.deleteOlderThan");
-		query.setParameter("olderThan", olderThan);
-		int deleted = query.executeUpdate();
+	public int delete(Date olderThan, int max) {
+		CriteriaQuery<Long> query = builder.createQuery(Long.class);
+		Root<FeedEntryStatus> root = query.from(getType());
+		query.select(root.get(FeedEntryStatus_.id));
+
+		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<Long> q = em.createQuery(query);
+		q.setMaxResults(max);
+		List<Long> ids = q.getResultList();
+
+		int deleted = 0;
+		if (ids.isEmpty() == false) {
+			Query deleteQuery = em.createNamedQuery("EntryStatus.deleteByIds");
+			deleteQuery.setParameter("ids", ids);
+			deleted = deleteQuery.executeUpdate();
+		}
 		return deleted;
 	}
 

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

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