Page MenuHomeWickedGov Phorge
Files F4144887

removeOrphanedEvents.php
No OneTemporary
Actions

Size
4 KB
Referenced Files
None
Subscribers
None

removeOrphanedEvents.php
View Options

<?php
/**
* Remove rows from echo_event that don't have corresponding rows in echo_notification or echo_email_batch.
*
* @ingroup Maintenance
*/
use MediaWiki\Extension\Notifications\DbFactory;
use MediaWiki\Maintenance\LoggedUpdateMaintenance;
// @codeCoverageIgnoreStart
require_once getenv( 'MW_INSTALL_PATH' ) !== false
? getenv( 'MW_INSTALL_PATH' ) . '/maintenance/Maintenance.php'
: __DIR__ . '/../../../maintenance/Maintenance.php';
// @codeCoverageIgnoreEnd
/**
* Maintenance script that removes orphaned event rows
*
* @ingroup Maintenance
*/
class RemoveOrphanedEvents extends LoggedUpdateMaintenance {
public function __construct() {
parent::__construct();
$this->addDescription( "Remove rows from echo_event and echo_target_page that don't have corresponding " .
"rows in echo_notification or echo_email_batch" );
$this->setBatchSize( 500 );
$this->requireExtension( 'Echo' );
}
/** @inheritDoc */
public function getUpdateKey() {
return __CLASS__;
}
/** @inheritDoc */
public function doDBUpdates() {
$startId = 0;
$dbFactory = DbFactory::newFromDefault();
$dbr = $dbFactory->getEchoDb( DB_REPLICA );
$maxId = (int)$dbr->newSelectQueryBuilder()
->select( 'MAX(event_id)' )
->from( 'echo_event' )
->caller( __METHOD__ )
->fetchField();
$eventsProcessedTotal = 0;
$targetsProcessedTotal = 0;
while ( $startId < $maxId ) {
$startId += $this->getBatchSize() * 1000;
[ $eventsProcessed, $targetsProcessed ] = $this->doMajorBatch( $startId );
$eventsProcessedTotal += $eventsProcessed;
$targetsProcessedTotal += $targetsProcessed;
}
$this->output( "In total, deleted $eventsProcessedTotal orphaned events and " .
"$targetsProcessedTotal target_page rows.\n" );
return true;
}
private function doMajorBatch( int $maxId ): array {
$dbFactory = DbFactory::newFromDefault();
$dbw = $dbFactory->getEchoDb( DB_PRIMARY );
$dbr = $dbFactory->getEchoDb( DB_REPLICA );
$iterator = new BatchRowIterator(
$dbr,
[ 'echo_event', 'echo_notification', 'echo_email_batch' ],
'event_id',
$this->getBatchSize()
);
$iterator->addJoinConditions( [
'echo_notification' => [ 'LEFT JOIN', 'notification_event=event_id' ],
'echo_email_batch' => [ 'LEFT JOIN', 'eeb_event_id=event_id' ],
] );
$iterator->addConditions( [
'notification_user' => null,
'eeb_user_id' => null,
$dbr->expr( 'event_id', '<', $maxId ),
] );
$iterator->setCaller( __METHOD__ );
$this->output( "Removing orphaned echo_event rows with max event_id of $maxId...\n" );
$eventsProcessed = 0;
$targetsProcessed = 0;
foreach ( $iterator as $batch ) {
$ids = [];
foreach ( $batch as $row ) {
$ids[] = $row->event_id;
}
$dbw->newDeleteQueryBuilder()
->deleteFrom( 'echo_event' )
->where( [ 'event_id' => $ids ] )
->caller( __METHOD__ )
->execute();
$eventsProcessed += $dbw->affectedRows();
$dbw->newDeleteQueryBuilder()
->deleteFrom( 'echo_target_page' )
->where( [ 'etp_event' => $ids ] )
->caller( __METHOD__ )
->execute();
$targetsProcessed += $dbw->affectedRows();
$this->output( "Deleted $eventsProcessed orphaned events and $targetsProcessed target_page rows.\n" );
$this->waitForReplication();
}
$this->output( "Removing any remaining orphaned echo_target_page rows with max etp_event of $maxId...\n" );
$iterator = new BatchRowIterator(
$dbr,
[ 'echo_target_page', 'echo_event' ],
'etp_event',
$this->getBatchSize()
);
$iterator->addJoinConditions( [ 'echo_event' => [ 'LEFT JOIN', 'event_id=etp_event' ] ] );
$iterator->addConditions(
[
'event_type' => null,
$dbr->expr( 'etp_event', '<', $maxId ),
]
);
$iterator->addOptions( [ 'DISTINCT' ] );
$iterator->setCaller( __METHOD__ );
$processed = 0;
foreach ( $iterator as $batch ) {
$ids = [];
foreach ( $batch as $row ) {
$ids[] = $row->etp_event;
}
$dbw->newDeleteQueryBuilder()
->deleteFrom( 'echo_target_page' )
->where( [ 'etp_event' => $ids ] )
->caller( __METHOD__ )
->execute();
$processed += $dbw->affectedRows();
$this->output( "Deleted $processed orphaned target_page rows.\n" );
$this->waitForReplication();
}
return [ $eventsProcessed, $targetsProcessed + $processed ];
}
}
// @codeCoverageIgnoreStart
$maintClass = RemoveOrphanedEvents::class;
require_once RUN_MAINTENANCE_IF_MAIN;
// @codeCoverageIgnoreEnd

File Metadata

Mime Type
text/x-php
Expires
Aug 19 2026, 17:24 (5 w, 13 m ago)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
53/06/9edd67af6e0940862c2123a2dfda
Default Alt Text
removeOrphanedEvents.php (4 KB)

Event Timeline