Query.php — Independent Analytics – WordPress Analytics Plugin 1.19.0

independent-analytics / IAWP / Query.php

independent-analytics / IAWP Last commit date

AJAX 3 years ago Migrations 3 years ago Models 3 years ago Queries 3 years ago Tables 3 years ago Utils 3 years ago Campaign_Builder.php 3 years ago Capability_Manager.php 3 years ago Chart.php 3 years ago Chart_Geo.php 3 years ago Chart_SVG.php 3 years ago Current_Resource.php 3 years ago Dashboard_Options.php 3 years ago Dashboard_Widget.php 3 years ago Email_Reports.php 3 years ago Filters.php 3 years ago Geo_Database.php 3 years ago Geo_Database_Download_Job.php 3 years ago Health_Check.php 3 years ago Independent_Analytics.php 3 years ago Known_Referrers.php 3 years ago PDF.php 3 years ago Query.php 3 years ago Quick_Stats.php 3 years ago REST_API.php 3 years ago Real_Time.php 3 years ago Settings.php 3 years ago Track_Resource_Changes.php 3 years ago View_Counter.php 3 years ago WP_Option_Cache_Bust.php 3 years ago

Query.php

197 lines

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