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

log entries deleted

Browse Source
This commit is contained in:
Athou
2015-02-20 08:51:33 +01:00
parent 191680a01b
commit 812988b31a
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/commafeed/backend/service/DatabaseCleaningService.java
View File

@@ -40,13 +40,16 @@ public class DatabaseCleaningService {
log.info("cleaning feeds without subscriptions"); log.info("cleaning feeds without subscriptions");
long total = 0; long total = 0;
int deleted = 0; int deleted = 0;
long entriesTotal = 0;
do { do {
List<Feed> feeds = UnitOfWork.run(sessionFactory, () -> feedDAO.findWithoutSubscriptions(1)); List<Feed> feeds = UnitOfWork.run(sessionFactory, () -> feedDAO.findWithoutSubscriptions(1));
for (Feed feed : feeds) { for (Feed feed : feeds) {
int entriesDeleted = 0; int entriesDeleted = 0;
do { do {
entriesDeleted = UnitOfWork.run(sessionFactory, () -> feedEntryDAO.delete(feed.getId(), BATCH_SIZE)); entriesDeleted = UnitOfWork.run(sessionFactory, () -> feedEntryDAO.delete(feed.getId(), BATCH_SIZE));
} while (entriesDeleted == BATCH_SIZE); entriesTotal += entriesDeleted;
log.info("removed {} entries for feeds without subscriptions", entriesTotal);
} while (entriesDeleted > 0);
} }
deleted = UnitOfWork.run(sessionFactory, () -> feedDAO.delete(feeds)); deleted = UnitOfWork.run(sessionFactory, () -> feedDAO.delete(feeds));
total += deleted; total += deleted;