# stream/3.0.7/includes/db-updates.php

Stream – Activity Log & Audit Trail, version 3.0.7. 77 lines.

- Page: https://pluginprobe.com/plugins/stream/3.0.7/code/includes/db-updates.php
- Raw: https://pluginprobe.com/plugins/stream/3.0.7/raw/includes/db-updates.php
- Modified: 2016-07-14T01:50:38+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/stream/3.0.7/code/includes/db-updates.php#L10-L20`.

```php
<?php
/**
 * Version 3.0.2
 *
 * @param string $db_version
 * @param string $current_version
 *
 * @return string
 */
function wp_stream_update_302( $db_version, $current_version ) {
	global $wpdb;

	$stream_entries = $wpdb->get_results( "SELECT * FROM {$wpdb->base_prefix}stream" );
	foreach ( $stream_entries as $entry ) {
		$class = 'Connector_' . $entry->context;
		if ( class_exists( $class ) ) {
			$connector = new $class();
			$wpdb->update( $wpdb->base_prefix . 'stream', array( 'connector' => $connector->name ), array( 'ID' => $entry->ID ) );
		} else {
			$wpdb->update( $wpdb->base_prefix . 'stream', array( 'connector' => strtolower( $entry->connector ) ), array( 'ID' => $entry->ID ) );
		}
	}

	return $current_version;
}

/**
 * Version 3.0.0
 *
 * Update from 1.4.9
 *
 * @param string $db_version
 * @param string $current_version
 *
 * @return string
 */
function wp_stream_update_auto_300( $db_version, $current_version ) {
	global $wpdb;

	// Get only the author_meta values that are double-serialized
	$wpdb->query( "RENAME TABLE {$wpdb->base_prefix}stream TO {$wpdb->base_prefix}stream_tmp, {$wpdb->base_prefix}stream_context TO {$wpdb->base_prefix}stream_context_tmp" );

	$plugin = wp_stream_get_instance();
	$plugin->install->install( $current_version );

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

	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->query( "DROP TABLE {$wpdb->base_prefix}stream_tmp, {$wpdb->base_prefix}stream_context_tmp" );

	return $current_version;
}

```