Drobotik\Eav\Model\Model

Complexity

Total Complexity

12

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

10 Methods

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

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

namespace Drobotik\Eav\Model;

use Drobotik\Eav\Database\Connection;
use Doctrine\DBAL\Connection as DBALConnection;
use PDO;

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

    protected string $table;

    public function db() : DBALConnection
    {
        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()->getNativeConnection();
        $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()->getNativeConnection();
        $table = $this->getTable();

        // Prepare the update statement
        $columns = array_keys($data);
        $setValues = implode(' = ?, ', $columns) . ' = ?';

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

        // Bind the data parameters
        $index = 1;
        foreach ($data as $value) {
            $stmt->bindValue($index, $value);
            $index++;
        }

        // Bind the ID parameter
        $stmt->bindValue(':key',  $key, PDO::PARAM_INT);
        return $stmt->execute();
    }

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

        $conn = $this->db()->getNativeConnection();
        $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
    {
        $conn = $this->db()->getNativeConnection();
        $table = $this->getTable();
        $stmt = $conn->prepare("SELECT COUNT(*) as count FROM $table");
        $stmt->execute();
        $record = $stmt->fetch(PDO::FETCH_ASSOC);
        return (int) $record["count"];
    }

    public function findByKey(int $key) : array|false
    {
        return $this->db()
            ->createQueryBuilder()
            ->select('*')
            ->from($this->getTable())
            ->where(sprintf('%s = ?', $this->getPrimaryKey()))
            ->setParameter(0, $key, PDO::PARAM_INT)
            ->executeQuery()
            ->fetchAssociative();
    }
}