Kuperwood\Eav\Model\Model

Complexity

Total Complexity

13

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Test Coverage

Coverage

95.92%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	updateByArray()	0	21	3
A	count()	0	7	1
A	getTable()	0	3	1
A	getPrimaryKey()	0	3	1
A	insert()	0	18	2
A	db()	0	3	1
A	deleteByKey()	0	11	1
A	setPrimaryKey()	0	3	1
A	findByKey()	0	7	1
A	setTable()	0	3	1

<?php
/**
 * This file is part of the eav package.
 * @author    Alex Kuperwood <alexkuperwood@gmail.com>
 * @copyright 2025 Alex Kuperwood
 * @license   https://opensource.org/license/mit  The MIT License
 */
declare(strict_types=1);

namespace Kuperwood\Eav\Model;

use Kuperwood\Eav\Database\Connection;
use PDO;

class Model
{
    protected string $primaryKey = 'id';

    protected string $table;

    public function db() : PDO
    {
        return Connection::get();
    }

    public function setPrimaryKey(string $name): void
    {
        $this->primaryKey = $name;
    }

    public function getPrimaryKey(): string
    {
        return $this->primaryKey;
    }

    public function setTable(string $table): void
    {
        $this->table = $table;
    }

    public function getTable() : string
    {
        return $this->table;
    }

    public function insert(array $data): int
    {
        $conn = $this->db();
        $table = $this->getTable();

        // Extract the column names and values from the data array
        $columns = implode(', ', array_keys($data));
        $placeholders = ':' . implode(', :', array_keys($data));

        // Prepare the SQL statement
        $stmt = $conn->prepare("INSERT INTO $table ($columns) VALUES ($placeholders)");
        // Bind the values from the $data array to the prepared statement
        foreach ($data as $key => $value) {
            $stmt->bindValue(':' . $key, $value);
        }
        $stmt->execute();

        return (int) $conn->lastInsertId();
    }

    public function updateByArray(int $key, array $data) : bool
    {
        $keyName = $this->getPrimaryKey();

        $conn = $this->db();
        $table = $this->getTable();

        $setValues = [];
        foreach (array_keys($data) as $column) {
            $setValues[] = "$column = :$column";
        }
        $setValues = implode(", ", $setValues);

        $stmt = $conn->prepare("UPDATE $table SET $setValues WHERE $keyName = :key");

        foreach ($data as $k => $value) {
            $stmt->bindValue($k, $value);
        }

        $binds = array_merge($data, ['key' => $key]);
        return $stmt->execute($binds);
    }

    public function deleteByKey(int $key): bool
    {
        $keyName = $this->getPrimaryKey();

        $conn = $this->db();
        $table = $this->getTable();

        $stmt = $conn->prepare("DELETE FROM $table WHERE $keyName = :key");
        $stmt->bindValue(':key',  $key, PDO::PARAM_INT);

        return $stmt->execute();
    }

    public function count() : int
    {
        $table = $this->getTable();
        $stmt = $this->db()->prepare("SELECT COUNT(*) as count FROM $table");
        $stmt->execute();
        $record = $stmt->fetch(PDO::FETCH_ASSOC);
        return (int) $record["count"];
    }

    public function findByKey(int $key)
    {
        $conn = $this->db();
        $sql = sprintf("SELECT * FROM %s WHERE %s = ?", $this->getTable(), $this->getPrimaryKey());
        $stmt = $conn->prepare($sql);
        $stmt->execute([$key]);
        return $stmt->fetch(PDO::FETCH_ASSOC);
    }
}