X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=src%2FWorker%2FDBClean.php;h=0316b9ebf6ebdef744938dac6ce698f63c0f6321;hb=f047944b2d28adb2239d68c81f1281d6ccffba8b;hp=67f073b10fd1f78239c8b9045d5cc08f3cd2fc86;hpb=94eca7704130822bf83bb5fee6930dee6bae81dd;p=friendica.git diff --git a/src/Worker/DBClean.php b/src/Worker/DBClean.php index 67f073b10f..0316b9ebf6 100644 --- a/src/Worker/DBClean.php +++ b/src/Worker/DBClean.php @@ -1,20 +1,38 @@ . + * */ namespace Friendica\Worker; -use Friendica\Core\Config; use Friendica\Core\Logger; use Friendica\Core\Worker; use Friendica\Database\DBA; +use Friendica\DI; +/** + * The script is called from time to time to clean the database entries and remove orphaned data. + */ class DBClean { public static function execute($stage = 0) { - if (!Config::get('system', 'dbclean', false)) { + if (!DI::config()->get('system', 'dbclean', false)) { return; } @@ -26,47 +44,47 @@ class DBClean { } /** - * @brief Fork the different DBClean processes + * Fork the different DBClean processes */ private static function forkCleanProcess() { // Get the expire days for step 8 and 9 - $days = Config::get('system', 'dbclean-expire-days', 0); + $days = DI::config()->get('system', 'dbclean-expire-days', 0); for ($i = 1; $i <= 10; $i++) { // Execute the background script for a step when it isn't finished. // Execute step 8 and 9 only when $days is defined. - if (!Config::get('system', 'finished-dbclean-'.$i, false) && (($i < 8) || ($i > 9) || ($days > 0))) { + if (!DI::config()->get('system', 'finished-dbclean-'.$i, false) && (($i < 8) || ($i > 9) || ($days > 0))) { Worker::add(PRIORITY_LOW, 'DBClean', $i); } } } /** - * @brief Remove orphaned database entries + * Remove orphaned database entries + * * @param integer $stage What should be deleted? * * Values for $stage: * ------------------ - * 1: Old global item entries from item table without user copy. - * 2: Items without parents. - * 3: Orphaned data from thread table. - * 4: Orphaned data from notify table. - * 5: Orphaned data from notify-threads table. - * 6: Orphaned data from sign table. - * 7: Orphaned data from term table. - * 8: Expired threads. - * 9: Old global item entries from expired threads. - * 10: Old conversations. + * 1: Old global item entries from item table without user copy. + * 2: Items without parents. + * 3: Orphaned data from thread table. + * 4: Orphaned data from notify table. + * 5: Orphaned data from notify-threads table. + * 6: Orphaned data from sign table. + * 7: Orphaned data from term table. + * 8: Expired threads. + * 9: Old global item entries from expired threads. + * 10: Old conversations. + * @throws \Friendica\Network\HTTPException\InternalServerErrorException */ private static function removeOrphans($stage) { - $count = 0; - // We split the deletion in many small tasks - $limit = Config::get('system', 'dbclean-expire-limit', 1000); + $limit = DI::config()->get('system', 'dbclean-expire-limit', 1000); // Get the expire days for step 8 and 9 - $days = Config::get('system', 'dbclean-expire-days', 0); - $days_unclaimed = Config::get('system', 'dbclean-expire-unclaimed', 90); + $days = DI::config()->get('system', 'dbclean-expire-days', 0); + $days_unclaimed = DI::config()->get('system', 'dbclean-expire-unclaimed', 90); if ($days_unclaimed == 0) { $days_unclaimed = $days; @@ -77,10 +95,10 @@ class DBClean { return; } - $last_id = Config::get('system', 'dbclean-last-id-1', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-1', 0); Logger::log("Deleting old global item entries from item table without user copy. Last ID: ".$last_id); - $r = DBA::p("SELECT `id` FROM `item` WHERE `uid` = 0 AND + $r = DBA::p("SELECT `id`, `guid` FROM `item` WHERE `uid` = 0 AND NOT EXISTS (SELECT `guid` FROM `item` AS `i` WHERE `item`.`guid` = `i`.`guid` AND `i`.`uid` != 0) AND `received` < UTC_TIMESTAMP() - INTERVAL ? DAY AND `id` >= ? ORDER BY `id` LIMIT ?", $days_unclaimed, $last_id, $limit); @@ -89,6 +107,7 @@ class DBClean { Logger::log("found global item orphans: ".$count); while ($orphan = DBA::fetch($r)) { $last_id = $orphan["id"]; + Logger::info('Delete global orphan item', ['id' => $orphan['id'], 'guid' => $orphan['guid']]); DBA::delete('item', ['id' => $orphan["id"]]); } Worker::add(PRIORITY_MEDIUM, 'DBClean', 1, $last_id); @@ -98,12 +117,12 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." old global item entries from item table without user copy. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-1', $last_id); + DI::config()->set('system', 'dbclean-last-id-1', $last_id); } elseif ($stage == 2) { - $last_id = Config::get('system', 'dbclean-last-id-2', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-2', 0); Logger::log("Deleting items without parents. Last ID: ".$last_id); - $r = DBA::p("SELECT `id` FROM `item` + $r = DBA::p("SELECT `id`, `guid` FROM `item` WHERE NOT EXISTS (SELECT `id` FROM `item` AS `i` WHERE `item`.`parent` = `i`.`id`) AND `id` >= ? ORDER BY `id` LIMIT ?", $last_id, $limit); $count = DBA::numRows($r); @@ -111,6 +130,7 @@ class DBClean { Logger::log("found item orphans without parents: ".$count); while ($orphan = DBA::fetch($r)) { $last_id = $orphan["id"]; + Logger::info('Delete orphan item', ['id' => $orphan['id'], 'guid' => $orphan['guid']]); DBA::delete('item', ['id' => $orphan["id"]]); } Worker::add(PRIORITY_MEDIUM, 'DBClean', 2, $last_id); @@ -120,13 +140,13 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." items without parents. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-2', $last_id); + DI::config()->set('system', 'dbclean-last-id-2', $last_id); if ($count < $limit) { - Config::set('system', 'finished-dbclean-2', true); + DI::config()->set('system', 'finished-dbclean-2', true); } } elseif ($stage == 3) { - $last_id = Config::get('system', 'dbclean-last-id-3', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-3', 0); Logger::log("Deleting orphaned data from thread table. Last ID: ".$last_id); $r = DBA::p("SELECT `iid` FROM `thread` @@ -146,13 +166,13 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." orphaned data from thread table. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-3', $last_id); + DI::config()->set('system', 'dbclean-last-id-3', $last_id); if ($count < $limit) { - Config::set('system', 'finished-dbclean-3', true); + DI::config()->set('system', 'finished-dbclean-3', true); } } elseif ($stage == 4) { - $last_id = Config::get('system', 'dbclean-last-id-4', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-4', 0); Logger::log("Deleting orphaned data from notify table. Last ID: ".$last_id); $r = DBA::p("SELECT `iid`, `id` FROM `notify` @@ -172,13 +192,13 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." orphaned data from notify table. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-4', $last_id); + DI::config()->set('system', 'dbclean-last-id-4', $last_id); if ($count < $limit) { - Config::set('system', 'finished-dbclean-4', true); + DI::config()->set('system', 'finished-dbclean-4', true); } } elseif ($stage == 5) { - $last_id = Config::get('system', 'dbclean-last-id-5', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-5', 0); Logger::log("Deleting orphaned data from notify-threads table. Last ID: ".$last_id); $r = DBA::p("SELECT `id` FROM `notify-threads` @@ -198,13 +218,13 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." orphaned data from notify-threads table. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-5', $last_id); + DI::config()->set('system', 'dbclean-last-id-5', $last_id); if ($count < $limit) { - Config::set('system', 'finished-dbclean-5', true); + DI::config()->set('system', 'finished-dbclean-5', true); } } elseif ($stage == 6) { - $last_id = Config::get('system', 'dbclean-last-id-6', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-6', 0); Logger::log("Deleting orphaned data from sign table. Last ID: ".$last_id); $r = DBA::p("SELECT `iid`, `id` FROM `sign` @@ -224,13 +244,13 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." orphaned data from sign table. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-6', $last_id); + DI::config()->set('system', 'dbclean-last-id-6', $last_id); if ($count < $limit) { - Config::set('system', 'finished-dbclean-6', true); + DI::config()->set('system', 'finished-dbclean-6', true); } } elseif ($stage == 7) { - $last_id = Config::get('system', 'dbclean-last-id-7', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-7', 0); Logger::log("Deleting orphaned data from term table. Last ID: ".$last_id); $r = DBA::p("SELECT `oid`, `tid` FROM `term` @@ -250,17 +270,17 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." orphaned data from term table. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-7', $last_id); + DI::config()->set('system', 'dbclean-last-id-7', $last_id); if ($count < $limit) { - Config::set('system', 'finished-dbclean-7', true); + DI::config()->set('system', 'finished-dbclean-7', true); } } elseif ($stage == 8) { if ($days <= 0) { return; } - $last_id = Config::get('system', 'dbclean-last-id-8', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-8', 0); Logger::log("Deleting expired threads. Last ID: ".$last_id); $r = DBA::p("SELECT `thread`.`iid` FROM `thread` @@ -289,17 +309,17 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." expired threads. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-8', $last_id); + DI::config()->set('system', 'dbclean-last-id-8', $last_id); } elseif ($stage == 9) { if ($days <= 0) { return; } - $last_id = Config::get('system', 'dbclean-last-id-9', 0); - $till_id = Config::get('system', 'dbclean-last-id-8', 0); + $last_id = DI::config()->get('system', 'dbclean-last-id-9', 0); + $till_id = DI::config()->get('system', 'dbclean-last-id-8', 0); Logger::log("Deleting old global item entries from expired threads from ID ".$last_id." to ID ".$till_id); - $r = DBA::p("SELECT `id` FROM `item` WHERE `uid` = 0 AND + $r = DBA::p("SELECT `id`, `guid` FROM `item` WHERE `uid` = 0 AND NOT EXISTS (SELECT `guid` FROM `item` AS `i` WHERE `item`.`guid` = `i`.`guid` AND `i`.`uid` != 0) AND `received` < UTC_TIMESTAMP() - INTERVAL 90 DAY AND `id` >= ? AND `id` <= ? ORDER BY `id` LIMIT ?", $last_id, $till_id, $limit); @@ -308,6 +328,7 @@ class DBClean { Logger::log("found global item entries from expired threads: ".$count); while ($orphan = DBA::fetch($r)) { $last_id = $orphan["id"]; + Logger::info('Delete expired thread item', ['id' => $orphan['id'], 'guid' => $orphan['guid']]); DBA::delete('item', ['id' => $orphan["id"]]); } Worker::add(PRIORITY_MEDIUM, 'DBClean', 9, $last_id); @@ -317,10 +338,10 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." old global item entries from expired threads. Last ID: ".$last_id); - Config::set('system', 'dbclean-last-id-9', $last_id); + DI::config()->set('system', 'dbclean-last-id-9', $last_id); } elseif ($stage == 10) { - $last_id = Config::get('system', 'dbclean-last-id-10', 0); - $days = intval(Config::get('system', 'dbclean_expire_conversation', 90)); + $last_id = DI::config()->get('system', 'dbclean-last-id-10', 0); + $days = intval(DI::config()->get('system', 'dbclean_expire_conversation', 90)); Logger::log("Deleting old conversations. Last created: ".$last_id); $r = DBA::p("SELECT `received`, `item-uri` FROM `conversation` @@ -340,7 +361,7 @@ class DBClean { DBA::close($r); Logger::log("Done deleting ".$count." conversations. Last created: ".$last_id); - Config::set('system', 'dbclean-last-id-10', $last_id); + DI::config()->set('system', 'dbclean-last-id-10', $last_id); } } }