Soluble\DbWrapper\Adapter\MysqliAdapter

Complexity

Total Complexity

9

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

86.96%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	quoteValue()	0	4	1
B	query()	0	25	6
A	getConnection()	0	4	1

<?php

namespace Soluble\DbWrapper\Adapter;

use Soluble\DbWrapper\Exception;
use mysqli;
use Soluble\DbWrapper\Result\Resultset;
use Soluble\DbWrapper\Connection\MysqliConnection;

class MysqliAdapter implements AdapterInterface
{
    /**
     * @var \mysqli
     */
    protected $resource;

    /**
     * @var MysqliConnection
     */
    protected $connection;

    /**
     * Constructor.
     *
     * @param mysqli $resource
     */
    public function __construct(mysqli $resource)
    {
        $this->resource = $resource;
        $this->connection = new MysqliConnection($this, $resource);
    }

    /**
     * {@inheritdoc}
     */
    public function quoteValue($value)
    {
        return "'" . $this->resource->real_escape_string($value) . "'";
    }

    /**
     * {@inheritdoc}
     */
    public function query($query, $resultsetType = Resultset::TYPE_ARRAY)
    {
        try {
            //$r = $this->resource->query($query, MYSQLI_STORE_RESULT);
            $r = $this->resource->query($query, MYSQLI_STORE_RESULT);

            $results = new Resultset($resultsetType);

            if ($r === false) {
                throw new Exception\InvalidArgumentException("Query cannot be executed [$query].");
            } elseif ($r instanceof \mysqli_result) {
                while ($row = $r->fetch_assoc()) {
                    $results->append($row);
                }
                $r->close();
            }
        } catch (Exception\InvalidArgumentException $e) {
            throw $e;
        } catch (\Exception $e) {
            $msg = "MysqliException: {$e->getMessage()} [$query]";
            throw new Exception\InvalidArgumentException($msg);
        }

        return $results;
    }

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