Mattbit\MysqlCompat\BridgeComponents\ExecuteQueries

Complexity

Total Complexity

15

Size/Duplication

Total Lines	99
Duplicated Lines	18.18 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	affectedRows()	0	6	1
A	query()	0	12	2
A	selectDb()	0	6	1
A	createDb()	9	9	1
A	listTables()	9	9	1
A	insertId()	0	6	1
A	listDbs()	0	4	1
A	dbName()	0	4	1
A	dbQuery()	0	7	1
A	dropDb()	0	4	1
A	listFields()	0	4	1
A	listProcesses()	0	4	1
A	tablename()	0	4	1
A	unbufferedQuery()	0	4	1

<?php

namespace Mattbit\MysqlCompat\BridgeComponents;

use Mattbit\MysqlCompat\Connection;
use Mattbit\MysqlCompat\Exception\QueryException;

trait ExecuteQueries
{
    public function affectedRows(Connection $linkIdentifier = null)
    {
        $connection = $this->manager->getOpenConnectionOrFail($linkIdentifier);

        return $connection->getRowCount();
    }

    public function query($query, Connection $linkIdentifier = null)
    {
        $connection = $this->manager->getOpenConnectionOrFail($linkIdentifier);

        try {
            $result = $connection->query($query);
        } catch (QueryException $e) {
            return false;
        }

        return $result;
    }

    public function selectDb($databaseName, Connection $linkIdentifier = null)
    {
        $connection = $this->manager->getOpenConnectionOrFail($linkIdentifier);

        return (bool) $connection->useDatabase($databaseName);
    }

    public function createDb($databaseName, Connection $linkIdentifier = null)

This method seems to be duplicated in your project.

    {
        $connection = $this->manager->getOpenConnectionOrFail($linkIdentifier);

        return $connection->parametrizedQuery(
            'CREATE DATABASE :databaseName',
            [':databaseName' => $databaseName]
        );
    }

    public function listTables($database, Connection $linkIdentifier = null)

This method seems to be duplicated in your project.

    {
        $connection = $this->manager->getOpenConnectionOrFail($linkIdentifier);

        return $connection->parametrizedQuery(
            'SHOW TABLES FROM :database',
            [':database' => $database]
        );
    }

    public function insertId(Connection $linkIdentifier = null)
    {
        $connection = $this->manager->getOpenConnectionOrFail($linkIdentifier);

        return (int) $connection->getLastInsertId();
    }

    public function listDbs()
    {
        // @todo
    }

    public function dbName()
    {
        // @todo
    }

    public function dbQuery($database, $query, Connection $linkIdentifier = null)
    {
        $connection = $this->manager->getOpenConnectionOrFail($linkIdentifier);
        $connection->useDatabase($database);

        return $connection->query($query);
    }

    public function dropDb()
    {
        // @todo
    }

    public function listFields()
    {
        // @todo
    }

    public function listProcesses()
    {
        // @todo
    }

    public function tablename()
    {
        // @todo
    }

    public function unbufferedQuery()
    {
        // @todo
    }
}