mirror of
https://github.com/ConnectedHumber/Air-Quality-Web
synced 2024-12-22 10:25:01 +00:00
66 lines
2.2 KiB
PHP
66 lines
2.2 KiB
PHP
<?php
|
|
|
|
namespace AirQuality\Repositories;
|
|
|
|
/**
|
|
* Fetches measurement readings from a MariaDB database.
|
|
*/
|
|
class MariaDBMeasurementDataRepository implements IMeasurementDataRepository {
|
|
public static $table_name_metadata = "readings";
|
|
public static $table_name_values = "reading_values";
|
|
|
|
public static $column_values_id = "id";
|
|
public static $column_values_reading_id = "reading_id";
|
|
public static $column_values_value = "value";
|
|
public static $column_values_reading_value_types_id = "reading_value_types_id";
|
|
|
|
public static $column_metadata_id = "id";
|
|
public static $column_metadata_storedon = "storedon";
|
|
public static $column_metadata_recordedon = "recordedon";
|
|
public static $column_metadata_device_id = "device_id";
|
|
public static $column_metadata_lat = "reading_latitude";
|
|
public static $column_metadata_long = "reading_longitude";
|
|
|
|
// ------------------------------------------------------------------------
|
|
|
|
/**
|
|
* The database connection.
|
|
* @var \AirQuality\Database
|
|
*/
|
|
private $database;
|
|
|
|
function __construct(\AirQuality\Database $in_database) {
|
|
$this->database = $in_database;
|
|
}
|
|
|
|
public function get_readings_by_date(\DateTime $datetime, string $reading_type) {
|
|
return $this->database->query(
|
|
"SELECT
|
|
$this->table_name_values.*,
|
|
$this->table_name_metadata.device_id,
|
|
COALESCE(
|
|
$this->table_name_metadata.$this->column_metadata_recordedon,
|
|
$this->table_name_metadata.$this->column_metadata_storedon
|
|
) AS datetime,
|
|
COALESCE(
|
|
$this->table_name_metadata.$this->column_metadata_lat,
|
|
{MariaDBDeviceRepository::$table_name}.device_latitude
|
|
) AS latitude,
|
|
COALESCE(
|
|
$this->table_name_metadata.$this->column_metadata_long,
|
|
devices.device_longitude
|
|
) AS longitude
|
|
FROM $this->table_name_values
|
|
JOIN $this->table_name_metadata ON $this->table_name_values.$this->column_values_reading_id = $this->table_name_metadata.id
|
|
JOIN devices ON $this->table_name_metadata.$this->column_metadata_device_id = devices.device_id
|
|
WHERE COALESCE(
|
|
$this->table_name_metadata.$this->column_metadata_recordedon,
|
|
$this->table_name_metadata.$this->column_metadata_storedon
|
|
) = :datetime",
|
|
[
|
|
"datetime" => $datetime,
|
|
"reading_type" => $reading_type
|
|
]
|
|
)->fetchAll();
|
|
}
|
|
}
|