Hhxsv5\LaravelS\Illuminate\Database\SwoolePDO

Complexity

Total Complexity

19

Size/Duplication

Total Lines	101
Duplicated Lines	0 %

Importance

Changes

0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	setAttribute()	0	4	1
A	prepare()	0	7	2
A	query()	0	3	1
A	errorInfo()	0	6	1
A	getAvailableDrivers()	0	3	1
A	rollBack()	0	4	1
A	getAttribute()	0	3	2
A	exec()	0	3	1
A	errorCode()	0	3	1
A	connect()	0	3	1
A	lastInsertId()	0	3	1
A	quote()	0	4	1
A	__construct()	0	3	1
A	rowCount()	0	3	1
A	beginTransaction()	0	4	1
A	inTransaction()	0	3	1
A	commit()	0	4	1

<?php

namespace Hhxsv5\LaravelS\Illuminate\Database;

use Illuminate\Database\QueryException;
use Swoole\Coroutine\MySQL as SwooleMySQL;

class SwoolePDO extends \PDO
{
    protected $sm;
    protected $isInTransaction = false;

    public function __construct()
    {
        $this->sm = new SwooleMySQL();
    }

    public function connect(array $serverInfo)
    {
        $this->sm->connect($serverInfo);
    }

    public function prepare($statement, $options = null)
    {
        $oldStatement = $this->sm->prepare($statement);
        if ($oldStatement === false) {

The condition $oldStatement === false is always false.

            throw new QueryException($statement, [], new \Exception($this->sm->error, $this->sm->errno));
        }
        return new SwoolePDOStatement($oldStatement);
    }

    public function beginTransaction()
    {
        $this->isInTransaction = true;
        $this->sm->begin();
    }

    public function commit()
    {
        $this->sm->commit();
        $this->isInTransaction = false;
    }

    public function rollBack()
    {
        $this->sm->rollback();
        $this->isInTransaction = false;
    }

    public function query($statement, $mode = \PDO::ATTR_DEFAULT_FETCH_MODE, $arg3 = null, array $ctorargs = [])
    {
        return $this->sm->query($statement, array_get($ctorargs, 'timeout', 0.0));
    }

    public function exec($statement)
    {
        return $this->sm->query($statement);
    }

    public function lastInsertId($name = null)
    {
        return $this->sm->insert_id;
    }

    public function rowCount()
    {
        return $this->sm->affected_rows;
    }

    public function quote($string, $parameter_type = \PDO::PARAM_STR)
    {
        //TODO
        return $string;
    }

    public function errorCode()
    {
        return $this->sm->errno;
    }

    public function errorInfo()
    {
        return [
            $this->sm->errno,
            $this->sm->errno,
            $this->sm->error,
        ];
    }

    public function inTransaction()
    {
        return $this->isInTransaction;
    }

    public function getAttribute($attribute)
    {
        return isset($this->sm->serverInfo[$attribute]) ? $this->sm->serverInfo[$attribute] : null;
    }

    public function setAttribute($attribute, $value)
    {
        // TODO
        return false;
    }

    public static function getAvailableDrivers()
    {
        return ['mysql'];
    }
}