Committed a bunch of live hacks from Wikimedia servers
[lhc/web/wiklou.git] / maintenance / updaters.inc
index 6ce2de6..9acf302 100644 (file)
@@ -22,10 +22,14 @@ $wgNewTables = array(
        array( 'objectcache',   'patch-objectcache.sql' ),
        array( 'categorylinks', 'patch-categorylinks.sql' ),
        array( 'logging',       'patch-logging.sql' ),
-       array( 'validate',      'patch-validate.sql' ),
        array( 'user_newtalk',  'patch-usernewtalk2.sql' ),
        array( 'transcache',    'patch-transcache.sql' ),
        array( 'trackbacks',    'patch-trackbacks.sql' ),
+       array( 'externallinks', 'patch-externallinks.sql' ),
+       array( 'job',           'patch-job.sql' ),
+       array( 'langlinks',     'patch-langlinks.sql' ),
+       array( 'querycache_info', 'patch-querycacheinfo.sql' ),
+       array( 'filearchive',   'patch-filearchive.sql' ),
 );
 
 $wgNewFields = array(
@@ -39,6 +43,7 @@ $wgNewFields = array(
        array( 'user',          'user_real_name',   'patch-user-realname.sql' ),
        array( 'user',          'user_token',       'patch-user_token.sql' ),
        array( 'user',          'user_email_token', 'patch-user_email_token.sql' ),
+       array( 'user',          'user_registration','patch-user_registration.sql' ),
        array( 'logging',       'log_params',       'patch-log_params.sql' ),
        array( 'archive',       'ar_rev_id',        'patch-archive-rev_id.sql' ),
        array( 'archive',       'ar_text_id',       'patch-archive-text_id.sql' ),
@@ -47,9 +52,11 @@ $wgNewFields = array(
        array( 'image',         'img_width',        'patch-img_width.sql' ),
        array( 'image',         'img_metadata',     'patch-img_metadata.sql' ),
        array( 'image',         'img_media_type',   'patch-img_media_type.sql' ),
-       array( 'validate',      'val_ip',           'patch-val_ip.sql' ),
        array( 'site_stats',    'ss_total_pages',   'patch-ss_total_articles.sql' ),
-       array( 'interwiki',     'iw_trans',         'patch-interwiki-trans.sql' ),
+       array( 'interwiki',     'iw_trans',         'patch-interwiki-trans.sql' ),
+       array( 'ipblocks',      'ipb_range_start',  'patch-ipb_range_start.sql' ),
+       array( 'site_stats',    'ss_images',        'patch-ss_images.sql' ),
+       array( 'ipblocks',      'ipb_anon_only',    'patch-ipb_anon_only.sql' ),
 );
 
 function rename_table( $from, $to, $patch ) {
@@ -130,7 +137,7 @@ function update_passwords() {
 
 function do_interwiki_update() {
        # Check that interwiki table exists; if it doesn't source it
-       global $wgDatabase;
+       global $wgDatabase, $IP;
        if( $wgDatabase->tableExists( "interwiki" ) ) {
                echo "...already have interwiki table\n";
                return true;
@@ -139,7 +146,7 @@ function do_interwiki_update() {
        dbsource( archive("patch-interwiki.sql") );
        echo "ok\n";
        echo "Adding default interwiki definitions: ";
-       dbsource( "maintenance/interwiki.sql" );
+       dbsource( "$IP/maintenance/interwiki.sql" );
        echo "ok\n";
 }
 
@@ -157,6 +164,20 @@ function do_index_update() {
        return false;
 }
 
+function do_image_index_update() {
+       global $wgDatabase;
+
+       $meta = $wgDatabase->fieldInfo( "image", "img_major_mime" );
+       if( $meta->multiple_key == 0 ) {
+               echo "Updating indexes to 20050912: ";
+               dbsource( archive("patch-mimesearch-indexes.sql") );
+               echo "ok\n";
+               return true;
+       }
+       echo "...indexes seem up to 20050912 standards\n";
+       return false;
+}
+
 function do_image_name_unique_update() {
        global $wgDatabase;
        if( $wgDatabase->indexExists( 'image', 'PRIMARY' ) ) {
@@ -168,15 +189,46 @@ function do_image_name_unique_update() {
        }
 }
 
+function do_logging_timestamp_index() {
+       global $wgDatabase;
+       if( $wgDatabase->indexExists( 'logging', 'times' ) ) {
+               echo "...timestamp key on logging already exists.\n";
+       } else {
+               echo "Adding timestamp key on logging table... ";
+               dbsource( archive("patch-logging-times-index.sql"), $wgDatabase );
+               echo "ok\n";
+       }
+}
+
+
 function do_watchlist_update() {
        global $wgDatabase;
+       $fname = 'do_watchlist_update';
        if( $wgDatabase->fieldExists( 'watchlist', 'wl_notificationtimestamp' ) ) {
                echo "The watchlist table is already set up for email notification.\n";
        } else {
                echo "Adding wl_notificationtimestamp field for email notification management.";
                /* ALTER TABLE watchlist ADD (wl_notificationtimestamp varchar(14) binary NOT NULL default '0'); */
-               dbsource( "maintenance/archives/patch-email-notification.sql", $wgDatabase );
+               dbsource( archive( 'patch-email-notification.sql' ), $wgDatabase );
+               echo "ok\n";
+       }
+       # Check if we need to add talk page rows to the watchlist
+       $talk = $wgDatabase->selectField( 'watchlist', 'count(*)', 'wl_namespace & 1', $fname );
+       $nontalk = $wgDatabase->selectField( 'watchlist', 'count(*)', 'NOT (wl_namespace & 1)', $fname );
+       if ( $talk != $nontalk ) {
+               echo "Adding missing watchlist talk page rows... ";
+               flush();
+
+               $wgDatabase->insertSelect( 'watchlist', 'watchlist', 
+                       array(
+                               'wl_user' => 'wl_user',
+                               'wl_namespace' => 'wl_namespace | 1',
+                               'wl_title' => 'wl_title',
+                               'wl_notificationtimestamp' => 'wl_notificationtimestamp'
+                       ), array( 'NOT (wl_namespace & 1)' ), $fname, 'IGNORE' );
                echo "ok\n";
+       } else {
+               echo "...watchlist talk page rows already present\n";
        }
 }
 
@@ -223,7 +275,7 @@ function do_user_update() {
        global $wgDatabase;
        if( $wgDatabase->fieldExists( 'user', 'user_emailauthenticationtimestamp' ) ) {
                echo "User table contains old email authentication field. Dropping... ";
-               dbsource( "maintenance/archives/patch-email-authentication.sql", $wgDatabase );
+               dbsource( archive( 'patch-email-authentication.sql' ), $wgDatabase );
                echo "ok\n";
        } else {
                echo "...user table does not contain old email authentication field.\n";
@@ -247,7 +299,7 @@ function do_logging_encoding() {
                echo "Logging table has correct title encoding.\n";
        } else {
                echo "Fixing title encoding on logging table... ";
-               dbsource( 'maintenance/archives/patch-logging-title.sql', $wgDatabase );
+               dbsource( archive( 'patch-logging-title.sql' ), $wgDatabase );
                echo "ok\n";
        }
 }
@@ -422,7 +474,7 @@ function do_inverse_timestamp() {
        $fname="do_schema_restructuring";
        if( $wgDatabase->fieldExists( 'revision', 'inverse_timestamp' ) ) {
                echo "Removing revision.inverse_timestamp and fixing indexes... ";
-               dbsource( 'maintenance/archives/patch-inverse_timestamp.sql', $wgDatabase );
+               dbsource( archive( 'patch-inverse_timestamp.sql' ), $wgDatabase );
                echo "ok\n";
        } else {
                echo "revision timestamp indexes already up to 2005-03-13\n";
@@ -435,7 +487,7 @@ function do_text_id() {
                echo "...rev_text_id already in place.\n";
        } else {
                echo "Adding rev_text_id field... ";
-               dbsource( 'maintenance/archives/patch-rev_text_id.sql', $wgDatabase );
+               dbsource( archive( 'patch-rev_text_id.sql' ), $wgDatabase );
                echo "ok\n";
        }
 }
@@ -484,7 +536,7 @@ function do_pagelinks_update() {
                echo "...already have pagelinks table.\n";
        } else {
                echo "Converting links and brokenlinks tables to pagelinks... ";
-               dbsource( "maintenance/archives/patch-pagelinks.sql", $wgDatabase );
+               dbsource( archive( 'patch-pagelinks.sql' ), $wgDatabase );
                echo "ok\n";
                flush();
 
@@ -523,7 +575,7 @@ function do_drop_img_type() {
 
        if( $wgDatabase->fieldExists( 'image', 'img_type' ) ) {
                echo "Dropping unused img_type field in image table... ";
-               dbsource( "maintenance/archives/patch-drop_img_type.sql", $wgDatabase );
+               dbsource( archive( 'patch-drop_img_type.sql' ), $wgDatabase );
                echo "ok\n";
        } else {
                echo "No img_type field in image table; Good.\n";
@@ -549,7 +601,7 @@ function do_user_unique_update() {
                        echo "WARNING: This next step will probably fail due to unfixed duplicates...\n";
                }
                echo "Adding unique index on user_name... ";
-               dbsource( 'maintenance/archives/patch-user_nameindex.sql', $wgDatabase );
+               dbsource( archive( 'patch-user_nameindex.sql' ), $wgDatabase );
                echo "ok\n";
        }
 }
@@ -564,13 +616,13 @@ function do_user_groups_update() {
        }
 
        echo "Adding user_groups table... ";
-       dbsource( 'maintenance/archives/patch-user_groups.sql', $wgDatabase );
+       dbsource( archive( 'patch-user_groups.sql' ), $wgDatabase );
        echo "ok\n";
 
        if( !$wgDatabase->tableExists( 'user_rights' ) ) {
                if( $wgDatabase->fieldExists( 'user', 'user_rights' ) ) {
                        echo "Upgrading from a 1.3 or older database? Breaking out user_rights for conversion...";
-                       dbsource( 'maintenance/archives/patch-user_rights.sql', $wgDatabase );
+                       dbsource( archive( 'patch-user_rights.sql' ), $wgDatabase );
                        echo "ok\n";
                } else {
                        echo "*** WARNING: couldn't locate user_rights table or field for upgrade.\n";
@@ -616,7 +668,7 @@ function do_user_groups_reformat() {
                echo "ok\n";
 
                echo "Re-adding fresh user_groups table... ";
-               dbsource( 'maintenance/archives/patch-user_groups.sql', $wgDatabase );
+               dbsource( archive( 'patch-user_groups.sql' ), $wgDatabase );
                echo "ok\n";
 
                echo "***\n";
@@ -634,10 +686,10 @@ function do_watchlist_null() {
        # and update old broken items.
        global $wgDatabase;
        $info = $wgDatabase->fieldInfo( 'watchlist', 'wl_notificationtimestamp' );
-       
+
        if( $info->not_null ) {
                echo "Making wl_notificationtimestamp nullable... ";
-               dbsource( 'maintenance/archives/patch-watchlist-null.sql', $wgDatabase );
+               dbsource( archive( 'patch-watchlist-null.sql' ), $wgDatabase );
                echo "ok\n";
        } else {
                echo "...wl_notificationtimestamp is already nullable.\n";
@@ -645,8 +697,92 @@ function do_watchlist_null() {
 
 }
 
-function do_all_updates() {
-       global $wgNewTables, $wgNewFields, $wgRenamedTables;
+/**
+ * @bug 3946
+ */
+function do_page_random_update() {
+       global $wgDatabase;
+
+       echo "Setting page_random to a random value on rows where it equals 0...";
+
+       $page = $wgDatabase->tableName( 'page' );
+       $wgDatabase->query( "UPDATE $page SET page_random = RAND() WHERE page_random = 0", 'do_page_random_update' );
+       $rows = $wgDatabase->affectedRows();
+
+       echo "changed $rows rows\n";
+}
+
+function do_templatelinks_update() {
+       global $wgDatabase, $wgLoadBalancer;
+       $fname = 'do_templatelinks_update';
+
+       if ( $wgDatabase->tableExists( 'templatelinks' ) ) {
+               echo "...templatelinks table already exists\n";
+               return;
+       }
+       echo "Creating templatelinks table...\n";
+       dbsource( archive('patch-templatelinks.sql'), $wgDatabase );
+       echo "Populating...\n";
+       if ( isset( $wgLoadBalancer ) && $wgLoadBalancer->getServerCount() > 1 ) {
+               // Slow, replication-friendly update
+               $res = $wgDatabase->select( 'pagelinks', array( 'pl_from', 'pl_namespace', 'pl_title' ),
+                       array( 'pl_namespace' => NS_TEMPLATE ), $fname );
+               $count = 0;
+               while ( $row = $wgDatabase->fetchObject( $res ) ) {
+                       $count = ($count + 1) % 100;
+                       if ( $count == 0 ) {
+                               if ( function_exists( 'wfWaitForSlaves' ) ) {
+                                       wfWaitForSlaves( 10 );
+                               } else {
+                                       sleep( 1 );
+                               }
+                       }
+                       $wgDatabase->insert( 'templatelinks',
+                               array(
+                                       'tl_from' => $row->pl_from,
+                                       'tl_namespace' => $row->pl_namespace,
+                                       'tl_title' => $row->pl_title,
+                               ), $fname
+                       );
+
+               }
+               $wgDatabase->freeResult( $res );
+       } else {
+               // Fast update
+               $wgDatabase->insertSelect( 'templatelinks', 'pagelinks',
+                       array(
+                               'tl_from' => 'pl_from',
+                               'tl_namespace' => 'pl_namespace',
+                               'tl_title' => 'pl_title'
+                       ), array(
+                               'pl_namespace' => 10
+                       ), $fname
+               );
+       }
+       echo "Done. Please run maintenance/refreshLinks.php for a more thorough templatelinks update.\n";
+}
+
+# July 2006
+# Add ( rc_namespace, rc_user_text ) index [R. Church]
+function do_rc_indices_update() {
+       global $wgDatabase;
+       echo( "Checking for additional recent changes indices...\n" );
+       # See if we can find the index we want
+       $info = $wgDatabase->indexInfo( 'recentchanges', 'rc_ns_usertext', __METHOD__ );
+       if( !$info ) {
+               # None, so create
+               echo( "...index on ( rc_namespace, rc_user_text ) not found; creating\n" );
+               dbsource( archive( 'patch-recentchanges-utindex.sql' ) );
+       } else {
+               # Index seems to exist
+               echo( "...seems to be ok\n" );
+       }
+}
+
+function do_all_updates( $doShared = false ) {
+       global $wgNewTables, $wgNewFields, $wgRenamedTables, $wgSharedDB, $wgDatabase;
+
+       $doUser = !$wgSharedDB || $doShared;
 
        # Rename tables
        foreach ( $wgRenamedTables as $tableRecord ) {
@@ -661,7 +797,9 @@ function do_all_updates() {
 
        # Add missing fields
        foreach ( $wgNewFields as $fieldRecord ) {
-               add_field( $fieldRecord[0], $fieldRecord[1], $fieldRecord[2] );
+               if ( $fieldRecord[0] != 'user' || $doUser ) {
+                       add_field( $fieldRecord[0], $fieldRecord[1], $fieldRecord[2] );
+               }
                flush();
        }
 
@@ -671,7 +809,9 @@ function do_all_updates() {
        do_old_links_update(); flush();
        do_image_name_unique_update(); flush();
        do_watchlist_update(); flush();
-       do_user_update(); flush();
+       if ( $doUser ) {
+               do_user_update(); flush();
+       }
 ###### do_copy_newtalk_to_watchlist(); flush();
        do_logging_encoding(); flush();
 
@@ -681,24 +821,35 @@ function do_all_updates() {
        do_namespace_size(); flush();
 
        do_pagelinks_update(); flush();
+       do_templatelinks_update(); flush(); // after pagelinks
 
        do_drop_img_type(); flush();
 
-       do_user_unique_update(); flush();
+       if ( $doUser ) {
+               do_user_unique_update(); flush();
+       }
        do_user_groups_update(); flush();
-       
+
        do_watchlist_null(); flush();
 
+       //do_image_index_update(); flush();
+
+       do_logging_timestamp_index(); flush();
+
+       do_page_random_update(); flush();
+       
+       do_rc_indices_update(); flush();
+
        initialiseMessages(); flush();
 }
 
 function archive($name) {
-       global $wgDBtype;
+       global $wgDBtype, $IP;
        switch ($wgDBtype) {
        case "oracle":
-               return "maintenance/oracle/archives/$name";
+               return "$IP/maintenance/oracle/archives/$name";
        default:
-               return "maintenance/archives/$name";
+               return "$IP/maintenance/archives/$name";
        }
 }
 ?>