Lagdo\DbAdmin\Db\AppDriver

Complexity

Total Complexity

14

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	6	1
A	createDriver()	0	6	2
A	__construct()	0	13	1
A	callCallbacks()	0	4	2
A	multiQuery()	0	6	1
A	beforeConnection()	0	3	1
A	createConnection()	0	3	1
A	name()	0	3	1
A	addQueryCallback()	0	3	1
A	configConnection()	0	3	1
A	openedConnection()	0	3	1
A	result()	0	6	1

<?php

namespace Lagdo\DbAdmin\Db;

use Lagdo\DbAdmin\Driver\Driver;
use Lagdo\DbAdmin\Driver\DriverInterface;
use Closure;

use function Jaxon\jaxon;

/**
 * Add callbacks to the driver features.
 */
class AppDriver extends Driver
{
    /**
     * @var array
     */
    private array $callbacks = [];

    /**
     * @param Driver $driver
     */
    public function __construct(protected Driver $driver)
    {
        // "Clone" the driver instance.
        $this->utils = $driver->utils;
        $this->config = $driver->config;
        $this->mainConnection = $driver->mainConnection;
        $this->connection = $driver->connection;

        $this->server = $driver->server;
        $this->database = $driver->database;
        $this->table = $driver->table;
        $this->query = $driver->query;
        $this->grammar = $driver->grammar;
    }

    /**
     * @inheritDoc
     */
    public function name()
    {
        return $this->driver->name();
    }

    /**
     * @return void
     */
    protected function beforeConnection()
    {
        $this->driver->beforeConnection();
    }

    /**
     * @return void
     */
    protected function configConnection()
    {
        $this->driver->configConnection();
    }

    /**
     * @return void
     */
    protected function openedConnection()
    {
        $this->driver->openedConnection();
    }

    /**
     * @inheritDoc
     */
    public function createConnection(array $options)
    {
        return $this->driver->createConnection($options);
    }

    /**
     * @param string $query
     *
     * @return void
     */
    private function callCallbacks(string $query): void
    {
        foreach ($this->callbacks as $callback) {
            $callback($query);
        }
    }

    /**
     * @inheritDoc
     */
    public function addQueryCallback(Closure $callback): void
    {
        $this->callbacks[] = $callback;
    }

    /**
     * @inheritDoc
     */
    public function multiQuery(string $query)
    {
        $result = $this->driver->multiQuery($query);
        // Call the query callbacks.
        $this->callCallbacks($query);
        return $result;
    }

    /**
     * @inheritDoc
     */
    public function result(string $query, int $field = -1)
    {
        $result = $this->driver->result($query, $field);
        // Call the query callbacks.
        $this->callCallbacks($query);
        return $result;
    }

    /**
     * @inheritDoc
     */
    public function execute(string $query)
    {
        $result = $this->driver->execute($query);
        // Call the query callbacks.
        $this->callCallbacks($query);
        return $result;
    }

    /**
     * @param array $options
     *
     * @return DriverInterface|null
     */
    public static function createDriver(array $options): ?DriverInterface
    {
        $drivers = Driver::drivers();
        $driver = $options['driver'];
        $closure = $drivers[$driver] ?? null;
        return !$closure ? null : $closure(jaxon()->di(), $options);
    }
}