37 parent::__construct();
38 $this->
addDescription(
'Updates page_restrictions table from old page_restriction column' );
46 if ( !$dbw->tableExists(
'page_restrictions', __METHOD__ ) ) {
47 $this->
fatalError(
"page_restrictions table does not exist" );
50 if ( !$dbw->fieldExists(
'page',
'page_restrictions' ) ) {
51 $this->
output(
"Migration is not needed.\n" );
55 $encodedExpiry = $dbw->getInfinity();
57 $maxPageId = $dbw->newSelectQueryBuilder()
58 ->select(
'MAX(page_id)' )
60 ->caller( __METHOD__ )->fetchField();
61 $escapedEmptyBlobValue = $dbw->addQuotes(
'' );
66 $batchMaxPageId = $batchMinPageId + $batchSize;
68 $this->
output(
"...processing page IDs from $batchMinPageId to $batchMaxPageId.\n" );
70 $res = $dbw->newSelectQueryBuilder()
71 ->select( [
'page_id',
'page_restrictions' ] )
74 "page_restrictions != $escapedEmptyBlobValue",
75 $dbw->expr(
'page_id',
'>', $batchMinPageId ),
76 $dbw->expr(
'page_id',
'<=', $batchMaxPageId ),
78 ->caller( __METHOD__ )->fetchResultSet();
81 if ( !$res->numRows() ) {
82 $batchMinPageId = $batchMaxPageId;
89 foreach ( $res as $row ) {
90 $pageIds[] = $row->page_id;
92 $restrictionsByAction = $this->mapLegacyRestrictionBlob( $row->page_restrictions );
94 # Update restrictions table
95 foreach ( $restrictionsByAction as $action => $restrictions ) {
97 'pr_page' => $row->page_id,
99 'pr_level' => $restrictions,
101 'pr_expiry' => $encodedExpiry
110 $dbw->newInsertQueryBuilder()
111 ->insertInto(
'page_restrictions' )
114 ->caller( __METHOD__ )->execute();
117 $dbw->newUpdateQueryBuilder()
119 ->set( [
'page_restrictions' =>
'' ] )
120 ->where( [
'page_id' => $pageIds ] )
121 ->caller( __METHOD__ )
126 $batchMinPageId = $batchMaxPageId;
127 }
while ( $batchMaxPageId < $maxPageId );
129 $this->
output(
"...Done!\n" );
141 private function mapLegacyRestrictionBlob( $legacyBlob ) {
142 $oldRestrictions = [];
144 foreach ( explode(
':', trim( $legacyBlob ) ) as $restrict ) {
145 $temp = explode(
'=', trim( $restrict ) );
148 if ( count( $temp ) == 1 ) {
149 $level = trim( $temp[0] );
151 $oldRestrictions[
'edit'] = $level;
152 $oldRestrictions[
'move'] = $level;
154 $restriction = trim( $temp[1] );
156 if ( $restriction !=
'' ) {
157 $oldRestrictions[$temp[0]] = $restriction;
162 return $oldRestrictions;
Abstract maintenance class for quickly writing and churning out maintenance scripts with minimal effo...
beginTransaction(IDatabase $dbw, $fname)
Begin a transaction on a DB.
commitTransaction(IDatabase $dbw, $fname)
Commit the transaction on a DB handle and wait for replica DBs to catch up.
output( $out, $channel=null)
Throw some output to the user.
addDescription( $text)
Set the description text.
fatalError( $msg, $exitCode=1)
Output a message and terminate the current script.