SimpleConnection::toDatabase() - Code Metrics - Inspection of "closes #2 Remove duplicate log on SimpleConnection..." - b2pweb/bdf-prime - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Push — master ( 58d054...1c36bc )

by Vincent
created 2020-05-27 14:22 UTC
SimpleConnection::toDatabase() A

↳ Parent: SimpleConnection
Complexity

Conditions	1
Paths	1
Size

Total Lines	3
Code Lines	1
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	2
CRAP Score	1
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
eloc	1
dl	0
loc	3
c	1
b	0
f	0
ccs	2
cts	2
cp	1
rs	10
cc	1
nc	1
nop	2
crap	1
<?php

namespace Bdf\Prime\Connection;

use Bdf\Prime\Connection\Event\ConnectionClosedListenerInterface;
use Bdf\Prime\Connection\Extensions\LostConnection;
use Bdf\Prime\Connection\Extensions\SchemaChanged;
use Bdf\Prime\Connection\Result\PdoResultSet;
use Bdf\Prime\Connection\Result\ResultSetInterface;

use Bdf\Prime\Connection\Result\UpdateResultSet;
use Bdf\Prime\Platform\Sql\SqlPlatform;
use Bdf\Prime\Query\Compiler\Preprocessor\PreprocessorInterface;
use Bdf\Prime\Query\Compiler\SqlCompiler;
use Bdf\Prime\Query\Contract\Compilable;
use Bdf\Prime\Query\Contract\Query\InsertQueryInterface;
use Bdf\Prime\Query\Contract\Query\KeyValueQueryInterface;
use Bdf\Prime\Query\Custom\BulkInsert\BulkInsertQuery;
use Bdf\Prime\Query\Custom\BulkInsert\BulkInsertSqlCompiler;
use Bdf\Prime\Query\Custom\KeyValue\KeyValueQuery;
use Bdf\Prime\Query\Custom\KeyValue\KeyValueSqlCompiler;
use Bdf\Prime\Query\Factory\DefaultQueryFactory;
use Bdf\Prime\Query\Factory\QueryFactoryInterface;

use Bdf\Prime\Query\Query;
use Bdf\Prime\Schema\SchemaManager;
use Doctrine\Common\EventManager;
use Doctrine\DBAL\Cache\QueryCacheProfile;
use Doctrine\DBAL\Configuration;
use Doctrine\DBAL\Connection as BaseConnection;
use Doctrine\DBAL\DBALException;
use Doctrine\DBAL\Driver;
use Doctrine\DBAL\Statement;
use PDO;

/**
 * Connection
 *
 * @package Bdf\Prime

 */
class SimpleConnection extends BaseConnection implements ConnectionInterface
{
    use LostConnection;
    use SchemaChanged;

    /**
     * The connection name.
     *
     * @var string
     */
    protected $name;
    
    /**
     * The schema manager.
     *
     * @var SchemaManager
     */
    private $schema;

    /**
     * @var SqlPlatform
     */
    private $platform;

    /**
     * @var QueryFactoryInterface
     */
    private $factory;

    /**
     * SimpleConnection constructor.
     *
     * @param array $params

     * @param Driver $driver

     * @param Configuration|null $config

     * @param EventManager|null $eventManager

     * @throws DBALException

     */
    public function __construct(array $params, Driver $driver, Configuration $config = null, EventManager $eventManager = null)
    {
        parent::__construct($params, $driver, $config, $eventManager);

        $this->factory = new DefaultQueryFactory(
            $this,
            new SqlCompiler($this),
            [
                KeyValueQuery::class   => KeyValueSqlCompiler::class,
                BulkInsertQuery::class => BulkInsertSqlCompiler::class,
            ],
            [
                KeyValueQueryInterface::class => KeyValueQuery::class,
                InsertQueryInterface::class   => BulkInsertQuery::class,
            ]
        );
    }

    /**

     * {@inheritdoc}
     */
    public function setName($name)
    {
        $this->name = $name;
        
        return $this;
    }

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

    /**
     * {@inheritdoc}
     */
    public function isConnected()
    {
        return $this->_conn !== null;
    }

    /**
     * {@inheritdoc}
     */
    public function schema()
    {
        if ($this->schema === null) {
            $this->schema = new SchemaManager($this);
        }

        return $this->schema;
    }

    /**
     * {@inheritdoc}
     */
    public function platform()
    {
        if ($this->platform === null) {
            $this->platform = new SqlPlatform(
                $this->getDatabasePlatform(),
                $this->getConfiguration()->getTypes()
                $this->getConfiguration()->/** @scrutinizer ignore-call */ getTypes()
            );
        }

        return $this->platform;
    }

    /**

     * {@inheritdoc}
     */
    public function fromDatabase($value, $type, array $fieldOptions = [])
    {
        return $this->platform()->types()->fromDatabase($value, $type, $fieldOptions);
        return $this->platform()->types()->/** @scrutinizer ignore-call */ fromDatabase($value, $type, $fieldOptions);
    }

    /**

     * {@inheritdoc}
     */
    public function toDatabase($value, $type = null)
    {
        return $this->platform()->types()->toDatabase($value, $type);
        return $this->platform()->types()->/** @scrutinizer ignore-call */ toDatabase($value, $type);
    }

    /**

     * {@inheritdoc}
     */
    public function builder(PreprocessorInterface $preprocessor = null)
    {
        return $this->factory->make(Query::class, $preprocessor);
    }

    /**

     * {@inheritdoc}
     */
    public function make($query, PreprocessorInterface $preprocessor = null)
    {
        return $this->factory->make($query, $preprocessor);
    }

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

    /**

     * {@inheritdoc}
     */
    public function from($table)
    {
        return $this->builder()->from($table);
    }

    /**

     * {@inheritdoc}
     */
    public function delete($table, array $identifier, array $types = array())

    {
        return $this->from($table)->where($identifier)->delete();
        return $this->from($table)->/** @scrutinizer ignore-call */ where($identifier)->delete();
    }
    
    /**

     * {@inheritdoc}
     */
    public function update($table, array $data, array $identifier, array $types = array())

    {
        return $this->from($table)->where($identifier)->update($data, $types);
    }

    /**

     * {@inheritdoc}
     */
    public function insert($table, array $data, array $types = array())

    {
        return $this->from($table)->insert($data, $types);
        return $this->from($table)->/** @scrutinizer ignore-call */ insert($data, $types);
    }

    /**
     * Executes select query and returns array of object
     * 
     * @param string $query
     * @param array  $bindings
     * @param array  $types
     * 
     * @return array
     */
    public function select($query, array $bindings = [], array $types = [])
    {
        $stmt = $this->executeQuery($query, $bindings, $types);
        $stmt->setFetchMode(PDO::FETCH_OBJ);

        $result = $stmt->fetchAll();

        $stmt->closeCursor();
        
        return $result;
    }

    /**

     * {@inheritdoc}
     */
    public function executeQuery($query, array $params = [], $types = [], QueryCacheProfile $qcp = null)
    {
        $this->prepareLogger();

        return $this->runOrReconnect(function() use ($query, $params, $types, $qcp) {

            return parent::executeQuery($query, $params, $types, $qcp);
        });
    }

    /**

     * {@inheritdoc}
     */
    public function executeUpdate($query, array $params = [], array $types = [])
    {
        $this->prepareLogger();

        return $this->runOrReconnect(function() use ($query, $params, $types) {

            return parent::executeUpdate($query, $params, $types);
        });
    }

    /**
     * {@inheritdoc}
     */
    public function query()
    {
        $this->prepareLogger();
        
        $args = func_get_args();

        return $this->runOrReconnect(function() use ($args) {

            return parent::query(...$args);
        });
    }
    
    /**

     * {@inheritdoc}
     */
    public function exec($statement)
    {
        $this->prepareLogger();
        
        return $this->runOrReconnect(function() use ($statement) {

            return parent::exec($statement);
        });
    }

    /**

     * {@inheritdoc}
     */
    public function prepare($statement)
    {
        return $this->runOrReconnect(function() use ($statement) {

            return parent::prepare($statement);
        });
    }

    /**

     * {@inheritdoc}
     */
    public function execute(Compilable $query)
    {
        $statement = $query->compile();

        if ($statement instanceof Statement) {
            return $this->executePrepared($statement, $query);
        }

        // $statement is a SQL query
        if ($query->type() === Compilable::TYPE_SELECT) {
            $stmt = $this->executeQuery($statement, $query->getBindings());

            return new PdoResultSet($stmt);
        }

        return new UpdateResultSet($this->executeUpdate($statement, $query->getBindings()));
    }

    /**
     * Execute a prepared statement
     *
     * @param Statement $statement
     * @param Compilable $query
     *
     * @return ResultSetInterface The query result
     * @throws DBALException

     */
    protected function executePrepared(Statement $statement, Compilable $query)
    {
        $bindings = $query->getBindings();

        $this->prepareLogger();

        try {
            $statement->execute($bindings);
        } catch (DBALException $exception) {
            // Prepared query on SQLite for PHP < 7.2 invalidates the query when schema change
            // This process may be removed on PHP 7.2
            if ($this->causedBySchemaChange($exception)) {
                $statement = $query->compile(true);
                $statement->execute($query->getBindings());
            } elseif ($this->causedByLostConnection($exception->getPrevious())) { // If the connection is lost, the query must be recompiled

                $this->close();
                $this->connect();

                $statement = $query->compile(true);
                $statement->execute($query->getBindings());
            } else {
                throw $exception;
            }
        }

        return new PdoResultSet($statement);
    }

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

        parent::beginTransaction();
    }

    /**
     * {@inheritdoc}
     */
    public function commit()
    {
        $this->prepareLogger();
        
        parent::commit();
    }
    
    /**
     * {@inheritdoc}
     */
    public function rollBack()
    {
        $this->prepareLogger();
        
        return parent::rollBack();
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
    }

    /**
     * {@inheritdoc}
     */
    public function close()
    {
        parent::close();

        $this->_eventManager->dispatchEvent(ConnectionClosedListenerInterface::EVENT_NAME);
    }
    
    /**
     * Log a query
     * 
     * @param string $query

     * @param int    $seconds

     * @param array  $bindings

     * @param array  $types

     */
    protected function prepareLogger()
    {
        $logger = $this->getConfiguration()->getSQLLogger();

        if ($logger && $logger instanceof ConnectionAwareInterface) {
            $logger->setConnection($this);
        }
    }

    /**
     * Execute a query. Try to reconnect if needed
     *
     * @param \Closure $callback
     *
     * @return mixed  The query result
     *
     * @throws DBALException

     */
    protected function runOrReconnect($callback)

    {
        try {
            return $callback();
        } catch (DBALException $exception) {
            if ($this->causedByLostConnection($exception->getPrevious())) {
                // Should check for active transaction.
                // Only reconnect the start transaction.
                // Should raise exception during transaction.
                $this->close();
                $this->connect();

                return $callback();
            }

            throw $exception;
        }
    }
}

b2pweb / bdf-prime

Push — master ( 58d054...1c36bc )

SimpleConnection::toDatabase() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like
