Agavi\Database\PdoDatabase::connect()

Complexity

Conditions	18
Paths	11125

Size

Total Lines	51
Code Lines	28

Duplication

Lines	10
Ratio	19.61 %

Importance

Changes

0

<?php
    protected function connect()
    {
        // determine how to get our parameters
        $method = $this->getParameter('method', 'dsn');

        // get parameters
        switch ($method) {
            case 'dsn':
                $dsn = $this->getParameter('dsn');
                if ($dsn == null) {
                    // missing required dsn parameter
                    $error = 'Database configuration specifies method "dsn", but is missing dsn parameter';
                    throw new DatabaseException($error);
                }
                break;
        }

        try {
            $username = $this->getParameter('username');
            $password = $this->getParameter('password');

            $options = array();

            if ($this->hasParameter('options')) {

This code seems to be duplicated across your project.

                foreach ((array)$this->getParameter('options') as $key => $value) {
                    $options[is_string($key) && strpos($key, '::') ? constant($key) : $key] = is_string($value) && strpos($value, '::') ? constant($value) : $value;
                }
            }

            $this->connection = $this->resource = new \PDO($dsn, $username, $password, $options);

The variable $dsn does not seem to be defined for all execution paths leading up to this point.

            // default connection attributes
            $attributes = array(
                // lets generate exceptions instead of silent failures
                \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION
            );
            if ($this->hasParameter('attributes')) {

This code seems to be duplicated across your project.

                foreach ((array)$this->getParameter('attributes') as $key => $value) {
                    $attributes[is_string($key) && strpos($key, '::') ? constant($key) : $key] = is_string($value) && strpos($value, '::') ? constant($value) : $value;
                }
            }
            foreach ($attributes as $key => $value) {
                $this->connection->setAttribute($key, $value);
            }
            foreach ((array)$this->getParameter('init_queries') as $query) {
                $this->connection->exec($query);
            }
        } catch (\PDOException $e) {
            throw new DatabaseException($e->getMessage(), 0, $e);
        }
    }