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

52 lines
1.3 KiB
Java
Raw Normal View History

package com.commafeed.backend;
import java.util.Calendar;
import java.util.concurrent.TimeUnit;
import javax.inject.Inject;
2013-06-18 13:28:15 +02:00
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
2013-06-19 17:01:28 +02:00
import com.commafeed.backend.dao.FeedDAO;
2013-06-19 13:29:56 +02:00
import com.commafeed.backend.dao.FeedEntryDAO;
public class DatabaseCleaner {
2013-06-18 13:28:15 +02:00
private static Logger log = LoggerFactory.getLogger(DatabaseCleaner.class);
2013-06-19 17:01:28 +02:00
@Inject
FeedDAO feedDAO;
@Inject
2013-06-19 13:29:56 +02:00
FeedEntryDAO feedEntryDAO;
2013-06-19 17:01:28 +02:00
public long cleanFeedsWithoutSubscriptions() {
long total = 0;
int deleted = -1;
do {
deleted = feedDAO.deleteWithoutSubscriptions(100);
total += deleted;
log.info("removed {} feeds without subscriptions", total);
} while (deleted != 0);
log.info("cleanup done: {} feeds without subscriptions deleted", total);
return total;
}
public long cleanEntriesOlderThan(long value, TimeUnit unit) {
Calendar cal = Calendar.getInstance();
cal.add(Calendar.MINUTE, -1 * (int) unit.toMinutes(value));
2013-06-18 13:00:03 +02:00
long total = 0;
int deleted = -1;
do {
2013-06-19 13:29:56 +02:00
deleted = feedEntryDAO.delete(cal.getTime(), 100);
2013-06-18 13:00:03 +02:00
total += deleted;
2013-06-19 15:14:15 +02:00
log.info("removed {} entries", total);
2013-06-18 13:00:03 +02:00
} while (deleted != 0);
2013-06-19 15:14:15 +02:00
log.info("cleanup done: {} entries deleted", total);
2013-06-18 13:00:03 +02:00
return total;
}
}