Dazzle\MySQL\Protocol\Command

Complexity

Total Complexity

12

Size/Duplication

Total Lines	298
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	1

Test Coverage

Coverage

0%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getID()	0	4	1
A	getSQL()	0	4	1
A	buildPacket()	0	2	1
A	getState()	0	4	2
A	setState()	0	5	1
A	equals()	0	4	1
A	setError()	0	4	1
A	getError()	0	4	1
A	hasError()	0	4	1
A	getConnection()	0	4	1

<?php

namespace Dazzle\MySQL\Protocol;

use Dazzle\Event\BaseEventEmitter;
use Dazzle\MySQL\DatabaseInterface;
use Error;
use Exception;

abstract class Command extends BaseEventEmitter implements CommandInterface
{
    /**
     * Code of mysql internat thread state.
     *
     * @var int
     */
    const SLEEP = 0x00;

    /**
     * Code of mysql_close.
     *
     * @var int
     */
    const QUIT = 0x01;

    /**
     * Code of mysql_select_db.
     *
     * @var int
     */
    const INIT_DB = 0x02;

    /**
     * Code of mysql_real_query.
     *
     * @var int
     */
    const QUERY = 0x03;

    /**
     * Code of mysql_list_fields.
     *
     * @var int
     */
    const FIELD_LIST = 0x04;

    /**
     * Code of mysql_create_db (deprecated).
     *
     * @var int
     */
    const CREATE_DB = 0x05;

    /**
     * Code of mysql_drop_db (deprecated).
     *
     * @var int
     */
    const DROP_DB = 0x06;

    /**
     * Code of mysql_refresh.
     *
     * @var int
     */
    const REFRESH = 0x07;

    /**
     * Code of mysql_shutdown.
     *
     * @var int
     */
    const SHUTDOWN = 0x08;

    /**
     * Code of mysql_stat.
     *
     * @var int
     */
    const STATISTICS = 0x09;

    /**
     * Code of mysql_list_processes.
     *
     * @var int
     */
    const PROCESS_INFO = 0x0a;

    /**
     * Code representing internal thread state.
     *
     * @var int
     */
    const CONNECT = 0x0b;

    /**
     * Code of mysql_kill.
     *
     * @var int
     */
    const PROCESS_KILL = 0x0c;

    /**
     * Code of mysql_dump_debug_info.
     *
     * @var int
     */
    const DEBUG = 0x0d;

    /**
     * Code of mysql_ping.
     *
     * @var int
     */
    const PING = 0x0e;

    /**
     * Code representing internal thread state.
     *
     * @var int
     */
    const TIME = 0x0f;

    /**
     * Code representing internal thread state.
     *
     * @var int
     */
    const DELAYED_INSERT = 0x10;

    /**
     * Code of mysql_change_user.
     *
     * @var int
     */
    const CHANGE_USER = 0x11;

    /**
     * Code sent by the slave IO thread to request a binlog
     *
     * @var int
     */
    const BINLOG_DUMP = 0x12;

    /**
     * Code of "LOAD TABLE ... FROM MASTER" (deprecated).
     *
     * @var int
     */
    const TABLE_DUMP = 0x13;

    /**
     * Code representing internal thread state
     *
     * @var int
     */
    const CONNECT_OUT = 0x14;

    /**
     * Code sent by the slave to register with the master (optional).
     *
     * @var int
     */
    const REGISTER_SLAVE = 0x15;

    /**
     * Code of mysql_stmt_prepare.
     *
     * @var int
     */
    const STMT_PREPARE = 0x16;

    /**
     * Code of mysql_stmt_execute
     *
     * @var int
     */
    const STMT_EXECUTE = 0x17;

    /**
     * Code of mysql_stmt_send_long_data
     *
     * @var int
     */
    const STMT_SEND_LONG_DATA = 0x18;

    /**
     * Code of mysql_stmt_close
     *
     * @var int
     */
    const STMT_CLOSE = 0x19;

    /**
     * Code of mysql_stmt_reset
     *
     * @var int
     */
    const STMT_RESET = 0x1a;

    /**
     * Code of mysql_set_server_option
     *
     * @var int
     */
    const SET_OPTION = 0x1b;

    /**
     * Code of mysql_stmt_fetch
     *
     * @var int
     */
    const STMT_FETCH = 0x1c;

    /**
     * Authenticate after the connection is established.
     *
     * @var int
     */
    const INIT_AUTHENTICATE = 0xf1;

    /**
     * @var int
     */
    protected $id = -1;

    /**
     * @var DatabaseInterface
     */
    protected $database;

    /**
     * @var mixed[]
     */
    protected $states;

    /**
     * @var Error|Exception
     */
    protected $error;

    /**
     * @var mixed
     */
    protected $context;

    /**
     * @param DatabaseInterface $database
     * @param mixed|null $context
     */
    public function __construct(DatabaseInterface $database, $context = null)
    {
        $this->database = $database;
        $this->states = [];
        $this->error = null;
        $this->context = $context;
    }

    public function getID()
    {
        return $this->id;
    }

    public function getSQL()
    {
        return '';
    }

    public function buildPacket()
    {}

    public function getState($name, $default = null)
    {
        return isset($this->states[$name]) ? $this->states[$name] : $default;
    }

    public function setState($name, $value)
    {
        $this->states[$name] = $value;
        return $this;
    }

    public function equals($commandId)
    {
        return $this->id === $commandId;
    }

    public function setError($error)
    {
        $this->error = $error;
    }

    public function getError()
    {
        return $this->error;
    }

    public function hasError()
    {
        return $this->error !== null;
    }

    public function getConnection()
    {
        return $this->database;
    }
}