Hhxsv5\LaravelS\Illuminate\Database\CoroutineMySQL

Complexity

Total Complexity

10

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	rowCount()	0	3	1
A	commit()	0	3	1
A	connect()	0	3	1
A	rollBack()	0	3	1
A	prepare()	0	7	2
A	lastInsertId()	0	3	1
A	__construct()	0	3	1
A	beginTransaction()	0	3	1
A	query()	0	3	1

<?php

namespace Hhxsv5\LaravelS\Illuminate\Database;

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

class CoroutineMySQL
{
    protected $coMySQL;

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

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

    public function prepare($sql)
    {
        $oldStatement = $this->coMySQL->prepare($sql);
        if ($oldStatement === false) {

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

            throw new QueryException($sql, [], new \Exception($this->coMySQL->error, $this->coMySQL->errno));
        }
        return new CoroutineMySQLStatement($oldStatement);
    }

    public function beginTransaction()
    {
        return $this->coMySQL->begin();

Are you sure the usage of $this->coMySQL->begin() targeting Swoole\Coroutine\Mysql::begin() seems to always return null.

    }

    public function commit()
    {
        return $this->coMySQL->commit();

Are you sure the usage of $this->coMySQL->commit() targeting Swoole\Coroutine\Mysql::commit() seems to always return null.

    }

    public function rollBack()
    {
        return $this->coMySQL->rollback();

Are you sure the usage of $this->coMySQL->rollback() targeting Swoole\Coroutine\Mysql::rollback() seems to always return null.

    }

    public function query($sql, $timeout = 0.0)
    {
        return $this->coMySQL->query($sql, $timeout);
    }

    public function lastInsertId()
    {
        return $this->coMySQL->insert_id;
    }

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