WebHemi\Adapter\Data\PDO\SQLiteAdapter

Complexity

Total Complexity

11

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	20	3
A	saveData()	0	4	2
B	insertData()	0	26	3
B	updateData()	0	24	3

<?php
/**
 * WebHemi.
 *
 * PHP version 7.1
 *
 * @copyright 2012 - 2017 Gixx-web (http://www.gixx-web.com)
 * @license   https://opensource.org/licenses/MIT The MIT License (MIT)
 *
 * @link      http://www.gixx-web.com
 */
declare(strict_types=1);

namespace WebHemi\Adapter\Data\PDO;

use InvalidArgumentException;
use RuntimeException;
use WebHemi\Adapter\Data\DataDriverInterface;

/**
 * Class SQLiteAdapter.
 *
 * @codeCoverageIgnore - Used by unit test only.
 */
class SQLiteAdapter extends MySQLAdapter
{
    /**
     * SQLiteAdapter constructor.
     *
     * @param DataDriverInterface $dataDriver
     * @throws InvalidArgumentException
     */
    public function __construct(DataDriverInterface $dataDriver)
    {
        if (!$dataDriver instanceof SQLiteDriver) {
            $type = gettype($dataDriver);

            if ($type == 'object') {
                $type = get_class($dataDriver);
            }

            $message = sprintf(
                'Can\'t create %s instance. The parameter must be an instance of SQLiteDriver, %s given.',
                __CLASS__,
                $type
            );

            throw new InvalidArgumentException($message, 1001);
        }

        $this->dataDriver = $dataDriver;
    }

    /**
     * Insert or update entity in the storage.
     *
     * @param int $identifier
     * @param array $data
     * @throws RuntimeException
     * @return int The ID of the saved entity in the storage
     */
    public function saveData(?int $identifier = null, array $data) : int
    {
        return empty($identifier) ? $this->insertData($data) : $this->updateData($identifier, $data);
    }

    /**
     * Insert data.
     *
     * @param array $data
     * @return int
     */
    protected function insertData(array $data) : int
    {
        $query = "INSERT INTO {$this->dataGroup}";

        $queryColumns = [];
        $queryData = [];
        $queryBind = [];

        foreach ($data as $fieldName => $value) {
            $queryColumns[] = $fieldName;
            $queryData[] = "?";
            $queryBind[] = $value;
        }

        $query .= ' ('.implode(', ', $queryColumns).') VALUES ('.implode(', ', $queryData).')';

        $statement = $this->dataDriver->prepare($query);

        if (!$statement) {
            throw new RuntimeException('Query error', 1002);
        }
        $this->bindValuesToStatement($statement, $queryBind);
        $statement->execute();

        return (int)$this->dataDriver->lastInsertId();
    }

    /**
     * Update data.
     *
     * @param int $identifier
     * @param array $data
     * @return int
     */
    protected function updateData(int $identifier, array $data) : int
    {
        $query = "UPDATE {$this->dataGroup}";

        $queryData = [];
        $queryBind = [];

        foreach ($data as $fieldName => $value) {
            $queryData[] = "{$fieldName} = ?";
            $queryBind[] = $value;
        }

        $query .= ' SET '.implode(', ', $queryData)." WHERE {$this->idKey} = ?";
        $queryBind[] = $identifier;
        $statement = $this->dataDriver->prepare($query);

        if (!$statement) {
            throw new RuntimeException('Query error', 1003);
        }
        $this->bindValuesToStatement($statement, $queryBind);
        $statement->execute();

        return $identifier;
    }
}