Cavemanon/piratepoet
8
Fork 0
Code Pull Requests Actions Releases 16 Activity

Optimize queries for orphaned scheduled task subscribers

Browse Source 
[MAILPOET-6219]
This commit is contained in:
Rostislav Wolny
2024-09-11 10:47:36 +02:00
committed by Aschepikov
parent f3d6813d97
commit 53a1664133
1 changed files with 32 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
mailpoet/lib/Util/DataInconsistency/DataInconsistencyRepository.php
View File

@@ -40,9 +40,21 @@ class DataInconsistencyRepository {
$stsTable = $this->entityManager->getClassMetadata(ScheduledTaskSubscriberEntity::class)->getTableName();
/** @var string $count */
$count = $this->entityManager->getConnection()->executeQuery("
SELECT count(*) FROM $stsTable sts
LEFT JOIN $stTable st ON st.`id` = sts.`task_id`
WHERE st.`id` IS NULL
SELECT COUNT(*)
FROM $stsTable sts
WHERE sts.task_id IN (
-- SELECT ... FROM (subquery) forces the subquery to materialize first.
-- We're using this twice here to get the reduced data set before JOIN.
SELECT oprhaned_task_ids.task_id FROM
(
SELECT task_ids.task_id
FROM (
SELECT DISTINCT task_id FROM $stsTable
) AS task_ids
LEFT JOIN $stTable st ON st.id = task_ids.task_id
WHERE st.id IS NULL
) AS oprhaned_task_ids
);
")->fetchOne();
return intval($count);
}
@@ -146,17 +158,30 @@ class DataInconsistencyRepository {
$stTable = $this->entityManager->getClassMetadata(ScheduledTaskEntity::class)->getTableName();
$stsTable = $this->entityManager->getClassMetadata(ScheduledTaskSubscriberEntity::class)->getTableName();
$deletedCount = 0;
$missingTaskIds = $this->entityManager->getConnection()->executeQuery("
SELECT task_ids.task_id
-- SELECT ... FROM (subquery) forces the subquery to materialize first.
-- We're using this here to get the reduced data set before JOIN.
FROM (
SELECT DISTINCT task_id FROM $stsTable
) AS task_ids
LEFT JOIN $stTable st ON st.id = task_ids.task_id
WHERE st.id IS NULL;")->fetchFirstColumn();
if (!$missingTaskIds) {
return 0;
}
do {
$deletedCount += (int)$this->entityManager->getConnection()->executeStatement(
"DELETE sts_top FROM $stsTable sts_top
JOIN (
SELECT sts.`task_id`, sts.`subscriber_id` FROM $stsTable sts
LEFT JOIN $stTable st ON st.`id` = sts.`task_id`
WHERE st.`id` IS NULL
WHERE sts.`task_id` IN (:taskIds)
LIMIT :limit
) as to_delete ON sts_top.`task_id` = to_delete.`task_id` AND sts_top.`subscriber_id` = to_delete.`subscriber_id`",
['limit' => self::DELETE_ROWS_LIMIT],
['limit' => ParameterType::INTEGER]
['taskIds' => $missingTaskIds, 'limit' => self::DELETE_ROWS_LIMIT],
['taskIds' => ArrayParameterType::INTEGER, 'limit' => ParameterType::INTEGER]
);
} while ($this->getOrphanedScheduledTasksSubscribersCount() > 0);
return $deletedCount;