<?php
|
namespace Framework;
|
|
use App\Database;
|
use PDO;
|
abstract class Model
|
{
|
protected array $errors = [];
|
protected ?string $table;
|
|
abstract protected function validate (array $data): void;
|
|
public function __construct(protected Database $database) {
|
}
|
|
public function update(string $id, array $data): bool {
|
$this->validate($data);
|
|
if(!empty($this->errors)) {
|
return false;
|
}
|
|
$sql = "UPDATE {$this->getTable()}";
|
|
unset($data["id"]);
|
|
$assignments = array_keys($data);
|
|
array_walk($assignments, function (&$value) {
|
$value = "$value = ?";
|
});
|
|
$sql .= " SET " . implode(", ", $assignments);
|
$sql .= " WHERE id = ?";
|
|
$conn = $this->database->getConnection();
|
$stmt = $conn->prepare($sql);
|
|
$i = 1;
|
foreach ($data as $value) {
|
$type = match(gettype($value)) {
|
"boolean" => PDO::PARAM_BOOL,
|
"integer"=> PDO::PARAM_INT,
|
"NULL"=> PDO::PARAM_NULL,
|
default => PDO::PARAM_STR
|
};
|
|
|
$stmt->bindValue($i++, $value, $type);
|
}
|
|
$stmt->bindValue($i, $id, PDO::PARAM_INT);
|
return $stmt->execute();
|
|
}
|
|
protected function addError(string $field, string $message): void {
|
$this->errors[$field] = $message;
|
}
|
|
public function getErrors(): array {
|
return $this->errors;
|
}
|
|
private function getTable() {
|
$parts = explode("\\", $this::class);
|
return strtolower(array_pop($parts));
|
}
|
public function getInsertID(): string {
|
$conn = $this->database->getConnection();
|
return $conn->lastInsertId();
|
}
|
public function findAll(): array|bool
|
{
|
$pdo = $this->database->getConnection();
|
|
$sql = "SELECT * FROM {$this->getTable()}";
|
|
$stmt = $pdo->query($sql);
|
|
return $stmt->fetchAll(PDO::FETCH_ASSOC);
|
}
|
|
public function find(string $id) {
|
$conn = $this->database->getConnection();
|
$sql = "SELECT *
|
FROM {$this->getTable()}
|
WHERE id = :id";
|
$stmt = $conn->prepare($sql);
|
$stmt->bindValue(":id", $id, PDO::PARAM_INT);
|
$stmt->execute();
|
return $stmt->fetch(PDO::FETCH_ASSOC);
|
}
|
|
public function insert(array $data) : bool {
|
$this->validate($data);
|
|
if(!empty($this->errors)) {
|
return false;
|
}
|
$columns = implode(", " , array_keys($data));
|
$placeholders = implode(", ", array_fill(0, count($data), "?"));
|
|
$sql = "INSERT INTO {$this->getTable()} ($columns) VALUES ($placeholders)";
|
|
$conn = $this->database->getConnection();
|
$stmt = $conn->prepare($sql);
|
|
$i = 1;
|
foreach ($data as $value) {
|
$type = match(gettype($value)) {
|
"boolean" => PDO::PARAM_BOOL,
|
"integer"=> PDO::PARAM_INT,
|
"NULL"=> PDO::PARAM_NULL,
|
default => PDO::PARAM_STR
|
};
|
|
|
$stmt->bindValue($i++, $value, $type);
|
}
|
|
|
return $stmt->execute();
|
}
|
|
public function delete(string $id): bool {
|
$sql = "DELETE FROM {$this->getTable()} WHERE id = :id";
|
|
$conn = $this->database->getConnection();
|
$stmt = $conn->prepare($sql);
|
$stmt->bindValue(":id", $id, PDO::PARAM_INT);
|
|
return $stmt->execute();
|
}
|
}
|
