Migration_7.php — Independent Analytics – WordPress Analytics Plugin 2.14.2

independent-analytics / IAWP / Migrations / Migration_7.php

independent-analytics / IAWP / Migrations Last commit date

Migration_7.php

42 lines

1	<?php
2
3	namespace IAWP\Migrations;
4
5	use IAWP\Query;
6	/** @internal */
7	class Migration_7 extends \IAWP\Migrations\Migration
8	{
9	/**
10	* @var string
11	*/
12	protected $database_version = '7';
13	/**
14	* @return void
15	*/
16	protected function migrate() : void
17	{
18	global $wpdb;
19	\update_option('iawp_need_clear_cache', \true, \true);
20	$charset_collate = $wpdb->get_charset_collate();
21	$sessions_table = Query::get_table_name(Query::SESSIONS);
22	$views_table = Query::get_table_name(Query::VIEWS);
23	$visitors_table = Query::get_table_name(Query::VISITORS);
24	$wpdb->query("DROP TABLE IF EXISTS {$sessions_table};");
25	$wpdb->query("CREATE TABLE {$sessions_table} (\n session_id bigint(20) UNSIGNED AUTO_INCREMENT,\n visitor_id varchar(32),\n initial_view_id bigint(20) UNSIGNED,\n referrer_id bigint(20) UNSIGNED,\n campaign_id bigint(20) UNSIGNED,\n created_at datetime NOT NULL,\n legacy_view boolean DEFAULT false NOT NULL,\n PRIMARY KEY (session_id)\n ) {$charset_collate};");
26	$wpdb->query("\n ALTER TABLE {$views_table}\n ADD (\n session_id bigint(20) UNSIGNED\n ),\n ADD INDEX (visitor_id);\n ");
27	$wpdb->query("\n INSERT INTO {$sessions_table} (visitor_id, initial_view_id, referrer_id, campaign_id, created_at, legacy_view)\n SELECT IF(visitors.visitor_token = '', NULL, LEFT(visitors.visitor_token, 32)) AS visitor_id,\n views.id AS initial_view_id,\n views.referrer_id,\n views.campaign_id,\n views.viewed_at AS created_at,\n 1 AS legacy_view\n FROM {$views_table} AS views\n LEFT JOIN {$visitors_table} AS visitors ON views.visitor_id = visitors.id;\n ");
28	// Add the indices after bulk insert
29	$wpdb->query("\n ALTER TABLE {$sessions_table}\n ADD INDEX(visitor_id),\n ADD INDEX(initial_view_id),\n ADD INDEX(referrer_id),\n ADD INDEX(campaign_id);\n ");
30	$wpdb->query("\n UPDATE\n {$views_table} AS views\n INNER JOIN {$sessions_table} AS sessions ON views.id = sessions.initial_view_id\n SET\n views.session_id = sessions.session_id;\n ");
31	$wpdb->query("\n ALTER TABLE {$views_table} DROP COLUMN referrer_id, DROP INDEX visitor_id, DROP COLUMN visitor_id, DROP COLUMN campaign_id, ADD INDEX (session_id);\n ");
32	$visitors_tmp_table = Query::get_table_name(Query::VISITORS_TMP);
33	$visitors_archive_table = Query::get_table_name(Query::VISITORS_1_16_ARCHIVE);
34	$wpdb->query("DROP TABLE IF EXISTS {$visitors_tmp_table};");
35	$wpdb->query("CREATE TABLE {$visitors_tmp_table} (\n visitor_id varchar(32),\n country_code varchar(256),\n city varchar(256),\n subdivision varchar(256),\n country varchar(256),\n continent varchar(256),\n PRIMARY KEY (visitor_id)\n ) {$charset_collate};");
36	$wpdb->query("INSERT INTO {$visitors_tmp_table} (visitor_id, country_code, city, subdivision, country, continent)\n SELECT\n LEFT(visitor_token, 32) AS visitor_token,\n country_code,\n city,\n subdivision,\n country,\n continent\n FROM\n {$visitors_table} AS visitors ON DUPLICATE KEY UPDATE country_code = visitors.country_code,\n city = visitors.city,\n subdivision = visitors.subdivision,\n country = visitors.country,\n continent = visitors.continent;\n ");
37	$wpdb->query("DROP TABLE IF EXISTS {$visitors_archive_table};");
38	$wpdb->query("RENAME TABLE {$visitors_table} TO {$visitors_archive_table};");
39	$wpdb->query("RENAME TABLE {$visitors_tmp_table} TO {$visitors_table};");
40	}
41	}
42