maintenance/storage/resolveStubs.php

   1 <?php
   2 /**
   3  * Convert history stubs that point to an external row to direct external
   4  * pointers.
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License as published by
   8  * the Free Software Foundation; either version 2 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14  * GNU General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU General Public License along
  17  * with this program; if not, write to the Free Software Foundation, Inc.,
  18  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
  19  * http://www.gnu.org/copyleft/gpl.html
  20  *
  21  * @file
  22  * @ingroup Maintenance ExternalStorage
  23  */
  24
  25 define( 'REPORTING_INTERVAL', 100 );
  26
  27 if ( !defined( 'MEDIAWIKI' ) ) {
  28         $optionsWithArgs = array( 'm' );
  29
  30         require_once __DIR__ . '/../commandLine.inc';
  31
  32         resolveStubs();
  33 }
  34
  35 /**
  36  * Convert history stubs that point to an external row to direct
  37  * external pointers
  38  */
  39 function resolveStubs() {
  40         $fname = 'resolveStubs';
  41
  42         $dbr = wfGetDB( DB_SLAVE );
  43         $maxID = $dbr->selectField( 'text', 'MAX(old_id)', false, $fname );
  44         $blockSize = 10000;
  45         $numBlocks = intval( $maxID / $blockSize ) + 1;
  46
  47         for ( $b = 0; $b < $numBlocks; $b++ ) {
  48                 wfWaitForSlaves();
  49
  50                 printf( "%5.2f%%\n", $b / $numBlocks * 100 );
  51                 $start = intval( $maxID / $numBlocks ) * $b + 1;
  52                 $end = intval( $maxID / $numBlocks ) * ( $b + 1 );
  53
  54                 $res = $dbr->select( 'text', array( 'old_id', 'old_text', 'old_flags' ),
  55                         "old_id>=$start AND old_id<=$end " .
  56                         "AND old_flags LIKE '%object%' AND old_flags NOT LIKE '%external%' " .
  57                         'AND LOWER(CONVERT(LEFT(old_text,22) USING latin1)) = \'o:15:"historyblobstub"\'',
  58                         $fname );
  59                 foreach ( $res as $row ) {
  60                         resolveStub( $row->old_id, $row->old_text, $row->old_flags );
  61                 }
  62         }
  63         print "100%\n";
  64 }
  65
  66 /**
  67  * Resolve a history stub
  68  */
  69 function resolveStub( $id, $stubText, $flags ) {
  70         $fname = 'resolveStub';
  71
  72         $stub = unserialize( $stubText );
  73         $flags = explode( ',', $flags );
  74
  75         $dbr = wfGetDB( DB_SLAVE );
  76         $dbw = wfGetDB( DB_MASTER );
  77
  78         if ( strtolower( get_class( $stub ) ) !== 'historyblobstub' ) {
  79                 print "Error found object of class " . get_class( $stub ) . ", expecting historyblobstub\n";
  80
  81                 return;
  82         }
  83
  84         # Get the (maybe) external row
  85         $externalRow = $dbr->selectRow(
  86                 'text',
  87                 array( 'old_text' ),
  88                 array(
  89                         'old_id' => $stub->mOldId,
  90                         'old_flags' . $dbr->buildLike( $dbr->anyString(), 'external', $dbr->anyString() )
  91                 ),
  92                 $fname
  93         );
  94
  95         if ( !$externalRow ) {
  96                 # Object wasn't external
  97                 return;
  98         }
  99
 100         # Preserve the legacy encoding flag, but switch from object to external
 101         if ( in_array( 'utf-8', $flags ) ) {
 102                 $newFlags = 'external,utf-8';
 103         } else {
 104                 $newFlags = 'external';
 105         }
 106
 107         # Update the row
 108         # print "oldid=$id\n";
 109         $dbw->update( 'text',
 110                 array( /* SET */
 111                         'old_flags' => $newFlags,
 112                         'old_text' => $externalRow->old_text . '/' . $stub->mHash
 113                 ),
 114                 array( /* WHERE */
 115                         'old_id' => $id
 116                 ), $fname
 117         );
 118 }