1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
<?php
namespace Database;
use PDO;
use Exception;
abstract class Table {
// Cannot be created, because FETCH_CLASS will assign to all attributes
// and then call the constructor
final private function __construct() {}
static protected function _fromDB(string $query_str, string $class) : object {
$conn = Table::connect();
$query = $conn->query($query_str);
// TODO: research if this is enough to close the connection, $query may store a reference
$conn = null;
if ($query->rowCount() == 0) {
throw new Exception("Value for $class doesn't exist!");
}
assert($query->rowCount() == 1, "Value for $class must be uniqely specified!");
$query->setFetchMode(PDO::FETCH_CLASS, $class);
return $query->fetch();
}
static protected function _create(string $table, string $columns, string $value) : int {
$conn = Table::connect();
$query = $conn->query("INSERT INTO $table $columns VALUES $value");
// NOTE: If we ever insert more than one values, lastInsertId will returne the first id
$id = $conn->lastInsertId();
$conn = null;
return $id;
}
static protected function _delete(string $table, string $condition) {
$conn = Table::connect();
$query = $conn->query("DELETE FROM $table WHERE $condition");
$conn = null;
}
static protected function _get_entries_count(string $table) : int {
$conn = Table::connect();
$query = $conn->query("SELECT count(*) FROM $table");
$conn = null;
return $query->fetchColumn();
}
static protected function _update(string $table, string $sets, string $identify) {
$conn = Table::connect();
$query = $conn->query("UPDATE $table SET $sets WHERE $identify");
$conn = null;
}
static protected function _get_all(string $table, string $class, string $additional = null, $columns = "*") : array {
$conn = Table::connect();
$query = $conn->query("SELECT $columns FROM $table " . $additional);
$conn = null;
$query->setFetchMode(PDO::FETCH_CLASS, $class);
return $query->fetchAll();
}
static protected function connect() : PDO {
$conn = new PDO(
"mysql:unix_socket=" . getenv('MYSQL_UNIX_SOCKET') . ";dbname=nwfh",
getenv('USER'),
"");
// set the PDO error mode to exception
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
return $conn;
}
}
|
