MySQL::autocommit() - Code Metrics - Pleets/dronephp - Measure and Improve Code Quality continuously with Scrutinizer

MySQL::autocommit() A
last analyzed 2020-10-16 14:23 UTC

↳ Parent: MySQL
Complexity

Conditions	1
Paths	1
Size

Total Lines	4
Code Lines	2
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	3
CRAP Score	1
Importance

Changes
Metric	Value
cc	1
eloc	2
nc	1
nop	1
dl	0
loc	4
ccs	3
cts	3
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)) {
            $options["dbchar"] = "utf8";
        }

        parent::__construct($options);

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

        if ($auto_connect) {
            $this->connect();
        }
    }

    /**
     * Connects to database
     *
     * @throws RuntimeException
     * @throws Exception\ConnectionException
     *
     * @return \mysqli
     */
    public function connect()
    {
        if (!extension_loaded('mysqli')) {
            throw new \RuntimeException("The Mysqli extension is not loaded");
        }

        if (!is_null($this->dbport) && !empty($this->dbport)) {

            $conn = @new \mysqli($this->dbhost, $this->dbuser, $this->dbpass, $this->dbname, $this->dbport);
        } else {
            $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])) {
                    $bind_types .= 's';
                } elseif (is_float($param_values[$i])) {
                    $bind_types .= 'd';
                } else {
                    # [POSSIBLE BUG] - To Future revision (What about non-string and non-decimal types ?)
                    $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) {
                $this->result = $res;
            }
        }

        # identify SELECT, SHOW, DESCRIBE or EXPLAIN queries
        if (is_object($this->result) && property_exists($this->result, 'num_rows')) {
            $this->numRows = $this->result->num_rows;
        } else {
            if (property_exists($this->dbconn, 'affected_rows') && !$is_stmt_result) {
                $this->rowsAffected = $this->dbconn->affected_rows;
            }
        }

        # affected_rows return the same of num_rows on select statements!
        if ($this->numRows > 0) {
            $this->rowsAffected = 0;
        }

        if (property_exists($this->dbconn, 'field_count')) {
            $this->numFields = $this->dbconn->field_count;
        }

        if ($this->transac_mode) {
            $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 {             # 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)) {
            @$this->dbconn->close();
            /** @scrutinizer ignore-unhandled */ @$this->dbconn->close();
        }
    }
}

Pleets / dronephp

MySQL::autocommit() A last analyzed 2020-10-16 14:23 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

MySQL::autocommit() A
last analyzed 2020-10-16 14:23 UTC
