Query.php — Independent Analytics – WordPress Analytics Plugin 1.29.0

independent-analytics / IAWP / Query.php

independent-analytics / IAWP Last commit date

AJAX 2 years ago Date_Range 2 years ago Interval 3 years ago Menu_Bar_Stats 3 years ago Migrations 2 years ago Models 2 years ago Queries 2 years ago Statistics 2 years ago Tables 2 years ago Utils 2 years ago Campaign_Builder.php 3 years ago Capability_Manager.php 3 years ago Chart.php 3 years ago Chart_Geo.php 2 years ago Chart_SVG.php 3 years ago City_To_Country_Converter.php 3 years ago Dashboard_Options.php 3 years ago Dashboard_Widget.php 3 years ago Email_Chart.php 3 years ago Email_Reports.php 2 years ago Filters.php 3 years ago Geo_Database_Background_Job.php 3 years ago Geo_Database_Downloader.php 2 years ago Geoposition.php 2 years ago Health_Check.php 3 years ago Icon_Directory.php 2 years ago Icon_Directory_Factory.php 2 years ago Illuminate_Builder.php 3 years ago Independent_Analytics.php 2 years ago Interrupt.php 2 years ago Known_Referrers.php 3 years ago Query.php 2 years ago Quick_Stats.php 3 years ago REST_API.php 2 years ago Real_Time.php 2 years ago Reset_Database.php 3 years ago Resource_Identifier.php 3 years ago Settings.php 2 years ago Sort_Configuration.php 3 years ago Track_Resource_Changes.php 3 years ago View.php 2 years ago View_Counter.php 2 years ago WP_Option_Cache_Bust.php 3 years ago WooCommerce_Order.php 3 years ago

Query.php

167 lines

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