wikimedia/mediawiki-extensions-AbuseFilter
1
0
Fork 0
mirror of https://gerrit.wikimedia.org/r/mediawiki/extensions/AbuseFilter.git synced 2024-09-23 10:18:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed broken batching in –PurgeOldLogIPData

Browse source 
Bug: T95382
Change-Id: I133642e5dd8e75e98e6189ad10f54dbbea648c8d
This commit is contained in:
Aaron Schulz 2015-04-07 19:28:01 -07:00
parent c127871784
commit 4219fa141c
1 changed files with 18 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
maintenance/purgeOldLogIPData.php
View file

@ -19,29 +19,34 @@ class PurgeOldLogIPData extends Maintenance {
$this->output( "Purging old IP Address data from abuse_filter_log...\n" );
$dbw = wfGetDB( DB_MASTER );
$cutoffUnix = time() - $wgAbuseFilterLogIPMaxAge;
$count = 0;
while ( true ) {
$dbw->begin();
$dbw->update(
do {
$ids = $dbw->selectFieldValues(
'abuse_filter_log',
array( 'afl_ip' => '' ),
'afl_id',
array(
'afl_ip <> ""',
"afl_timestamp < " . $dbw->addQuotes( $dbw->timestamp( time() - $wgAbuseFilterLogIPMaxAge ) )
"afl_timestamp < " . $dbw->addQuotes( $dbw->timestamp( $cutoffUnix ) )
),
__METHOD__,
array( 'LIMIT' => $this->mBatchSize )
);
$count += $dbw->affectedRows();
$dbw->commit();
if ( $dbw->affectedRows() < $this->mBatchSize ) {
break; // all updated
}
$this->output( "$count\n" );
wfWaitForSlaves();
}
if ( $ids ) {
$dbw->update(
'abuse_filter_log',
array( 'afl_ip' => '' ),
array( 'afl_id' => $ids ),
__METHOD__
);
$count += $dbw->affectedRows();
$this->output( "$count\n" );
wfWaitForSlaves();
}
} while ( count( $ids ) >= $this->mBatchSize );
$this->output( "$count rows.\n" );