Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Process DB migration 5000 rows at a time instead of all at once. #905

Merged
merged 8 commits into from Jan 15, 2017
Merged

Process DB migration 5000 rows at a time instead of all at once. #905

Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
26ffa8e
Process DB migration 5000 rows at a time instead of all at once.
Jan 6, 2017
c0b51e9
Split retrieval of stream entries and while loop to make it easier to…
Jan 9, 2017
d9b7a6c
Use $wpdb->prepare instead of passing raw variables to $wpdb->get_res…
Jan 10, 2017
2fb8d35
Formatting updates for WP coding standards
Jan 10, 2017
d580de2
Move $wpdb->prepare directly into $wpdb->get_results
Jan 10, 2017
775dfa4
More formatting updates
Jan 10, 2017
1d7844d
Move function calls to single line
Jan 10, 2017
2c5d7e2
Move another multiline function call to single line
Jan 10, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
53 changes: 31 additions & 22 deletions includes/db-updates.php
View file
Open in desktop
Expand Up @@ -60,31 +60,40 @@ function wp_stream_update_auto_300( $db_version, $current_version ) {
$plugin = wp_stream_get_instance();
$plugin->install->install( $current_version );

$stream_entries = $wpdb->get_results( "SELECT * FROM {$wpdb->base_prefix}stream_tmp" );
$starting_row = 0;
$rows_per_round = 5000;

foreach ( $stream_entries as $entry ) {
$context = $wpdb->get_row(
$wpdb->prepare( "SELECT * FROM {$wpdb->base_prefix}stream_context_tmp WHERE record_id = %s LIMIT 1", $entry->ID )
);

$new_entry = array(
'site_id' => $entry->site_id,
'blog_id' => $entry->blog_id,
'user_id' => $entry->author,
'user_role' => $entry->author_role,
'summary' => $entry->summary,
'created' => $entry->created,
'connector' => $context->connector,
'context' => $context->context,
'action' => $context->action,
'ip' => $entry->ip,
);

if ( $entry->object_id && 0 !== $entry->object_id ) {
$new_entry['object_id'] = $entry->object_id;
$stream_entries = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$wpdb->base_prefix}stream_tmp LIMIT %d, %d", $starting_row, $rows_per_round ) );

while ( ! empty( $stream_entries ) ) {
foreach ( $stream_entries as $entry ) {
$context = $wpdb->get_row(
$wpdb->prepare( "SELECT * FROM {$wpdb->base_prefix}stream_context_tmp WHERE record_id = %s LIMIT 1", $entry->ID )
);

$new_entry = array(
'site_id' => $entry->site_id,
'blog_id' => $entry->blog_id,
'user_id' => $entry->author,
'user_role' => $entry->author_role,
'summary' => $entry->summary,
'created' => $entry->created,
'connector' => $context->connector,
'context' => $context->context,
'action' => $context->action,
'ip' => $entry->ip,
);

if ( $entry->object_id && 0 !== $entry->object_id ) {
$new_entry['object_id'] = $entry->object_id;
}

$wpdb->insert( $wpdb->base_prefix . 'stream', $new_entry );
}

$wpdb->insert( $wpdb->base_prefix . 'stream', $new_entry );
$starting_row += $rows_per_round;

$stream_entries = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$wpdb->base_prefix}stream_tmp LIMIT %d, %d", $starting_row, $rows_per_round ) );
}

$wpdb->query( "DROP TABLE {$wpdb->base_prefix}stream_tmp, {$wpdb->base_prefix}stream_context_tmp" );
Expand Down