Ticket #30261: 30261.11.diff

src/wp-admin/includes/schema.php

@@ -496 +496 @@
 
         // 3.5
         'link_manager_enabled' => 0,
+
+        // 4.3
+        'shared_terms_split' => 0,
         );
 
         // 3.3

src/wp-admin/includes/upgrade.php

@@ -1506 +1506 @@
         }
 
         if ( $wp_current_db_version < 32814 ) {
-                split_all_shared_terms();
+                _wp_batch_split_terms();
         }
 
+
         if ( $wp_current_db_version < 33055 && 'utf8mb4' === $wpdb->charset ) {
                 if ( is_multisite() ) {
                         $tables = $wpdb->tables( 'blog' );
@@ -1881 +1882 @@
 }
 
 /**
- * Splits all shared taxonomy terms.
- *
- * @since 4.3.0
- *
- * @global wpdb $wpdb WordPress database abstraction object.
- */
-function split_all_shared_terms() {
-        global $wpdb;
-
-        // Get a list of shared terms (those with more than one associated row in term_taxonomy).
-        $shared_terms = $wpdb->get_results(
-                "SELECT tt.term_id, t.*, count(*) as term_tt_count FROM {$wpdb->term_taxonomy} tt
-                 LEFT JOIN {$wpdb->terms} t ON t.term_id = tt.term_id
-                 GROUP BY t.term_id
-                 HAVING term_tt_count > 1"
-        );
-
-        if ( empty( $shared_terms ) ) {
-                return;
-        }
-
-        // Rekey shared term array for faster lookups.
-        $_shared_terms = array();
-        foreach ( $shared_terms as $shared_term ) {
-                $term_id = intval( $shared_term->term_id );
-                $_shared_terms[ $term_id ] = $shared_term;
-        }
-        $shared_terms = $_shared_terms;
-
-        // Get term taxonomy data for all shared terms.
-        $shared_term_ids = implode( ',', array_keys( $shared_terms ) );
-        $shared_tts = $wpdb->get_results( "SELECT * FROM {$wpdb->term_taxonomy} WHERE `term_id` IN ({$shared_term_ids})" );
-
-        // Split term data recording is slow, so we do it just once, outside the loop.
-        $suspend = wp_suspend_cache_invalidation( true );
-        $split_term_data = get_option( '_split_terms', array() );
-        $skipped_first_term = $taxonomies = array();
-        foreach ( $shared_tts as $shared_tt ) {
-                $term_id = intval( $shared_tt->term_id );
-
-                // Don't split the first tt belonging to a given term_id.
-                if ( ! isset( $skipped_first_term[ $term_id ] ) ) {
-                        $skipped_first_term[ $term_id ] = 1;
-                        continue;
-                }
-
-                if ( ! isset( $split_term_data[ $term_id ] ) ) {
-                        $split_term_data[ $term_id ] = array();
-                }
-
-                // Keep track of taxonomies whose hierarchies need flushing.
-                if ( ! isset( $taxonomies[ $shared_tt->taxonomy ] ) ) {
-                        $taxonomies[ $shared_tt->taxonomy ] = 1;
-                }
-
-                // Split the term.
-                $split_term_data[ $term_id ][ $shared_tt->taxonomy ] = _split_shared_term( $shared_terms[ $term_id ], $shared_tt, false );
-        }
-
-        // Rebuild the cached hierarchy for each affected taxonomy.
-        foreach ( array_keys( $taxonomies ) as $tax ) {
-                delete_option( "{$tax}_children" );
-                _get_term_hierarchy( $tax );
-        }
-
-        wp_suspend_cache_invalidation( $suspend );
-        update_option( '_split_terms', $split_term_data );
-}
-
-/**
  * Retrieve all options as it was for 1.2.
  *
  * @since 1.2.0

src/wp-includes/default-filters.php

@@ -331 +331 @@
 add_action( 'split_shared_term', '_wp_check_split_default_terms',  10, 4 );
 add_action( 'split_shared_term', '_wp_check_split_terms_in_menus', 10, 4 );
 add_action( 'split_shared_term', '_wp_check_split_nav_menu_terms', 10, 4 );
+add_action( 'split_shared_term_batch', '_wp_batch_split_terms' );
 
 /**
  * Filters formerly mixed into wp-includes

src/wp-includes/taxonomy.php

@@ -4249 +4249 @@
                 $term_taxonomy_id = intval( $term_taxonomy->term_taxonomy_id );
         }
 
-        // Don't try to split terms if database schema does not support shared slugs.
-        $current_db_version = get_option( 'db_version' );
-        if ( $current_db_version < 30133 ) {
-                return $term_id;
-        }
-
         // If there are no shared term_taxonomy rows, there's nothing to do here.
         $shared_tt_count = $wpdb->get_var( $wpdb->prepare( "SELECT COUNT(*) FROM $wpdb->term_taxonomy tt WHERE tt.term_id = %d AND tt.term_taxonomy_id != %d", $term_id, $term_taxonomy_id ) );
 
@@ -4339 +4333 @@
 }
 
 /**
+ * Splits a batch of shared taxonomy terms.
+ *
+ * @since 4.3.0
+ *
+ * @global wpdb $wpdb WordPress database abstraction object.
+ */
+function _wp_batch_split_terms() {
+        global $wpdb;
+
+        /*
+         * FROM {$wpdb->term_taxonomy} isn't necessaray for GET_LOCK(), but it'll
+         * help HyperDB direct the request to the correct MySQL server.
+         * We need to make sure the query is going to the master, though.
+         */
+        if ( is_callable( array( $wpdb, 'send_reads_to_master' ) ) ) {
+                $wpdb->send_reads_to_master();
+        }
+        $lock = $wpdb->get_var( "SELECT GET_LOCK( 'split_terms', 10 ) FROM {$wpdb->term_taxonomy}" );
+        if ( 1 !== $lock ) {
+                // The lock failed. Try again later.
+                wp_schedule_single_event( time() + ( 5 * MINUTE_IN_SECONDS ), 'split_shared_term_batch' );
+                return;
+        }
+
+        // Get a list of shared terms (those with more than one associated row in term_taxonomy).
+        $shared_terms = $wpdb->get_results(
+                "SELECT tt.term_id, t.*, count(*) as term_tt_count FROM {$wpdb->term_taxonomy} tt
+                 LEFT JOIN {$wpdb->terms} t ON t.term_id = tt.term_id
+                 GROUP BY t.term_id
+                 HAVING term_tt_count > 1
+                 LIMIT 20"
+        );
+
+        // Shared terms found? Need to run this script again.
+        if ( ! empty( $shared_terms ) ) {
+                wp_schedule_single_event( time() + ( 5 * MINUTE_IN_SECONDS ), 'split_shared_term_batch' );
+        }
+
+        // Rekey shared term array for faster lookups.
+        $_shared_terms = array();
+        foreach ( $shared_terms as $shared_term ) {
+                $term_id = intval( $shared_term->term_id );
+                $_shared_terms[ $term_id ] = $shared_term;
+        }
+        $shared_terms = $_shared_terms;
+
+        // Get term taxonomy data for all shared terms.
+        $shared_term_ids = implode( ',', array_keys( $shared_terms ) );
+        $shared_tts = $wpdb->get_results( "SELECT * FROM {$wpdb->term_taxonomy} WHERE `term_id` IN ({$shared_term_ids})" );
+
+        // Split term data recording is slow, so we do it just once, outside the loop.
+        $suspend = wp_suspend_cache_invalidation( true );
+        $split_term_data = get_option( '_split_terms', array() );
+        $skipped_first_term = $taxonomies = array();
+        foreach ( $shared_tts as $shared_tt ) {
+                $term_id = intval( $shared_tt->term_id );
+
+                // Don't split the first tt belonging to a given term_id.
+                if ( ! isset( $skipped_first_term[ $term_id ] ) ) {
+                        $skipped_first_term[ $term_id ] = 1;
+                        continue;
+                }
+
+                if ( ! isset( $split_term_data[ $term_id ] ) ) {
+                        $split_term_data[ $term_id ] = array();
+                }
+
+                // Keep track of taxonomies whose hierarchies need flushing.
+                if ( ! isset( $taxonomies[ $shared_tt->taxonomy ] ) ) {
+                        $taxonomies[ $shared_tt->taxonomy ] = 1;
+                }
+
+                // Split the term.
+                $split_term_data[ $term_id ][ $shared_tt->taxonomy ] = _split_shared_term( $shared_terms[ $term_id ], $shared_tt, false );
+        }
+
+        // Rebuild the cached hierarchy for each affected taxonomy.
+        foreach ( array_keys( $taxonomies ) as $tax ) {
+                delete_option( "{$tax}_children" );
+                _get_term_hierarchy( $tax );
+        }
+
+        wp_suspend_cache_invalidation( $suspend );
+        update_option( '_split_terms', $split_term_data );
+
+        $lock = $wpdb->get_var( "SELECT RELEASE_LOCK( 'split_terms' ) FROM {$wpdb->term_taxonomy}" );
+}
+
+/**
  * Check default categories when a term gets split to see if any of them need to be updated.
  *
  * @ignore