mirror of
https://github.com/ConnectedHumber/Air-Quality-Web
synced 2024-12-22 10:25:01 +00:00
Implement new ISensorRepository.
This is thanks to @BNNorman's recent DB changes :D
This commit is contained in:
parent
dc0ddcdb87
commit
a325940322
2 changed files with 109 additions and 0 deletions
22
logic/Repositories/ISensorRepository.php
Normal file
22
logic/Repositories/ISensorRepository.php
Normal file
|
@ -0,0 +1,22 @@
|
|||
<?php
|
||||
|
||||
namespace AirQuality\Repositories;
|
||||
|
||||
/**
|
||||
* Defines the interface of repositories that fetch information about sensors.
|
||||
*/
|
||||
interface ISensorRepository {
|
||||
/**
|
||||
* Returns an array of all the different types of sensor that devices can
|
||||
* have.
|
||||
* @return array An array of sensors.
|
||||
*/
|
||||
public function get_all_sensors();
|
||||
|
||||
/**
|
||||
* Returns a list of sensors that a given device posesses.
|
||||
* @param int $device_id The id of the device to return a list of sensors for.
|
||||
* @return array An array of sensors that the device with the given id has.
|
||||
*/
|
||||
public function get_device_sensors(int $device_id) : array;
|
||||
}
|
87
logic/Repositories/MariaDBSensorRepository.php
Normal file
87
logic/Repositories/MariaDBSensorRepository.php
Normal file
|
@ -0,0 +1,87 @@
|
|||
<?php
|
||||
|
||||
namespace AirQuality\Repositories;
|
||||
|
||||
use Location\Coordinate;
|
||||
use Location\Distance\Vincenty;
|
||||
|
||||
|
||||
/**
|
||||
* Fetches device info from a MariaDB database.
|
||||
*/
|
||||
class MariaDBDeviceRepository implements ISensorRepository {
|
||||
public static $table_name = "sensors";
|
||||
public static $col_id = "id";
|
||||
public static $col_type = "Type";
|
||||
public static $col_descriptioon = "Description";
|
||||
|
||||
public static $table_name_assoc = "device_sensors";
|
||||
public static $col_assoc_device_id = "device_id";
|
||||
public static $col_assoc_sensor_id = "sensors_id";
|
||||
|
||||
|
||||
// ------------------------------------------------------------------------
|
||||
|
||||
/**
|
||||
* The database connection.
|
||||
* @var \AirQuality\Database
|
||||
*/
|
||||
private $database;
|
||||
|
||||
/**
|
||||
* Function that gets a static variable by it's name. Useful in preparing SQL queries.
|
||||
* @var callable
|
||||
*/
|
||||
private $get_static;
|
||||
/**
|
||||
* Function that gets a static variable by it's name & class. Useful in preparing SQL queries.
|
||||
* @var callable
|
||||
*/
|
||||
private $get_static_extra;
|
||||
|
||||
/**
|
||||
* Creates a new ISensorRepository implementation that's designed for
|
||||
* talking to MariaDB databases.
|
||||
* @param \AirQuality\Database $in_database The database connection instance to use to talk to the database.
|
||||
*/
|
||||
function __construct(\AirQuality\Database $in_database) {
|
||||
$this->database = $in_database;
|
||||
|
||||
$this->get_static = function($name) { return self::$$name; };
|
||||
$this->get_static_extra = function($class_name, $name) {
|
||||
return $class_name::$$name;
|
||||
};
|
||||
}
|
||||
|
||||
|
||||
public function get_all_sensors() {
|
||||
$s = $this->get_static;
|
||||
|
||||
return $this->database->query(
|
||||
"SELECT
|
||||
{$s("table_name")}.{$s("col_id")} AS id,
|
||||
{$s("table_name")}.{$s("col_type")} AS type,
|
||||
{$s("table_name")}.{$s("col_description")} AS description,
|
||||
FROM {$s("table_name")};", [
|
||||
|
||||
]
|
||||
)->fetchAll();
|
||||
}
|
||||
|
||||
public function get_device_sensors(int $device_id) : array {
|
||||
$s = $this->get_static;
|
||||
|
||||
return $this->database->query(
|
||||
"SELECT
|
||||
{$s("table_name")}.{$s("col_id")} AS id,
|
||||
{$s("table_name")}.{$s("col_type")} AS type,
|
||||
{$s("table_name")}.{$s("col_description")} AS description,
|
||||
FROM {$s("table_name")}
|
||||
JOIN {$s("table_name_assoc")} ON
|
||||
{$s("table_name_assoc")}.{$s("col_assoc_sensor_id")}
|
||||
WHERE {$s("table_name_assoc")}.{$s("col_assoc_device_id")} = :device_id;", [
|
||||
"device_id" => $device_id
|
||||
]
|
||||
)->fetchAll();
|
||||
}
|
||||
}
|
Loading…
Reference in a new issue