MySQL::rollback() - Code Metrics - Inspection of "Improve Db tests and code coverage" - Pleets/dronephp - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — master ( 87e63f...d6a1bd )

by Darío
created 2019-05-14 03:20 UTC
MySQL::rollback() A

↳ Parent: MySQL
Complexity

Conditions	1
Paths	1
Size

Total Lines	3
Code Lines	1
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	2
CRAP Score	1
Importance

Changes
Metric	Value
cc	1
eloc	1
nc	1
nop	0
dl	0
loc	3
ccs	2
cts	2
cp	1
crap	1
rs	10
c	0
b	0
f	0
<?php
/**
 * DronePHP (http://www.dronephp.com)
 *
 * @link      http://github.com/Pleets/DronePHP
 * @copyright Copyright (c) 2016-2018 Pleets. (http://www.pleets.org)
 * @license   http://www.dronephp.com/license
 * @author    Darío Rivera <[email protected]>
 */

namespace Drone\Db\Driver;

/**
 * MySQL class
 *
 * This is a database driver class to connect to MySQL
 */
class MySQL extends AbstractDriver implements DriverInterface
{
    /**
     * {@inheritDoc}
     *
     * @var object
     */
    protected $dbconn;

    /**
     * {@inheritDoc}
     *
     * @param array $options
     */
    public function __construct($options)
    {
        $this->driverName = 'Mysqli';

        if (!array_key_exists("dbchar", $options))
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            $options["dbchar"] = "utf8";

        parent::__construct($options);

        $auto_connect = array_key_exists('auto_connect', $options) ? $options["auto_connect"] : true;

        if ($auto_connect)
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            $this->connect();
    }

    /**
     * Connects to database
     *
     * @throws RuntimeException
     * @throws Exception\ConnectionException
     *
     * @return \mysqli
     */
    public function connect()
    {
        if (!extension_loaded('mysqli'))
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            throw new \RuntimeException("The Mysqli extension is not loaded");

        if (!is_null($this->dbport) && !empty($this->dbport))
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            $conn = @new \mysqli($this->dbhost, $this->dbuser, $this->dbpass, $this->dbname, $this->dbport);
        else
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            $conn = @new \mysqli($this->dbhost, $this->dbuser, $this->dbpass, $this->dbname);

        if ($conn->connect_errno)
        {
            /*
             * Use ever mysqli_connect_errno() and mysqli_connect_error()
             * over $this->dbconn->errno and $this->dbconn->error to prevent
             * the warning message "Property access is not allowed yet".
             */
            throw new Exception\ConnectionException(mysqli_connect_error(), mysqli_connect_errno());
        }
        else

        {
            $this->dbconn = $conn;
            $this->dbconn->set_charset($this->dbchar);
        }

        return $this->dbconn;
    }

    /**
     * Excecutes a statement
     *
     * @param string $sql
     * @param array $params
     *
     * @throws RuntimeException
     * @throws Exception\InvalidQueryException
     *
     * @return \mysqli_result
     */
    public function execute($sql, Array $params = [])

    {
        $this->numRows = 0;
        $this->numFields = 0;
        $this->rowsAffected = 0;

        $this->arrayResult = null;

        # Bound variables
        if (count($params))
        {
            $this->result = $stmt = @$this->dbconn->prepare($sql);

            if (!$stmt)
            {
                $this->error($this->dbconn->errno, $this->dbconn->error);
                       error($this->dbconn->errno, $this->dbconn->error);
                throw new Exception\InvalidQueryException($this->dbconn->error, $this->dbconn->errno);
            }

            $param_values = array_values($params);

            $n_params = count($param_values);
            $bind_values = [];
            $bind_types = "";

            for ($i = 0; $i < $n_params; $i++)
            {
                if (is_string($param_values[$i]))
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
                    $bind_types .= 's';
                else if(is_float($param_values[$i]))
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
                    $bind_types .= 'd';
                # [POSSIBLE BUG] - To Future revision (What about non-string and non-decimal types ?)
                else
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
                    $bind_types .= 's';

                $bind_values[] = '$param_values[' . $i . ']';
            }

            $values = implode(', ', $bind_values);
            eval('$stmt->bind_param(\'' . $bind_types . '\', ' . $values . ');');


            $r = $stmt->execute();
        }
        else

        {
            $prev_error_handler = set_error_handler(['\Drone\Error\ErrorHandler', 'errorControlOperator'], E_ALL);

            // may be throw a Fatal error (Ex: Maximum execution time)
            $r = $this->result = $this->dbconn->query($sql);

            set_error_handler($prev_error_handler);
        }

        if (!$r)
        {
            $this->error($this->dbconn->errno, $this->dbconn->error);
            throw new Exception\InvalidQueryException($this->dbconn->error, $this->dbconn->errno);
        }

        $is_stmt_result = is_object($this->result) && get_class($this->result) == 'mysqli_stmt';

        if ($is_stmt_result)
        {
            $this->rowsAffected = $this->result->affected_rows;

            $res = $this->result->get_result();

            /*
             * if $res is false then there aren't results.
             * It is useful to prevent rollback transactions on insert statements because
             * insert statement do not free results.
             */
            if ($res)
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
                $this->result = $res;
        }

        # identify SELECT, SHOW, DESCRIBE or EXPLAIN queries
        if (is_object($this->result) && property_exists($this->result, 'num_rows'))
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            $this->numRows = $this->result->num_rows;
        else

        {
            if (property_exists($this->dbconn, 'affected_rows') && !$is_stmt_result)
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
                $this->rowsAffected = $this->dbconn->affected_rows;
        }

        # affected_rows return the same of num_rows on select statements!
        if ($this->numRows > 0)
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            $this->rowsAffected = 0;

        if (property_exists($this->dbconn, 'field_count'))
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            $this->numFields = $this->dbconn->field_count;

        if ($this->transac_mode)
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            $this->transac_result = is_null($this->transac_result) ? $this->result: $this->transac_result && $this->result;

        /*
         * Because mysqli_query() returns FALSE on failure, a mysqli_result object for SELECT, SHOW, DESCRIBE or EXPLAIN queries,
         * and TRUE for other successful queries, it should be handled to return only objects or resources.
         *
         * Ref: http://php.net/manual/en/mysqli.query.php
         */
        return is_bool($this->result) ? $this->dbconn : $this->result;
    }

    /**
     * {@inheritDoc}
     */
    public function commit()
    {
        return $this->dbconn->commit();
    }

    /**
     * {@inheritDoc}
     */
    public function rollback()
    {
        return $this->dbconn->rollback();
    }

    /**
     * {@inheritDoc}
     */
    public function disconnect()
    {
        parent::disconnect();

        if ($this->dbconn->close())
        {
            $this->dbconn = null;
            return true;
        }

        return false;
    }

    /**
     * {@inheritDoc}
     */
    public function autocommit($value)
    {
        parent::autocommit($value);
        $this->dbconn->autocommit($value);
    }

    /**
     * Returns an array with the rows fetched
     *
     * @throws LogicException
     *
     * @return array
     */
    protected function toArray()
    {
        $data = [];

        if ($this->result && !is_bool($this->result))
        {
            while ($row = $this->result->fetch_array(MYSQLI_BOTH))
            {
                $data[] = $row;
            }
        }
        else
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            # This error is thrown because of 'execute' method has not been executed.
            throw new \LogicException('There are not data in the buffer!');

        $this->arrayResult = $data;

        return $data;
    }

    /**
     * By default __destruct() disconnects to database
     *
     * @return null
     */
    public function __destruct()
    {
        # prevent "Property access is not allowed yet" with @ on failure connections
        if ($this->dbconn !== false && !is_null($this->dbconn))
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}
            @$this->dbconn->close();
            /** @scrutinizer ignore-unhandled */ @$this->dbconn->close();
    }
}
Pleets / dronephp

Push — master ( 87e63f...d6a1bd )

MySQL::rollback() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like
