<?php

namespace Blog\Model;

use PDOException;
use PDO;

class NewsModel extends Database {

    public function getNewsById($id) {
        $pdo = $this->linkDB();
        $sql = "SELECT * FROM news WHERE news_id = :news_id;";
        $stmt = $pdo->prepare($sql);
        $params = [':news_id' => $id];
        $stmt->execute($params);
        return $stmt->fetch(PDO::FETCH_ASSOC);
    }

    public function updateNews($id, $data) {
        $pdo = $this->linkDB();
        $sql = "UPDATE news SET name = :name, description = :description, date = :date WHERE news_id = :news_id;";
        $stmt = $pdo->prepare($sql);
        $params = [
            ':name' => $data['name'],
            ':description' => $data['description'],
            ':date' => $data['date'],
            ':news_id' => $id
        ];
        return $stmt->execute($params);
    }

    public function getNews() {
        $pdo = $this->linkDB();
        $sql = "SELECT * FROM news ORDER BY date DESC;";
        $stmt = $pdo->prepare($sql);
        $stmt->execute();
        return $stmt->fetchAll(PDO::FETCH_ASSOC);
    }

    public function createNews($data) {
        $pdo = $this->linkDB();
        $sql = "INSERT INTO news (name, description, date) VALUES (:name, :description, :date);";
        $stmt = $pdo->prepare($sql);
        $params = [
            ':name' => $data['name'],
            ':description' => $data['description'],
            ':date' => $data['date']
        ];
        $stmt->execute($params);
        return $pdo->lastInsertId();
    }

    public function deleteNews($id) {
        $pdo = $this->linkDB();
        $sql = "DELETE FROM news WHERE news_id = :news_id;";
        $stmt = $pdo->prepare($sql);
        $params = [':news_id' => $id];
        return $stmt->execute($params);
    }
}