Jackal\Copycat\Reader\PDOMySQLReader

Complexity

Total Complexity

2

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	28	2

<?php

namespace Jackal\Copycat\Reader;

use PDO;
use Symfony\Component\OptionsResolver\OptionsResolver;

/**
 * Class PDOMySQLReader
 * @package Jackal\Copycat\Reader
 */
class PDOMySQLReader extends BaseReader
{
    /**
     * @var array
     */
    protected $options;

    /**
     * PDOMySQLReader constructor.
     * @param $query
     * @param array $options
     */
    public function __construct($query, array $options)
    {
        $resolver = new OptionsResolver();
        $resolver->setDefaults([
            'host' => 'localhost',
            'port' => 3306,
            'username' => null,
            'password' => null,
            'database_name' => null,
            'query' => $query,
            'driver_options' => [
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            ],
        ]);

        $this->options = $resolver->resolve($options);

        /** @noinspection SpellCheckingInspection */
        $dbh = $pdo = new PDO(

The assignment to $pdo is dead and can be removed.

            sprintf('mysql:host=%s;dbname=%s', $this->options['host'], $this->options['database_name']),
            $this->options['username'],
            $this->options['password'],
            $this->options['driver_options']
        );
        foreach ($dbh->query($query) as $row) {
            $this->addItem($row);
        }
        $dbh = null;

The assignment to $dbh is dead and can be removed.

    }
}