Drobotik\Eav\Model\ValueBase

Complexity

Total Complexity

12

Size/Duplication

Total Lines	132
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	destroy()	0	11	1
B	bulkCreate()	0	53	7
A	__construct()	0	3	1
A	update()	0	17	1
A	find()	0	16	1
A	create()	0	18	1

<?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 Drobotik\Eav\Enum\_VALUE;
use Drobotik\Eav\Enum\ATTR_TYPE;
use Drobotik\Eav\Import\Content\ValueSet;
use Drobotik\Eav\Trait\SingletonsTrait;

class ValueBase extends Model
{

    use SingletonsTrait;
    public function __construct()
    {
        $this->setPrimaryKey(_VALUE::ID->column());
    }

    public function find(string $table, int $domainKey, int $entityKey, int $attributeKey) : bool|array
    {
        return $this->db()
            ->createQueryBuilder()
            ->select('*')
            ->from($table)
            ->where(sprintf('%s = :domain AND %s = :entity AND %s = :attr',
                _VALUE::DOMAIN_ID->column(), _VALUE::ENTITY_ID->column(), _VALUE::ATTRIBUTE_ID->column()
            ))
            ->setParameters([
                "domain" => $domainKey,
                "entity" => $entityKey,
                "attr" => $attributeKey
            ])
            ->executeQuery()
            ->fetchAssociative();
    }

    public function create(string $table, int $domainKey, int $entityKey, int $attributeKey, $value) : int
    {
        $conn = $this->db();

        $conn->createQueryBuilder()
            ->insert($table)
            ->values([
                _VALUE::DOMAIN_ID->column() => '?',
                _VALUE::ENTITY_ID->column() => '?',
                _VALUE::ATTRIBUTE_ID->column() => '?',
                _VALUE::VALUE->column() => '?',
            ])
            ->setParameter(0, $domainKey)
            ->setParameter(1, $entityKey)
            ->setParameter(2, $attributeKey)
            ->setParameter(3, $value)
            ->executeQuery();
        return (int) $conn->lastInsertId();
    }

    public function update(string $table, int $domainKey, int $entityKey, int $attributeKey, $value) : int
    {
        $conn = $this->db();
        return $conn->createQueryBuilder()
            ->update($table)
            ->where(sprintf('%s = :domain AND %s = :entity AND %s = :attr',
                _VALUE::DOMAIN_ID->column(), _VALUE::ENTITY_ID->column(), _VALUE::ATTRIBUTE_ID->column()
            ))
            ->set(_VALUE::VALUE->column(), ':value')
            ->setParameters([
                "domain" => $domainKey,
                "entity" => $entityKey,
                "attr" => $attributeKey,
                "value" => $value
            ])
            ->executeQuery()
            ->rowCount();
    }

    public function destroy(string $table, int $domainKey, int $entityKey, int $attributeKey) : int
    {
        return $this->db()
            ->createQueryBuilder()
            ->delete($table)
            ->where(sprintf('%s = ? AND %s = ? AND %s = ?',
                _VALUE::DOMAIN_ID->column(), _VALUE::ENTITY_ID->column(), _VALUE::ATTRIBUTE_ID->column()
            ))
            ->setParameters([$domainKey, $entityKey, $attributeKey])
            ->executeQuery()
            ->rowCount();
    }

    public function bulkCreate(ValueSet $valueSet, int $domainKey): void
    {
        $pdo = Connection::get()->getNativeConnection();

        $template = "INSERT INTO %s ("._VALUE::DOMAIN_ID->column().","._VALUE::ENTITY_ID->column().","._VALUE::ATTRIBUTE_ID->column().","._VALUE::VALUE->column().")";

        $stringTable = ATTR_TYPE::STRING->valueTable();
        $integerTable = ATTR_TYPE::INTEGER->valueTable();
        $decimalTable = ATTR_TYPE::DECIMAL->valueTable();
        $datetimeTable = ATTR_TYPE::DATETIME->valueTable();
        $textTable = ATTR_TYPE::TEXT->valueTable();

        $stringTemplate = sprintf($template, $stringTable) . " VALUES %s;";
        $integerTemplate = sprintf($template, $integerTable) . " VALUES %s;";
        $decimalTemplate = sprintf($template, $decimalTable) . " VALUES %s;";
        $datetimeTemplate = sprintf($template, $datetimeTable) . " VALUES %s;";
        $textTemplate = sprintf($template, $textTable) . " VALUES %s;";

        $stringBulk = [];
        $integerBulk = [];
        $decimalBulk = [];
        $datetimeBulk = [];
        $textBulk = [];

        foreach ($valueSet->forExistingEntities() as $data) {
            $attributeKey = $data->getAttributeKey();
            $value = $data->getValue();
            $table = $data->getType()->valueTable();
            $entityKey = $data->getEntityKey();
            $bulkTemplate = "($domainKey, $entityKey, $attributeKey, '$value')";
            match($table) {
                $stringTable => $stringBulk[] = $bulkTemplate,
                $integerTable => $integerBulk[] = $bulkTemplate,
                $decimalTable => $decimalBulk[] = $bulkTemplate,
                $datetimeTable=> $datetimeBulk[] = $bulkTemplate,
                $textTable    => $textBulk[] = $bulkTemplate
            };
        }

        if(count($stringBulk) > 0) {
            $pdo->exec(sprintf($stringTemplate, implode(',', $stringBulk)));
        }
        if(count($integerBulk) > 0) {
            $pdo->exec(sprintf($integerTemplate, implode(',', $integerBulk)));
        }
        if(count($decimalBulk) > 0) {
            $pdo->exec(sprintf($decimalTemplate, implode(',', $decimalBulk)));
        }
        if(count($datetimeBulk) > 0) {
            $pdo->exec(sprintf($datetimeTemplate, implode(',', $datetimeBulk)));
        }
        if(count($textBulk) > 0) {
            $pdo->exec(sprintf($textTemplate, implode(',', $textBulk)));
        }
    }

}