onTransactionPreCommitOrIdle( function() use ( $dbw, $namespace, $dbkeys ) { // Determine which pages need to be updated. // This is necessary to prevent the job queue from smashing the DB with // large numbers of concurrent invalidations of the same page. $now = $dbw->timestamp(); $ids = $dbw->selectFieldValues( 'page', 'page_id', [ 'page_namespace' => $namespace, 'page_title' => $dbkeys, 'page_touched < ' . $dbw->addQuotes( $now ) ], __METHOD__ ); if ( $ids === [] ) { return; } // Do the update. // We still need the page_touched condition, in case the row has changed since // the non-locking select above. $dbw->update( 'page', [ 'page_touched' => $now ], [ 'page_id' => $ids, 'page_touched < ' . $dbw->addQuotes( $now ) ], __METHOD__ ); } ); } }