Lepton\Core\Database

Complexity

Total Complexity

30

Size/Duplication

Total Lines	144
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	fetch_array()	0	16	4
A	num_rows()	0	4	1
A	query()	0	21	5
A	fetch_result()	0	3	1
A	_gettype()	0	7	5
A	error()	0	4	2
A	last_insert_id()	0	3	1
A	affected_rows()	0	3	1
A	close()	0	3	1
B	fetch_all()	0	25	7
A	__construct()	0	7	2

<?php

namespace Lepton\Core;

class Database
{

    protected $connection;
    protected $query;
    protected $show_errors = TRUE;
    protected $query_closed = TRUE;

    /**
     * Database constructor.
     * @param string $dbhost
     * @param string $dbuser
     * @param string $dbpass
     * @param string $dbname
     * @param string $charset
     */
    public function __construct($dbhost = 'localhost', $dbuser = 'root', $dbpass = '', $dbname = '', $charset = 'utf8')
    {
        $this->connection = new \mysqli($dbhost, $dbuser, $dbpass, $dbname);
        if ($this->connection->connect_error) {
            $this->error('Failed to connect to MySQL - ' . $this->connection->connect_error);
        }
        $this->connection->set_charset($charset);
    }

    /*
    * Execute an SQL query on the database
    * @param string $query
    * @param array $args
    * @return array|bool
    */

    public function query($query, &...$args)
    {
        if (!$this->query_closed) {
            $this->query_closed = TRUE;
            $this->query->close();
        }
        if ($this->query = $this->connection->prepare($query)) {
            if (count($args)) {
                $types = implode(array_map(array($this, '_gettype'), $args));
                $this->query->bind_param($types, ...$args);
            }

            $this->query->execute();
            if ($this->query->errno) {
                $this->error('Unable to process MySQL query (check your params) - ' . $this->query->error);
            }
            $this->query_closed = FALSE;
        } else {
            $this->error('Unable to prepare MySQL statement (check your syntax) - ' . $this->connection->error);
        }
        return $this;

The expression return $this returns the type Lepton\Core\Database which is incompatible with the documented return type array|boolean.

    }


    public function fetch_all($callback = null)
    {
        $params = array();
        $row = array();
        $meta = $this->query->result_metadata();
        while ($field = $meta->fetch_field()) {
            $params[] = &$row[$field->name];
        }
        $this->query->bind_result(...$params);

        $result = array();
        while ($this->query->fetch()) {
            $r = array();
            foreach ($row as $key => $val) {
                $r[$key] = $val;
            }
            if ($callback != null && is_callable($callback)) {
                $value = $callback($r); //call_user_func($callback, $r);
                if ($value == 'break') break;
            } else {
                $result[] = $r;
            }
        }
        $this->query_closed = TRUE;
        return $result;
    }

    public function fetch_array()
    {
        $params = array();
        $row = array();
        $meta = $this->query->result_metadata();
        while ($field = $meta->fetch_field()) {
            $params[] = &$row[$field->name];
        }
        $this->query->bind_result(...$params);
        $result = array();
        while ($this->query->fetch()) {
            foreach ($row as $key => $val) {
                $result[$key] = $val;
            }
        }
        return $result;
    }

    public function fetch_result()
    {
        return $this->query->get_result();
    }




    public function close()
    {
        return $this->connection->close();
    }

    public function num_rows()
    {
        $this->query->store_result();
        return $this->query->num_rows;
    }

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

    public function last_insert_id()
    {
        return $this->connection->insert_id;
    }

    public function error($error)
    {
        if ($this->show_errors) {
            die($error);

Using exit here is not recommended.

        }
    }

    private function _gettype($var)
    {
        if (is_string($var)) return 's';
        if (is_float($var)) return 'd';
        if (is_int($var)) return 'i';
        if (is_null($var)) return 's';
        return 'b';
    }
}