<?php

$IP = getenv( 'MW_INSTALL_PATH' );
if ( $IP === false ) {
	$IP = __DIR__ . '/../..';
}

require_once( "$IP/maintenance/Maintenance.php" );

/**
 * @ingroup Maintenance
 */
class CleanupArchiveUserText extends Maintenance {
	public function __construct() {
		parent::__construct();
		$this->mDescription = "Update the archive table where users were previously renamed, but their archive contributions were not";
	}

	public function execute() {
		$dbw = wfGetDB( DB_MASTER );
		do {
			$res = $dbw->select(
				array( 'archive', 'user' ),
				array( 'DISTINCT ar_user_text', 'user_name', 'ar_user' ),
				array(
					'ar_user_text <> user_name',
					'ar_user = user_id',
				),
				__METHOD__,
				array( 'LIMIT' => 50 )
			);
			$results = 0;
			foreach( $res as $row ) {
				$results++;
				$this->output( "User:{$row->ar_user_text} => User:{$row->user_name} " );
				$dbw->update(
					'archive',
					array( 'ar_user_text' => $row->user_name ),
					array(
						'ar_user_text' => $row->ar_user_text,
						'ar_user' => $row->ar_user,
					),
					__METHOD__,
					array( 'LIMIT' => 50 )
				);
				$affected = $dbw->affectedRows();
				$this->output( "$affected rows\n" );
				wfWaitForSlaves();
			}
		} while ( $results === 50 );
	}

	public function getDbType() {
		return Maintenance::DB_ADMIN;
	}
}

$maintClass = "CleanupArchiveUserText";
require_once( RUN_MAINTENANCE_IF_MAIN );