query.php — Independent Analytics – WordPress Analytics Plugin 1.17

independent-analytics / IAWP / query.php

independent-analytics / IAWP Last commit date

Migrations 3 years ago ajax 3 years ago models 3 years ago queries 3 years ago sql 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 dashboard_options.php 3 years ago dashboard_widget.php 3 years ago email_reports.php 3 years ago filters.php 3 years ago freemius.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 real_time.php 3 years ago rest_api.php 3 years ago settings.php 3 years ago track_resource_changes.php 3 years ago view_counter.php 3 years ago

query.php

186 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 = path_to("IAWP/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
144	if ($is_ipv6 && extension_loaded('mysqlnd')) {
145	$host = "[$host]";
146	}
147
148	if (isset($socket)) {
149	$data_source_name = 'mysql:unix_socket=' . $socket . ';dbname=' . DB_NAME . ';charset=' . DB_CHARSET;
150	} else {
151	$data_source_name = 'mysql:host=' . $host . ';dbname=' . DB_NAME . ';charset=' . DB_CHARSET;
152
153	if (isset($port)) {
154	$data_source_name .= ';port=' . $port;
155	}
156	}
157
158	$this->pdo = new \PDO($data_source_name, DB_USER, DB_PASSWORD);
159	}
160
161	private function close_connection()
162	{
163	$this->pdo = null;
164	}
165
166	/**
167	* Safe way to get the name of a table
168	*
169	* @param string $name
170	* @return string\|null
171	*/
172	public static function get_table_name(string $name): ?string
173	{
174	global $wpdb;
175	$prefix = $wpdb->prefix;
176	$reflection = new \ReflectionClass(static::class);
177	$constants = $reflection->getConstants();
178
179	if (in_array($name, $constants)) {
180	return $prefix . 'independent_analytics_' . $name;
181	} else {
182	return null;
183	}
184	}
185	}
186