Foolz\SphinxQL\Drivers\Mysqli\Connection

Complexity

Total Complexity

17

Size/Duplication

Total Lines	165
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	escape()	0	11	2
A	query()	0	23	2
A	close()	0	6	1
A	connect()	0	25	4
A	mbPop()	0	9	2
A	ping()	0	5	1
A	multiQuery()	0	18	3
A	getInternalEncoding()	0	3	1
A	mbPush()	0	6	1

<?php

namespace Foolz\SphinxQL\Drivers\Mysqli;

use Foolz\SphinxQL\Drivers\ConnectionBase;
use Foolz\SphinxQL\Drivers\MultiResultSet;
use Foolz\SphinxQL\Drivers\ResultSet;
use Foolz\SphinxQL\Exception\ConnectionException;
use Foolz\SphinxQL\Exception\DatabaseException;
use Foolz\SphinxQL\Exception\SphinxQLException;

/**
 * SphinxQL connection class utilizing the MySQLi extension.
 * It also contains escaping and quoting functions.
 */
class Connection extends ConnectionBase
{
    /**
     * Internal Encoding
     *
     * @var string
     */
    protected $internal_encoding;

    /**
     * Returns the internal encoding.
     *
     * @return string current multibyte internal encoding
     */
    public function getInternalEncoding()
    {
        return $this->internal_encoding;
    }

    /**
     * @inheritdoc
     */
    public function connect()
    {
        $data = $this->getParams();
        $conn = mysqli_init();

        if (!empty($data['options'])) {
            foreach ($data['options'] as $option => $value) {
                $conn->options($option, $value);
            }
        }

        set_error_handler(function () {});
        try {
            if (!$conn->real_connect($data['host'], null, null, null, (int) $data['port'], $data['socket'])) {
                throw new ConnectionException('Connection Error: ['.$conn->connect_errno.']'.$conn->connect_error);
            }
        } finally {
            restore_error_handler();
        }

        $conn->set_charset('utf8');
        $this->connection = $conn;
        $this->mbPush();

        return true;
    }

    /**
     * Pings the Sphinx server.
     *
     * @return bool True if connected, false otherwise
     * @throws ConnectionException
     */
    public function ping()
    {
        $this->ensureConnection();

        return $this->getConnection()->ping();

The method ping() does not exist on PDO.

    }

    /**
     * @inheritdoc
     */
    public function close()
    {
        $this->mbPop();
        $this->getConnection()->close();

The method close() does not exist on PDO.

        return parent::close();
    }

    /**
     * @inheritdoc
     */
    public function query($query)
    {
        $this->ensureConnection();

        set_error_handler(function () {});
        try {
            /**
             * ManticoreSearch/Sphinx silence warnings thrown by php mysqli/mysqlnd
             *
             * unknown command (code=9) - status() command not implemented by Sphinx/ManticoreSearch
             * ERROR mysqli::prepare(): (08S01/1047): unknown command (code=22) - prepare() not implemented by Sphinx/Manticore
             */
            $resource = @$this->getConnection()->query($query);
        } finally {
            restore_error_handler();
        }        

        if ($this->getConnection()->error) {

The property error does not seem to exist on PDO.

            throw new DatabaseException('['.$this->getConnection()->errno.'] '.

The property errno does not seem to exist on PDO.

                $this->getConnection()->error.' [ '.$query.']');
        }

        return new ResultSet(new ResultSetAdapter($this, $resource));
    }

    /**
     * @inheritdoc
     */
    public function multiQuery(array $queue)
    {
        $count = count($queue);

        if ($count === 0) {
            throw new SphinxQLException('The Queue is empty.');
        }

        $this->ensureConnection();

        $this->getConnection()->multi_query(implode(';', $queue));

The method multi_query() does not exist on PDO.

        if ($this->getConnection()->error) {

The property error does not seem to exist on PDO.

            throw new DatabaseException('['.$this->getConnection()->errno.'] '.

The property errno does not seem to exist on PDO.

                $this->getConnection()->error.' [ '.implode(';', $queue).']');
        }

        return new MultiResultSet(new MultiResultSetAdapter($this));
    }

    /**
     * Escapes the input with \MySQLi::real_escape_string.
     * Based on FuelPHP's escaping function.
     * @inheritdoc
     */
    public function escape($value)
    {
        $this->ensureConnection();

        if (($value = $this->getConnection()->real_escape_string((string) $value)) === false) {

The method real_escape_string() does not exist on PDO.

            // @codeCoverageIgnoreStart
            throw new DatabaseException($this->getConnection()->error, $this->getConnection()->errno);

The property error does not seem to exist on PDO.

The property errno does not seem to exist on PDO.

            // @codeCoverageIgnoreEnd
        }

        return "'".$value."'";
    }

    /**
     * Enter UTF-8 multi-byte workaround mode.
     */
    public function mbPush()
    {
        $this->internal_encoding = mb_internal_encoding();

It seems like mb_internal_encoding() can also be of type true. However, the property $internal_encoding is declared as type string. Maybe add an additional type check?

        mb_internal_encoding('UTF-8');

        return $this;
    }

    /**
     * Exit UTF-8 multi-byte workaround mode.
     */
    public function mbPop()
    {
        // TODO: add test case for #155
        if ($this->getInternalEncoding()) {
            mb_internal_encoding($this->getInternalEncoding());
            $this->internal_encoding = null;
        }

        return $this;
    }
}