DH\Auditor\Provider\Doctrine\Auditing\Logger\Middleware\DHConnection

Complexity

Total Complexity

11

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	query()	0	3	1
A	beginTransaction()	0	3	1
A	__construct()	0	4	1
A	prepare()	0	3	1
A	commit()	0	9	2
A	exec()	0	3	1
A	quote()	0	3	1
A	getNativeConnection()	0	3	1
A	lastInsertId()	0	3	1
A	rollBack()	0	5	1

<?php

declare(strict_types=1);

namespace DH\Auditor\Provider\Doctrine\Auditing\Logger\Middleware;

use Doctrine\DBAL\Driver\Connection as ConnectionInterface;
use Doctrine\DBAL\Driver\Result;
use Doctrine\DBAL\Driver\Statement;
use Doctrine\DBAL\ParameterType;

/**
 * @interal
 */
final class DHConnection implements ConnectionInterface
{
    private ConnectionInterface $connection;
    private DHDriver $DHDriver;

    public function __construct(ConnectionInterface $connection, DHDriver $DHDriver)
    {
        $this->connection = $connection;
        $this->DHDriver = $DHDriver;
    }

    public function prepare(string $sql): Statement
    {
        return $this->connection->prepare($sql);
    }

    public function query(string $sql): Result
    {
        return $this->connection->query($sql);
    }

    public function quote($value, $type = ParameterType::STRING)
    {
        return $this->connection->quote($value, $type);
    }

    public function exec(string $sql): int
    {
        return $this->connection->exec($sql);
    }

    public function lastInsertId($name = null)
    {
        return $this->connection->lastInsertId($name);
    }

    public function beginTransaction(): bool
    {
        return $this->connection->beginTransaction();
    }

    public function commit(): bool
    {
        $flusherList = $this->DHDriver->getFlusherList();
        foreach ($flusherList as $flusher) {
            ($flusher)();
        }
        $this->DHDriver->resetDHFlusherList();

        return $this->connection->commit();
    }

    public function rollBack(): bool
    {
        $this->DHDriver->resetDHFlusherList();

        return $this->connection->rollBack();
    }

    /**
     * @return object|resource
     */
    public function getNativeConnection()
    {
        return $this->connection->getNativeConnection();

The method getNativeConnection() does not exist on Doctrine\DBAL\Driver\Connection. It seems like you code against a sub-type of said class. However, the method does not exist in Doctrine\DBAL\Driver\ServerInfoAwareConnection. Are you sure you never get one of those?

    }
}