EdmondsCommerce\DoctrineStaticMeta\Entity\Testing\Fixtures\QueryCachingLogger

Complexity

Total Complexity

14

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
B	run()	0	23	7
A	stopQuery()	0	3	1
A	runQuery()	0	20	5
A	startQuery()	0	3	1

<?php declare(strict_types=1);

namespace EdmondsCommerce\DoctrineStaticMeta\Entity\Testing\Fixtures;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Driver\Statement;
use Doctrine\DBAL\Logging\SQLLogger;
use EdmondsCommerce\DoctrineStaticMeta\Exception\DoctrineStaticMetaException;

/**
 * This class is caches queries so that they can be run as quickly as possible on subsequent builds
 *
 * @see \EdmondsCommerce\DoctrineStaticMeta\Entity\Testing\Fixtures\FixturesHelper::createDb
 */
class QueryCachingLogger implements SQLLogger
{
    private $queries = [];

    public function startQuery($sql, array $params = null, array $types = null)
    {
        $this->queries[$sql][] = [$params, $types];
    }

    public function stopQuery()
    {
        return;
    }

    public function run(Connection $connection): void
    {
        foreach ($this->queries as $query => $paramsArray) {
            if ('"START TRANSACTION"' === $query) {
                $connection->beginTransaction();
                continue;
            }
            if ('"COMMIT"' === $query) {
                $connection->commit();
                continue;
            }
            if ($connection->getDatabasePlatform()->getDummySelectSQL() === $query) {
                //this is a ping query
                unset($this->queries[$query]);
                continue;
            }
            if ([[[], []]] === $paramsArray) {
                $connection->prepare($query)->execute();
                continue;
            }
            $stmt = $connection->prepare($query);
            foreach ($paramsArray as $paramsTypes) {
                $this->runQuery($paramsTypes, $stmt, $connection, $query);
            }
        }
    }

    private function runQuery(array $paramsTypes, Statement $stmt, Connection $connection, string $query): void
    {
        try {
            list($params, $types) = $paramsTypes;
            if ($params !== null) {
                $colNum = 1;
                foreach ($params as $key => $value) {
                    $stmt->bindValue($colNum++, $value, $types[$key]);
                }
            }
            $stmt->execute();
        } catch (\Exception $e) {
            if ($connection->isTransactionActive()) {
                $connection->rollBack();
            }
            throw new DoctrineStaticMetaException(
                'Failed running logged query ' . $query . 'with params and types: '
                . print_r($paramsTypes, true),
                $e->getCode(),
                $e
            );
        }
    }
}