Dazzle\PgSQL\Statement\PrepareQuery

Complexity

Total Complexity

8

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	getName()	0	4	1
A	setName()	0	6	1
A	getPipe()	0	4	1
A	execute()	0	6	1
A	handle()	0	9	2
A	generateName()	0	9	1

<?php
namespace Dazzle\PgSQL\Statement;

use Dazzle\PgSQL\Connection\ConnectorInterface;
use Dazzle\Promise\Deferred;

class PrepareQuery extends Deferred implements Statement
{
    use StatementAwareTrait;
    
    protected $name;
    /**
     * @var ConnectorInterface
     */
    protected $pipeline;

    public function __construct($sql)
    {
        parent::__construct();
        $this->sql = $sql;
        $this->name = $this->generateName();
    }

    public function getName()
    {
        return $this->name;
    }

    public function setName($name)
    {
        $this->name = $name;

        return $this;
    }

    public function getPipe()
    {
        return $this->pipeline;
    }

    public function execute(ConnectorInterface $connector)
    {
        $this->pipeline = $connector;

        return \pg_send_prepare($connector->getStream(), $this->name, $this->getSQL());
    }

    /**
     * @overwrite
     * @param resource $result
     * @return mixed
     */
    public function handle($result)
    {
        $stat = pg_result_status($result, \PGSQL_STATUS_LONG);
        if ($stat != PGSQL_COMMAND_OK) {
            return new \Exception('error');
        }

        return new Prepared($this);
    }

    private function generateName($length = 6)
    {
        $id = md5(microtime());
        $size = strlen($id);
        $offset = mt_rand(0, $size - $length);
        $end = mt_rand($offset + $length, $size);

        return substr($id, $offset, $end);
    }
}