database.php

<?php
    require_once("config.php");
    require_once("logger.php");

    function dbConnect()
    {
        $mysqli = new mysqli(DBADDR, DBUSER, DBPASS, DBNAME);
        if ($mysqli->connect_errno) 
        {
            LogMessage("(".$mysqli->connect_errno.") ".$mysqli->connect_error, "mysql_connect.log");
            exit;
        }
        $mysqli->set_charset("utf8");
        return $mysqli;
    }
    function dbClose($mysqli)
    {
        if($mysqli->errno)
            LogMessage("(".$mysqli->errno.") ".$mysqli->error, "mysql.log", true);
        $mysqli->close();
    }
    function dbUpdate($query,$parametersType = null,$parameters = null, $returnType = DatabaseReturns::RETURN_BOOLEAN)
    {
        $res = false;
        $dbConn = dbConnect();
        if($st = $dbConn->prepare($query))
        {
            if($parametersType!=null)
                call_user_func_array(array($st, 'bind_param'), array_merge(array($parametersType), makeValuesReferenced($parameters)));
            $res = $st->execute();
            switch($returnType)
            {
                case DatabaseReturns::RETURN_BOOLEAN:
                    //è il valore salvato di default in $res
                    break;
                case DatabaseReturns::RETURN_AFFECTED_ROWS:
                    $res = $dbConn->affected_rows;
                    break;
                case DatabaseReturns::RETURN_INSERT_ID:
                    $res = $dbConn->insert_id;
                    break;
            }
            $st->close();
        }
        dbClose($dbConn);
        return $res;
    }
    function dbSelect($query,$parametersType = null,$parameters = null,$oneRow = false)
    {
        $res = false;
        $dbConn = dbConnect();
        if($st = $dbConn->prepare($query))
        {
            if($parametersType!=null)
                call_user_func_array(array($st, 'bind_param'), array_merge(array($parametersType), makeValuesReferenced($parameters)));
            if($st->execute())
            {
                if($oneRow)
                    $res = null;
                else
                    $res = array();
                $result = $st->get_result();
                while($row = $result->fetch_array(MYSQLI_ASSOC))
                {
                    if($oneRow)
                    {
                        $res = $row;
                        break;
                    }
                    else
                        array_push($res,$row);
                }
            }
            $st->close();
        }
        dbClose($dbConn);
        return $res;
    }
	function makeValuesReferenced(&$arr)
	{ 
		$refs = array(); 
		foreach($arr as $key => $value) 
			$refs[$key] = &$arr[$key]; 
		return $refs;
	}

    abstract class DatabaseReturns extends BasicEnum
    {
        const RETURN_BOOLEAN = 1;
        const RETURN_AFFECTED_ROWS = 2;
        const RETURN_INSERT_ID = 3;
    }
    abstract class BasicEnum {
        private static $constCacheArray = NULL;

        public static function getConstants() {
            if (self::$constCacheArray == NULL) {
                self::$constCacheArray = array();
            }
            $calledClass = get_called_class();
            if (!array_key_exists($calledClass, self::$constCacheArray)) {
                $reflect = new ReflectionClass($calledClass);
                self::$constCacheArray[$calledClass] = $reflect->getConstants();
            }
            return self::$constCacheArray[$calledClass];
        }

        public static function isValidName($name, $strict = false) {
            $constants = self::getConstants();

            if ($strict) {
                return array_key_exists($name, $constants);
            }

            $keys = array_map('strtolower', array_keys($constants));
            return in_array(strtolower($name), $keys);
        }

        public static function isValidValue($value, $strict = true) {
            $values = array_values(self::getConstants());
            return in_array($value, $values, $strict);
        }
    }
?>