-- VIEW application-view
--
DROP VIEW IF EXISTS `application-view`;
-CREATE VIEW `application-view` AS SELECT
+CREATE VIEW `application-view` AS SELECT
`application`.`id` AS `id`,
`application-token`.`uid` AS `uid`,
`application`.`name` AS `name`,
-- VIEW circle-member-view
--
DROP VIEW IF EXISTS `circle-member-view`;
-CREATE VIEW `circle-member-view` AS SELECT
+CREATE VIEW `circle-member-view` AS SELECT
`group_member`.`id` AS `id`,
`group`.`uid` AS `uid`,
`group_member`.`contact-id` AS `contact-id`,
-- VIEW post-counts-view
--
DROP VIEW IF EXISTS `post-counts-view`;
-CREATE VIEW `post-counts-view` AS SELECT
+CREATE VIEW `post-counts-view` AS SELECT
`post-counts`.`uri-id` AS `uri-id`,
`post-counts`.`vid` AS `vid`,
`verb`.`name` AS `verb`,
-- VIEW post-engagement-user-view
--
DROP VIEW IF EXISTS `post-engagement-user-view`;
-CREATE VIEW `post-engagement-user-view` AS SELECT
+CREATE VIEW `post-engagement-user-view` AS SELECT
`post-thread-user`.`uid` AS `uid`,
`post-engagement`.`uri-id` AS `uri-id`,
`post-engagement`.`owner-id` AS `owner-id`,
-- VIEW post-timeline-view
--
DROP VIEW IF EXISTS `post-timeline-view`;
-CREATE VIEW `post-timeline-view` AS SELECT
+CREATE VIEW `post-timeline-view` AS SELECT
`post-user`.`uid` AS `uid`,
`post-user`.`uri-id` AS `uri-id`,
`post-user`.`gravity` AS `gravity`,
-- VIEW post-timeline-origin-view
--
DROP VIEW IF EXISTS `post-timeline-origin-view`;
-CREATE VIEW `post-timeline-origin-view` AS SELECT
+CREATE VIEW `post-timeline-origin-view` AS SELECT
`post-origin`.`uid` AS `uid`,
`post-origin`.`uri-id` AS `uri-id`,
`post-origin`.`gravity` AS `gravity`,
-- VIEW post-searchindex-user-view
--
DROP VIEW IF EXISTS `post-searchindex-user-view`;
-CREATE VIEW `post-searchindex-user-view` AS SELECT
+CREATE VIEW `post-searchindex-user-view` AS SELECT
`post-thread-user`.`uid` AS `uid`,
`post-searchindex`.`uri-id` AS `uri-id`,
`post-searchindex`.`owner-id` AS `owner-id`,
-- VIEW post-origin-view
--
DROP VIEW IF EXISTS `post-origin-view`;
-CREATE VIEW `post-origin-view` AS SELECT
+CREATE VIEW `post-origin-view` AS SELECT
`post-origin`.`id` AS `id`,
`post-origin`.`id` AS `post-user-id`,
`post-origin`.`uid` AS `uid`,
-- VIEW post-thread-origin-view
--
DROP VIEW IF EXISTS `post-thread-origin-view`;
-CREATE VIEW `post-thread-origin-view` AS SELECT
+CREATE VIEW `post-thread-origin-view` AS SELECT
`post-origin`.`id` AS `id`,
`post-origin`.`id` AS `post-user-id`,
`post-origin`.`uid` AS `uid`,
-- VIEW post-user-view
--
DROP VIEW IF EXISTS `post-user-view`;
-CREATE VIEW `post-user-view` AS SELECT
+CREATE VIEW `post-user-view` AS SELECT
`post-user`.`id` AS `id`,
`post-user`.`id` AS `post-user-id`,
`post-user`.`uid` AS `uid`,
-- VIEW post-thread-user-view
--
DROP VIEW IF EXISTS `post-thread-user-view`;
-CREATE VIEW `post-thread-user-view` AS SELECT
+CREATE VIEW `post-thread-user-view` AS SELECT
`post-user`.`id` AS `id`,
`post-user`.`id` AS `post-user-id`,
`post-thread-user`.`uid` AS `uid`,
-- VIEW post-view
--
DROP VIEW IF EXISTS `post-view`;
-CREATE VIEW `post-view` AS SELECT
+CREATE VIEW `post-view` AS SELECT
`item-uri`.`uri` AS `uri`,
`post`.`uri-id` AS `uri-id`,
`parent-item-uri`.`uri` AS `parent-uri`,
-- VIEW post-thread-view
--
DROP VIEW IF EXISTS `post-thread-view`;
-CREATE VIEW `post-thread-view` AS SELECT
+CREATE VIEW `post-thread-view` AS SELECT
`item-uri`.`uri` AS `uri`,
`post-thread`.`uri-id` AS `uri-id`,
`parent-item-uri`.`uri` AS `parent-uri`,
-- VIEW category-view
--
DROP VIEW IF EXISTS `category-view`;
-CREATE VIEW `category-view` AS SELECT
+CREATE VIEW `category-view` AS SELECT
`post-category`.`uri-id` AS `uri-id`,
`post-category`.`uid` AS `uid`,
`post-category`.`type` AS `type`,
-- VIEW collection-view
--
DROP VIEW IF EXISTS `collection-view`;
-CREATE VIEW `collection-view` AS SELECT
+CREATE VIEW `collection-view` AS SELECT
`post-collection`.`uri-id` AS `uri-id`,
`post-collection`.`type` AS `type`,
`post-collection`.`author-id` AS `cid`,
-- VIEW media-view
--
DROP VIEW IF EXISTS `media-view`;
-CREATE VIEW `media-view` AS SELECT
+CREATE VIEW `media-view` AS SELECT
`post-media`.`uri-id` AS `uri-id`,
`post-media`.`type` AS `type`,
`post`.`received` AS `received`,
-- VIEW tag-view
--
DROP VIEW IF EXISTS `tag-view`;
-CREATE VIEW `tag-view` AS SELECT
+CREATE VIEW `tag-view` AS SELECT
`post-tag`.`uri-id` AS `uri-id`,
`post-tag`.`type` AS `type`,
`post-tag`.`tid` AS `tid`,
-- VIEW network-thread-view
--
DROP VIEW IF EXISTS `network-thread-view`;
-CREATE VIEW `network-thread-view` AS SELECT
+CREATE VIEW `network-thread-view` AS SELECT
`post-thread-user`.`uri-id` AS `uri-id`,
`post-thread-user`.`post-user-id` AS `parent`,
`post-thread-user`.`received` AS `received`,
-- VIEW network-thread-circle-view
--
DROP VIEW IF EXISTS `network-thread-circle-view`;
-CREATE VIEW `network-thread-circle-view` AS SELECT
+CREATE VIEW `network-thread-circle-view` AS SELECT
`post-thread-user`.`uri-id` AS `uri-id`,
`post-thread-user`.`post-user-id` AS `parent`,
`post-thread-user`.`received` AS `received`,
-- VIEW owner-view
--
DROP VIEW IF EXISTS `owner-view`;
-CREATE VIEW `owner-view` AS SELECT
+CREATE VIEW `owner-view` AS SELECT
`contact`.`id` AS `id`,
`contact`.`uid` AS `uid`,
`contact`.`created` AS `created`,
-- VIEW account-view
--
DROP VIEW IF EXISTS `account-view`;
-CREATE VIEW `account-view` AS SELECT
+CREATE VIEW `account-view` AS SELECT
`contact`.`id` AS `id`,
`contact`.`url` AS `url`,
`contact`.`nurl` AS `nurl`,
-- VIEW account-user-view
--
DROP VIEW IF EXISTS `account-user-view`;
-CREATE VIEW `account-user-view` AS SELECT
+CREATE VIEW `account-user-view` AS SELECT
`ucontact`.`id` AS `id`,
`contact`.`id` AS `pid`,
`ucontact`.`uid` AS `uid`,
-- VIEW pending-view
--
DROP VIEW IF EXISTS `pending-view`;
-CREATE VIEW `pending-view` AS SELECT
+CREATE VIEW `pending-view` AS SELECT
`register`.`id` AS `id`,
`register`.`hash` AS `hash`,
`register`.`created` AS `created`,
-- VIEW tag-search-view
--
DROP VIEW IF EXISTS `tag-search-view`;
-CREATE VIEW `tag-search-view` AS SELECT
+CREATE VIEW `tag-search-view` AS SELECT
`post-tag`.`uri-id` AS `uri-id`,
`post-user`.`uid` AS `uid`,
`post-user`.`id` AS `iid`,
-- VIEW workerqueue-view
--
DROP VIEW IF EXISTS `workerqueue-view`;
-CREATE VIEW `workerqueue-view` AS SELECT
+CREATE VIEW `workerqueue-view` AS SELECT
`process`.`pid` AS `pid`,
`workerqueue`.`priority` AS `priority`
FROM `process`
-- VIEW profile_field-view
--
DROP VIEW IF EXISTS `profile_field-view`;
-CREATE VIEW `profile_field-view` AS SELECT
+CREATE VIEW `profile_field-view` AS SELECT
`profile_field`.`id` AS `id`,
`profile_field`.`uid` AS `uid`,
`profile_field`.`label` AS `label`,
-- VIEW diaspora-contact-view
--
DROP VIEW IF EXISTS `diaspora-contact-view`;
-CREATE VIEW `diaspora-contact-view` AS SELECT
+CREATE VIEW `diaspora-contact-view` AS SELECT
`diaspora-contact`.`uri-id` AS `uri-id`,
`item-uri`.`uri` AS `url`,
`item-uri`.`guid` AS `guid`,
public static function setCompositeRootDependencyByHand()
{
$database = static::dba();
- $database->setDependency(static::config(), static::profiler(), static::logger());
+ $database->setDependency(static::config(), static::profiler(), static::logger(), static::lock());
}
/**
namespace Friendica\Database;
+use Friendica\Core\Lock\Exception\LockPersistenceException;
use Friendica\DI;
use mysqli;
use mysqli_result;
return DI::dba()->optimizeTable($table);
}
+ /**
+ * Acquire a lock to prevent a table optimization
+ *
+ * @return bool
+ * @throws LockPersistenceException
+ */
+ public static function acquireOptimizeLock(): bool
+ {
+ return DI::dba()->acquireOptimizeLock();
+ }
+
+ /**
+ * Release the table optimization lock
+ * @return bool
+ * @throws LockPersistenceException
+ */
+ public static function releaseOptimizeLock(): bool
+ {
+ return DI::dba()->releaseOptimizeLock();
+ }
+
/**
* Kill sleeping database processes
*/
namespace Friendica\Database;
use Friendica\Core\Config\Capability\IManageConfigValues;
+use Friendica\Core\Lock\Capability\ICanLock;
+use Friendica\Core\Lock\Exception\LockPersistenceException;
use Friendica\Core\System;
use Friendica\Database\Definition\DbaDefinition;
use Friendica\Database\Definition\ViewDefinition;
const INSERT_UPDATE = 1;
const INSERT_IGNORE = 2;
+ const LOCK_OPTIMIZE = 'database::optimize_tables';
+
protected $connected = false;
/**
* @var LoggerInterface
*/
protected $logger = null;
+ /**
+ * @var ICanLock
+ */
+ protected $syslock = null;
+
protected $server_info = '';
/** @var PDO|mysqli */
protected $connection;
*
* @todo Make this method obsolete - use a clean pattern instead ...
*/
- public function setDependency(IManageConfigValues $config, Profiler $profiler, LoggerInterface $logger)
+ public function setDependency(IManageConfigValues $config, Profiler $profiler, LoggerInterface $logger, ICanLock $lock)
{
$this->logger = $logger;
$this->profiler = $profiler;
$this->config = $config;
+ $this->syslock = $lock;
}
/**
*/
public function optimizeTable(string $table): bool
{
- return $this->e("OPTIMIZE TABLE " . DBA::buildTableString([$table])) !== false;
+ if ($this->syslock->isLocked(self::LOCK_OPTIMIZE)) {
+ $this->logger->info('Optimization is locked');
+ return false;
+ }
+
+ if (!$this->acquireOptimizeLock()) {
+ return false;
+ }
+
+ $result = $this->e("OPTIMIZE TABLE " . DBA::buildTableString([$table])) !== false;
+
+ $this->releaseOptimizeLock();
+
+ return $result;
+ }
+
+ /**
+ * Acquire a lock to prevent a table optimization
+ *
+ * @return bool
+ * @throws LockPersistenceException
+ */
+ public function acquireOptimizeLock(): bool
+ {
+ return $this->syslock->acquire(self::LOCK_OPTIMIZE, 0);
+ }
+
+ /**
+ * Release the table optimization lock
+ *
+ * @return bool
+ * @throws LockPersistenceException
+ */
+ public function releaseOptimizeLock(): bool
+ {
+ return $this->syslock->release(self::LOCK_OPTIMIZE);
}
/**
*/
public static function execute()
{
+ if (!DBA::acquireOptimizeLock()) {
+ Logger::warning('Lock could not be acquired');
+ return;
+ }
+
self::deleteExpiredOriginPosts();
self::deleteOrphanedEntries();
self::addMissingEntries();
}
+ DBA::releaseOptimizeLock();
+
// Set the expiry for origin posts
Worker::add(Worker::PRIORITY_LOW, 'Expire');
Logger::notice('Delete expired posts');
// physically remove anything that has been deleted for more than two months
$condition = ["`gravity` = ? AND `deleted` AND `changed` < ?", Item::GRAVITY_PARENT, DateTimeFormat::utc('now - 60 days')];
- $rows = Post::select(['guid', 'uri-id', 'uid'], $condition);
- while ($row = Post::fetch($rows)) {
- Logger::info('Delete expired item', ['uri-id' => $row['uri-id'], 'guid' => $row['guid']]);
- Post\User::delete(['parent-uri-id' => $row['uri-id'], 'uid' => $row['uid']]);
- Post\Origin::delete(['parent-uri-id' => $row['uri-id'], 'uid' => $row['uid']]);
- }
- DBA::close($rows);
-
- Logger::notice('Delete expired posts - done');
+ $pass = 0;
+ do {
+ ++$pass;
+ $rows = Post::select(['guid', 'uri-id', 'uid'], $condition, ['limit' => 100]);
+ $affected_count = 0;
+ while ($row = Post::fetch($rows)) {
+ Logger::info('Delete expired item', ['pass' => $pass, 'uri-id' => $row['uri-id'], 'guid' => $row['guid']]);
+ Post\User::delete(['parent-uri-id' => $row['uri-id'], 'uid' => $row['uid']]);
+ $affected_count += DBA::affectedRows();
+ Post\Origin::delete(['parent-uri-id' => $row['uri-id'], 'uid' => $row['uid']]);
+ $affected_count += DBA::affectedRows();
+ }
+ DBA::close($rows);
+ DBA::commit();
+ Logger::notice('Delete expired posts - done', ['pass' => $pass, 'rows' => $affected_count]);
+ } while ($affected_count);
}
/**
$affected_count += DBA::affectedRows();
}
DBA::close($uris);
+ DBA::commit();
Logger::notice('Orphaned entries deleted', ['table' => $table, 'rows' => $affected_count]);
}
Logger::notice('Delete orphaned entries - done');
{
// We have to avoid deleting newly created "item-uri" entries.
// So we fetch a post that had been stored yesterday and only delete older ones.
- $item = Post::selectFirstThread(['uri-id'], ["`uid` = ? AND `received` < ?", 0, DateTimeFormat::utc('now - 1 day')],
- ['order' => ['received' => true]]);
+ $item = Post::selectFirstThread(
+ ['uri-id'],
+ ["`uid` = ? AND `received` < ?", 0, DateTimeFormat::utc('now - 1 day')],
+ ['order' => ['received' => true]]
+ );
if (empty($item['uri-id'])) {
Logger::warning('No item with uri-id found - we better quit here');
return;
}
Logger::notice('Start collecting orphaned URI-ID', ['last-id' => $item['uri-id']]);
- $uris = DBA::select('item-uri', ['id'], ["`id` < ?
+ $condition = [
+ "`id` < ?
AND NOT EXISTS(SELECT `uri-id` FROM `post-user` WHERE `uri-id` = `item-uri`.`id`)
AND NOT EXISTS(SELECT `parent-uri-id` FROM `post-user` WHERE `parent-uri-id` = `item-uri`.`id`)
AND NOT EXISTS(SELECT `thr-parent-id` FROM `post-user` WHERE `thr-parent-id` = `item-uri`.`id`)
AND NOT EXISTS(SELECT `uri-id` FROM `post-delivery` WHERE `uri-id` = `item-uri`.`id`)
AND NOT EXISTS(SELECT `uri-id` FROM `post-delivery` WHERE `inbox-id` = `item-uri`.`id`)
AND NOT EXISTS(SELECT `parent-uri-id` FROM `mail` WHERE `parent-uri-id` = `item-uri`.`id`)
- AND NOT EXISTS(SELECT `thr-parent-id` FROM `mail` WHERE `thr-parent-id` = `item-uri`.`id`)", $item['uri-id']]);
-
- Logger::notice('Start deleting orphaned URI-ID', ['last-id' => $item['uri-id']]);
- $affected_count = 0;
- while ($rows = DBA::toArray($uris, false, 100)) {
- $ids = array_column($rows, 'id');
- DBA::delete('item-uri', ['id' => $ids]);
- $affected_count += DBA::affectedRows();
- Logger::info('Deleted', ['rows' => $affected_count]);
- }
- DBA::close($uris);
- Logger::notice('Orphaned URI-ID entries removed', ['rows' => $affected_count]);
+ AND NOT EXISTS(SELECT `thr-parent-id` FROM `mail` WHERE `thr-parent-id` = `item-uri`.`id`)", $item['uri-id']
+ ];
+ $pass = 0;
+ do {
+ ++$pass;
+ $uris = DBA::select('item-uri', ['id'], $condition, ['limit' => 1000]);
+ Logger::notice('Start deleting orphaned URI-ID', ['pass' => $pass, 'last-id' => $item['uri-id']]);
+ $affected_count = 0;
+ while ($rows = DBA::toArray($uris, false, 100)) {
+ $ids = array_column($rows, 'id');
+ DBA::delete('item-uri', ['id' => $ids]);
+ $affected_count += DBA::affectedRows();
+ Logger::info('Deleted', ['pass' => $pass, 'rows' => $affected_count]);
+ }
+ DBA::close($uris);
+ DBA::commit();
+ Logger::notice('Orphaned URI-ID entries removed', ['pass' => $pass, 'rows' => $affected_count]);
+ } while ($affected_count);
}
/**
if (!empty($expire_days)) {
Logger::notice('Start collecting expired threads', ['expiry_days' => $expire_days]);
- $uris = DBA::select('item-uri', ['id'], ["`id` IN
- (SELECT `uri-id` FROM `post-thread` WHERE `received` < ?
- AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-thread-user`
- WHERE (`mention` OR `starred` OR `wall`) AND `uri-id` = `post-thread`.`uri-id`)
- AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-category`
- WHERE `uri-id` = `post-thread`.`uri-id`)
- AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-collection`
- WHERE `uri-id` = `post-thread`.`uri-id`)
- AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-media`
- WHERE `uri-id` = `post-thread`.`uri-id`)
- AND NOT `uri-id` IN (SELECT `parent-uri-id` FROM `post-user` INNER JOIN `contact` ON `contact`.`id` = `contact-id` AND `notify_new_posts`
- WHERE `parent-uri-id` = `post-thread`.`uri-id`)
- AND NOT `uri-id` IN (SELECT `parent-uri-id` FROM `post-user`
- WHERE (`origin` OR `event-id` != 0 OR `post-type` = ?) AND `parent-uri-id` = `post-thread`.`uri-id`)
- AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-content`
- WHERE `resource-id` != 0 AND `uri-id` = `post-thread`.`uri-id`))",
- DateTimeFormat::utc('now - ' . (int)$expire_days . ' days'), Item::PT_PERSONAL_NOTE]);
+ $condition = [
+ "`id` IN (SELECT `uri-id` FROM `post-thread` WHERE `received` < ?
+ AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-thread-user`
+ WHERE (`mention` OR `starred` OR `wall`) AND `uri-id` = `post-thread`.`uri-id`)
+ AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-category`
+ WHERE `uri-id` = `post-thread`.`uri-id`)
+ AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-collection`
+ WHERE `uri-id` = `post-thread`.`uri-id`)
+ AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-media`
+ WHERE `uri-id` = `post-thread`.`uri-id`)
+ AND NOT `uri-id` IN (SELECT `parent-uri-id` FROM `post-user` INNER JOIN `contact` ON `contact`.`id` = `contact-id` AND `notify_new_posts`
+ WHERE `parent-uri-id` = `post-thread`.`uri-id`)
+ AND NOT `uri-id` IN (SELECT `parent-uri-id` FROM `post-user`
+ WHERE (`origin` OR `event-id` != 0 OR `post-type` = ?) AND `parent-uri-id` = `post-thread`.`uri-id`)
+ AND NOT `uri-id` IN (SELECT `uri-id` FROM `post-content`
+ WHERE `resource-id` != 0 AND `uri-id` = `post-thread`.`uri-id`))",
+ DateTimeFormat::utc('now - ' . (int)$expire_days . ' days'), Item::PT_PERSONAL_NOTE
+ ];
+ $pass = 0;
+ do {
+ ++$pass;
+ $uris = DBA::select('item-uri', ['id'], $condition, ['limit' => 100]);
- Logger::notice('Start deleting expired threads');
- $affected_count = 0;
- while ($rows = DBA::toArray($uris, false, 100)) {
- $ids = array_column($rows, 'id');
- DBA::delete('item-uri', ['id' => $ids]);
- $affected_count += DBA::affectedRows();
- }
- DBA::close($uris);
-
- Logger::notice('Deleted expired threads', ['rows' => $affected_count]);
+ Logger::notice('Start deleting expired threads', ['pass' => $pass]);
+ $affected_count = 0;
+ while ($rows = DBA::toArray($uris, false, 100)) {
+ $ids = array_column($rows, 'id');
+ DBA::delete('item-uri', ['id' => $ids]);
+ $affected_count += DBA::affectedRows();
+ }
+ DBA::close($uris);
+ DBA::commit();
+ Logger::notice('Deleted expired threads', ['pass' => $pass, 'rows' => $affected_count]);
+ } while ($affected_count);
}
if (!empty($expire_days_unclaimed)) {
Logger::notice('Start collecting unclaimed public items', ['expiry_days' => $expire_days_unclaimed]);
- $uris = DBA::select('item-uri', ['id'], ["`id` IN
- (SELECT `uri-id` FROM `post-user` WHERE `gravity` = ? AND `uid` = ? AND `received` < ?
- AND NOT `uri-id` IN (SELECT `parent-uri-id` FROM `post-user` AS `i` WHERE `i`.`uid` != ?
- AND `i`.`parent-uri-id` = `post-user`.`uri-id`)
- AND NOT `uri-id` IN (SELECT `parent-uri-id` FROM `post-user` AS `i` WHERE `i`.`uid` = ?
- AND `i`.`parent-uri-id` = `post-user`.`uri-id` AND `i`.`received` > ?))",
- Item::GRAVITY_PARENT, 0, DateTimeFormat::utc('now - ' . (int)$expire_days_unclaimed . ' days'), 0, 0, DateTimeFormat::utc('now - ' . (int)$expire_days_unclaimed . ' days')]);
+ $condition = [
+ "`id` IN (SELECT `uri-id` FROM `post-user` WHERE `gravity` = ? AND `uid` = ? AND `received` < ?
+ AND NOT `uri-id` IN (SELECT `parent-uri-id` FROM `post-user` AS `i` WHERE `i`.`uid` != ?
+ AND `i`.`parent-uri-id` = `post-user`.`uri-id`)
+ AND NOT `uri-id` IN (SELECT `parent-uri-id` FROM `post-user` AS `i` WHERE `i`.`uid` = ?
+ AND `i`.`parent-uri-id` = `post-user`.`uri-id` AND `i`.`received` > ?))",
+ Item::GRAVITY_PARENT, 0, DateTimeFormat::utc('now - ' . (int)$expire_days_unclaimed . ' days'), 0, 0, DateTimeFormat::utc('now - ' . (int)$expire_days_unclaimed . ' days')
+ ];
+ $pass = 0;
+ do {
+ ++$pass;
+ $uris = DBA::select('item-uri', ['id'], $condition, ['limit' => 100]);
- Logger::notice('Start deleting unclaimed public items');
- $affected_count = 0;
- while ($rows = DBA::toArray($uris, false, 100)) {
- $ids = array_column($rows, 'id');
- DBA::delete('item-uri', ['id' => $ids]);
- $affected_count += DBA::affectedRows();
- }
- DBA::close($uris);
- Logger::notice('Deleted unclaimed public items', ['rows' => $affected_count]);
+ Logger::notice('Start deleting unclaimed public items', ['pass' => $pass]);
+ $affected_count = 0;
+ while ($rows = DBA::toArray($uris, false, 100)) {
+ $ids = array_column($rows, 'id');
+ DBA::delete('item-uri', ['id' => $ids]);
+ $affected_count += DBA::affectedRows();
+ }
+ DBA::close($uris);
+ DBA::commit();
+ Logger::notice('Deleted unclaimed public items', ['pass' => $pass, 'rows' => $affected_count]);
+ } while ($affected_count);
}
}
}
projects / friendica.git / commitdiff