Ticket #3115: myth_clean_tvchain2.diff

programs/mythbackend/housekeeper.cpp

@@ -247 +247 @@
             if (wantToRun("DailyCleanup", 1, 0, 24)) {
                 JobQueue::CleanupOldJobsInQueue();
                 CleanupAllOldInUsePrograms();
+                CleanupOldLivetvChains();
                 CleanupRecordedTables();
                 CleanupProgramListings();
                 updateLastrun("DailyCleanup");
@@ -353 +354 @@
     query.exec();
 }
 
+void HouseKeeper::CleanupOldLivetvChains(void)
+{
+    QDateTime fourHoursAgo = QDateTime::currentDateTime().addSecs(-4 * 60 * 60);
+    MSqlQuery query(MSqlQuery::InitCon());
+    MSqlQuery deleteQuery(MSqlQuery::InitCon());
+
+    // Keep these tvchains, they may be in use.
+    query.prepare("SELECT DISTINCT chainid FROM tvchain "
+                  "WHERE endtime > :FOURHOURSAGO ;");
+    query.bindValue(":FOURHOURSAGO", fourHoursAgo);
+
+    if (!query.exec() || !query.isActive())
+    {
+        MythContext::DBError("HouseKeeper Cleaning TVChain Table", query);
+        return;
+    }
+
+    QString keepChains = "";
+    while (query.next())
+        keepChains += "'" + query.value(0).toString() + "',";
+ 
+    if (keepChains.isEmpty())
+        deleteQuery.prepare("TRUNCATE TABLE tvchain;");
+    else
+    {
+        keepChains = keepChains.left(keepChains.length() - 1);
+        // bindValue() adds unwanted quoting of keepChains :(
+        deleteQuery.prepare(QString("DELETE FROM tvchain "
+                                    "WHERE endtime < now() "
+                                    "AND chainid NOT IN ( %1 );")
+                                    .arg(keepChains));
+    }
+    deleteQuery.exec();
+}
+
 void HouseKeeper::CleanupRecordedTables(void)
 {
     MSqlQuery query(MSqlQuery::InitCon());

programs/mythbackend/housekeeper.h

@@ -34 +34 @@
     void runFillDatabase();
     void CleanupMyOldRecordings(void);
     void CleanupAllOldInUsePrograms(void);
+    void CleanupOldLivetvChains(void);
     void CleanupRecordedTables(void);
     void CleanupProgramListings(void);
     void RunStartupTasks(void);