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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
<?php
namespace Database;
use PDO;
use Exception;
include __DIR__ . '/../constants.php';
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 {
global $SERVER;
global $PORT;
global $USER;
global $PASSWORD;
global $DB_NAME;
global $MYSQL_UNIX_SOCKET;
$unix_socket = $MYSQL_UNIX_SOCKET;
$conn = null;
// Windows support
if ($unix_socket == '') {
$conn = new PDO(
"mysql:host=" . $SERVER . ";port=" . $PORT . ";dbname=" . $DB_NAME,
$USER,
$PASSWORD);
}
else {
$conn = new PDO(
"mysql:unix_socket=$unix_socket;dbname=" . $DB_NAME,
$USER,
$PASSWORD);
}
// set the PDO error mode to exception
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
return $conn;
}
}
|
