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, "Vaue 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 _get_all(string $table, string $class, string $additional = null) : array { $conn = Table::connect(); $query = $conn->query("SELECT * 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; } }