mysqldatabase.class.php

<?php
 
class MysqlDatabase
{
 
    private $host;
    private $usuario;
    private $pass;
    private $db;
 
    private $connection;
 
    function __construct($host, $usuario, $pass, $db)
    {
        $this->host = $host;
        $this->usuario = $usuario;
        $this->pass = $pass;
        $this->db = $db;
    }
 
    function connect(){
         
        $this->connection = mysqli_connect(
            $this->host,
            $this->usuario,
            $this->pass,
            $this->db
        );
 
        $this->connection->set_charset("utf8");
 
        if (mysqli_connect_errno()) {
            print("error al conectarse");
        }
    }
 
    function getData($sql)
    {
        $data = array();
        $result = mysqli_query($this->connection, $sql);
 
        $error = mysqli_error($this->connection);
 
        if (empty($error)) {
            if (mysqli_num_rows($result) > 0) {
                while ($row = mysqli_fetch_assoc($result)) {
                    array_push($data, $row);
                }
            }
        } else {
            throw new Exception($error);
        }
        return $data;
    }
 
    function numRows($sql)
    {
        $result = mysqli_query($this->connection, $sql);
        $error = mysqli_error($this->connection);
 
        if (empty($error)) {
            return mysqli_num_rows($result);
        } else {
            throw new Exception($error);
        }
    }
 
    function getDataSingle($sql)
    {
 
        $result = mysqli_query($this->connection, $sql);
 
        $error = mysqli_error($this->connection);
 
        if (empty($error)) {
            if (mysqli_num_rows($result) > 0) {
                return mysqli_fetch_assoc($result);
            }
        } else {
            throw new Exception($error);
        }
        return null;
    }
 
    function getDataSingleProp($sql, $prop)
    {
 
        $result = mysqli_query($this->connection, $sql);
 
        $error = mysqli_error($this->connection);
 
        if (empty($error)) {
            if (mysqli_num_rows($result) > 0) {
                $data = mysqli_fetch_assoc($result);
                return $data[$prop];
            }
        } else {
            throw new Exception($error);
        }
        return null;
    }
 
    function executeInstruction($sql)
    {
        $success = mysqli_query($this->connection, $sql);
 
        $error = mysqli_error($this->connection);
 
        if (empty($error)) {
            return $success;
        } else {
            throw new Exception($error);
        }
    }
 
    function close()
    {
        mysqli_close($this->connection);
    }
 
    function getLastId()
    {
        return mysqli_insert_id($this->connection);
    }
}




?>