Query.php — Independent Analytics – WordPress Analytics Plugin 2.2.0

independent-analytics / IAWP / Query.php

independent-analytics / IAWP Last commit date

AJAX 2 years ago Admin_Page 2 years ago Date_Range 2 years ago Interval 2 years ago Menu_Bar_Stats 2 years ago Migrations 2 years ago Models 2 years ago Public_API 2 years ago Rows 2 years ago Statistics 2 years ago Tables 2 years ago Utils 2 years ago Campaign_Builder.php 2 years ago Capability_Manager.php 2 years ago Chart.php 2 years ago Chart_Geo.php 2 years ago Cron_Manager.php 2 years ago Current_Traffic_Finder.php 2 years ago Dashboard_Options.php 2 years ago Dashboard_Widget.php 2 years ago Database_Manager.php 2 years ago Email_Chart.php 2 years ago Email_Reports.php 2 years ago Empty_Report_Option.php 2 years ago Env.php 2 years ago Filters.php 2 years ago Geo_Database_Background_Job.php 2 years ago Geo_Database_Manager.php 2 years ago Geoposition.php 2 years ago Icon_Directory.php 2 years ago Icon_Directory_Factory.php 2 years ago Illuminate_Builder.php 2 years ago Independent_Analytics.php 2 years ago Interrupt.php 2 years ago Known_Referrers.php 2 years ago Plugin_Conflict_Detector.php 2 years ago Query.php 2 years ago Quick_Stats.php 2 years ago REST_API.php 2 years ago Real_Time.php 2 years ago Report.php 2 years ago Report_Finder.php 2 years ago Report_Options_Parser.php 2 years ago Resource_Identifier.php 2 years ago Settings.php 2 years ago Sort_Configuration.php 2 years ago Track_Resource_Changes.php 2 years ago View.php 2 years ago View_Counter.php 2 years ago Visitors_Over_Time_Finder.php 2 years ago WP_Option_Cache_Bust.php 2 years ago WooCommerce_Order.php 2 years ago WooCommerce_Referrer_Meta_Box.php 2 years ago

Query.php

164 lines

1	<?php
2
3	namespace IAWP_SCOPED\IAWP;
4
5	/** @internal */
6	class Query
7	{
8	public const CAMPAIGN_URLS = 'campaign_urls';
9	public const CAMPAIGNS = 'campaigns';
10	public const REFERRER_GROUPS = 'referrer_groups';
11	public const REFERRERS = 'referrers';
12	public const RESOURCES = 'resources';
13	public const VIEWS = 'views';
14	public const VISITORS = 'visitors';
15	public const VISITORS_TMP = 'visitors_tmp';
16	// Used in DB v7 migration
17	public const VISITORS_1_16_ARCHIVE = 'visitors_1_16_archive';
18	// Used in DB v7 migration
19	public const SESSIONS = 'sessions';
20	public const WC_ORDERS = 'wc_orders';
21	public const CITIES = 'cities';
22	public const COUNTRIES = 'countries';
23	public const DEVICES = 'devices';
24	public const DEVICE_TYPES = 'device_types';
25	public const DEVICE_OSS = 'device_oss';
26	public const DEVICE_BROWSERS = 'device_browsers';
27	public const REPORTS = 'reports';
28	private $query;
29	private $parameters;
30	private $pdo;
31	private $rows = [];
32	private $last_inserted_id = 0;
33	private $external_tables = ['wc_order_stats', 'comments'];
34	public function __construct(string $query_name, ?array $parameters = [])
35	{
36	$this->query = $this->get_query($query_name);
37	$this->parameters = $parameters;
38	}
39	public function last_inserted_id() : ?int
40	{
41	return $this->last_inserted_id;
42	}
43	public function rows() : array
44	{
45	return $this->rows;
46	}
47	public function row() : ?\stdClass
48	{
49	if (isset($this->rows[0])) {
50	return $this->rows[0];
51	} else {
52	return null;
53	}
54	}
55	public function run() : self
56	{
57	$this->open_connection();
58	$statement = $this->pdo->prepare($this->query);
59	foreach ($this->parameters as $key => $value) {
60	$statement->bindValue($key, $value);
61	}
62	$statement->execute();
63	$rows = $statement->fetchAll();
64	$this->rows = \array_map(function ($row) {
65	return (object) $row;
66	}, $rows);
67	$this->last_inserted_id = $this->pdo->lastInsertId();
68	$this->close_connection();
69	return $this;
70	}
71	/**
72	* Responsible for fetching the SQL from the correct query file. Query files are stored as text
73	* files with the txt extension to prevent being filtered out during backups and migrations by
74	* various hosts.
75	*
76	* @param string $query_name
77	*
78	* @return string
79	*/
80	private function get_query(string $query_name) : string
81	{
82	global $wpdb;
83	$wordpress_table_prefix = $wpdb->prefix;
84	$file_path = \IAWP_SCOPED\iawp_path_to("sql/{$query_name}.txt");
85	$file_contents = \file_get_contents($file_path);
86	$reflection = new \ReflectionClass(static::class);
87	$constants = $reflection->getConstants();
88	foreach ($constants as $table_partial) {
89	$hard_coded_table = 'wp_independent_analytics_' . $table_partial;
90	$actual_table = $wordpress_table_prefix . 'independent_analytics_' . $table_partial;
91	if ($actual_table !== $hard_coded_table) {
92	$file_contents = \str_replace($hard_coded_table, $actual_table, $file_contents);
93	}
94	}
95	foreach ($this->external_tables as $table_partial) {
96	$hard_coded_table = 'wp_' . $table_partial;
97	$actual_table = $wordpress_table_prefix . $table_partial;
98	if ($actual_table !== $hard_coded_table) {
99	$file_contents = \str_replace($hard_coded_table, $actual_table, $file_contents);
100	}
101	}
102	return $file_contents;
103	}
104	private function open_connection()
105	{
106	global $wpdb;
107	$raw_host = $wpdb->dbhost;
108	$name = $wpdb->dbname;
109	$charset = $wpdb->dbcharset ?? 'utf8';
110	$user = $wpdb->dbuser;
111	$password = $wpdb->dbpassword;
112	if ($host_data = $wpdb->parse_db_host($raw_host)) {
113	list($host, $port, $socket, $is_ipv6) = $host_data;
114	} else {
115	\error_log('IAWP: Parsing DB host failed. Host = ' . $raw_host);
116	return;
117	}
118	if ($is_ipv6 && \extension_loaded('mysqlnd')) {
119	$host = "[{$host}]";
120	}
121	$charset_collate = $wpdb->determine_charset($charset, '');
122	$charset = $charset_collate['charset'];
123	if (isset($socket)) {
124	$data_source_name = 'mysql:unix_socket=' . $socket . ';dbname=' . $name . ';charset=' . $charset;
125	} else {
126	$data_source_name = 'mysql:host=' . $host . ';dbname=' . $name . ';charset=' . $charset;
127	if (isset($port)) {
128	$data_source_name .= ';port=' . $port;
129	}
130	}
131	$this->pdo = new \PDO($data_source_name, $user, $password);
132	$this->pdo->query("SET SESSION group_concat_max_len = 20000;");
133	}
134	private function close_connection()
135	{
136	$this->pdo = null;
137	}
138	public static function query(string $query_name, ?array $parameters = []) : self
139	{
140	$db = new self($query_name, $parameters);
141	$db->run();
142	return $db;
143	}
144	/**
145	* Safe way to get the name of a table
146	*
147	* @param string $name
148	*
149	* @return string\|null
150	*/
151	public static function get_table_name(string $name) : ?string
152	{
153	global $wpdb;
154	$prefix = $wpdb->prefix;
155	$reflection = new \ReflectionClass(static::class);
156	$constants = $reflection->getConstants();
157	if (\in_array($name, $constants)) {
158	return $prefix . 'independent_analytics_' . $name;
159	} else {
160	return null;
161	}
162	}
163	}
164