- logger("Deleting orphaned data from thread table");
- if ($db->q("SELECT `iid` FROM `thread` WHERE NOT EXISTS (SELECT `id` FROM `item` WHERE `item`.`parent` = `thread`.`iid`)", true)) {
- logger("found thread orphans: ".$db->num_rows());
- while ($orphan = $db->qfetch())
- q("DELETE FROM `thread` WHERE `iid` = %d", intval($orphan["iid"]));
+ if (($stage == 1) OR ($stage == 0)) {
+ logger("Deleting orphaned data from thread table");
+ if ($db->q("SELECT `iid` FROM `thread` WHERE NOT EXISTS (SELECT `id` FROM `item` WHERE `item`.`parent` = `thread`.`iid`)", true)) {
+ logger("found thread orphans: ".$db->num_rows());
+ while ($orphan = $db->qfetch()) {
+ q("DELETE FROM `thread` WHERE `iid` = %d", intval($orphan["iid"]));
+ }
+ }
+ $db->qclose();