Maketok\DataMigration\Storage\Db\AbstractDBALResource

Complexity

Total Complexity

13

Size/Duplication

Total Lines	114
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

67.44%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
	getDriver()	0	1	?
A	__construct()	0	5	1
A	open()	0	19	3
A	getDriverOptions()	0	4	1
A	close()	0	4	1
A	__destruct()	0	6	2
A	isActive()	0	4	1
A	startTransaction()	0	4	1
A	commit()	0	4	1
A	rollback()	0	4	1
A	getConnection()	0	4	1

<?php

namespace Maketok\DataMigration\Storage\Db;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Driver as DriverInterface;
use Maketok\DataMigration\Action\ConfigInterface;

abstract class AbstractDBALResource implements ResourceInterface
{
    /**
     * @var Connection
     */
    protected $connection;
    /**
     * @var ConfigInterface
     */
    protected $config;

    /**
     * @param ConfigInterface $config
     */
    public function __construct(ConfigInterface $config)
    {
        $this->config = $config;
        $this->open();
    }

    /**
     * {@inheritdoc}
     */
    public function open()
    {
        $params = [
            'dbname' => $this->config['db_name'],
            'user' => $this->config['db_user'],
            'password' => $this->config['db_password'],
            'host' => $this->config['db_host'],
            'port' => $this->config['db_port'],
        ];
        if (isset($this->config['db_pdo'])) {
            $params['pdo'] = $this->config['db_pdo'];
        }
        if (isset($this->config['db_url'])) {
            $params['url'] = $this->config['db_url'];
        }
        $params['driverOptions'] = $this->getDriverOptions();
        $this->connection = new Connection($params, $this->getDriver());
        return $this->connection->connect();
    }

    /**
     * @return array
     */
    protected function getDriverOptions()
    {
        return [];
    }

    /**
     * @return DriverInterface
     */
    abstract protected function getDriver();

    /**
     * {@inheritdoc}
     */
    public function close()
    {
        $this->connection->close();
    }

    /**
     * GC opened resource
     */
    public function __destruct()
    {
        if ($this->isActive()) {
            $this->close();
        }
    }

    /**
     * {@inheritdoc}
     */
    public function isActive()
    {
        return $this->connection->isConnected();
    }

    /**
     * {@inheritdoc}
     */
    public function startTransaction()
    {
        $this->connection->beginTransaction();
    }

    /**
     * {@inheritdoc}
     */
    public function commit()
    {
        $this->connection->commit();
    }

    /**
     * {@inheritdoc}
     */
    public function rollback()
    {
        $this->connection->rollBack();
    }

    /**
     * @return Connection
     */
    public function getConnection()
    {
        return $this->connection;
    }
}