StefanoTree\NestedSet\Adapter\Zend2

Complexity

Total Complexity

13

Size/Duplication

Total Lines	104
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

98.15%

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getConnection()	0	4	1
A	getOptions()	0	4	1
A	beginTransaction()	0	7	1
A	commitTransaction()	0	7	1
A	rollbackTransaction()	0	7	1
A	isInTransaction()	0	7	1
A	canHandleNestedTransaction()	0	4	1
A	quoteIdentifier()	0	6	1
A	executeSQL()	0	5	1
A	executeSelectSQL()	0	6	1
A	executeInsertSQL()	0	15	2

<?php

declare(strict_types=1);

namespace StefanoTree\NestedSet\Adapter;

use StefanoTree\NestedSet\Options;
use Zend\Db\Adapter\Adapter as DbAdapter;

class Zend2 implements AdapterInterface
{
    private $connection;
    private $options;

    /**
     * @param Options   $options
     * @param DbAdapter $connection
     */
    public function __construct(Options $options, DbAdapter $connection)
    {
        $this->connection = $connection;
        $this->options = $options;
    }

    /**
     * @return DbAdapter
     */
    private function getConnection(): DbAdapter
    {
        return $this->connection;
    }

    /**
     * @return Options
     */
    public function getOptions(): Options
    {
        return $this->options;
    }

    public function beginTransaction(): void
    {
        $this->getConnection()
             ->getDriver()
             ->getConnection()
             ->beginTransaction();
    }

    public function commitTransaction(): void
    {
        $this->getConnection()
             ->getDriver()
             ->getConnection()
             ->commit();
    }

    public function rollbackTransaction(): void
    {
        $this->getConnection()
             ->getDriver()
             ->getConnection()
             ->rollback();
    }

    public function isInTransaction(): bool
    {
        return $this->getConnection()
             ->getDriver()
             ->getConnection()
             ->inTransaction();
    }

    public function canHandleNestedTransaction(): bool
    {
        return true;
    }

    public function quoteIdentifier(string $columnName): string
    {
        return $this->getConnection()
                    ->getPlatform()
                    ->quoteIdentifierChain(explode('.', $columnName));
    }

    public function executeInsertSQL(string $sql, array $params = array())
    {
        $options = $this->getOptions();
        $this->executeSQL($sql, $params);

        if (array_key_exists($options->getIdColumnName(), $params)) {
            return $params[$options->getIdColumnName()];
        } else {
            $lastGeneratedValue = $this->getConnection()
                                       ->getDriver()
                                       ->getLastGeneratedValue($options->getSequenceName());

The call to DriverInterface::getLastGeneratedValue() has too many arguments starting with $options->getSequenceName().

            return $lastGeneratedValue;
        }
    }

    public function executeSQL(string $sql, array $params = array()): void
    {
        $this->getConnection()
             ->query($sql, $params);
    }

    public function executeSelectSQL(string $sql, array $params = array()): array
    {
        return $this->getConnection()
                    ->query($sql, $params)
                    ->toArray();
    }
}