<?php
class Database extends PDO{   
	public function __construct($dbdriver, $hostname, $dbname, $username, $password, $char_set){
    	try{
    	parent::__construct($dbdriver . "::host=". $hostname ."; dbname=".$dbname, $username, $password, 
                            array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES '.$char_set));
            
        parent::setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        }catch(PDOException $e){
            include './views/exception/index.php';
            exit();
        }
	}
    
    public function insert($table, $data){
        ksort($data);
        
        $fieldNames = implode('`, `', array_keys($data));
        $fieldValues = ':' .  implode(', :', array_keys($data));
        try{
            $stn = $this->prepare("INSERT INTO `$table` (`$fieldNames`) VALUES($fieldValues)");
            
            foreach($data as $key=>$value){
                $stn->bindValue(":$key", $value);
        }
        
        $stn->execute();
        }catch(Exception $e){
            include './views/exception/index.php';
            exit();
        }
    }
    
    
    public function selectAll($table){
    try{
        $sql = $this->query("SELECT * FROM `$table`");
        while($res = $sql->fetch(PDO::FETCH_ASSOC)){
            $ar = new stdClass();
            foreach ($res as $key=>$value)
                $ar->$key = $value;
            $data[] = $ar;
        }
        return $data;
    }catch(Exception $e){
        include './views/exception/index.php';
        exit();
    }
    }
    
    public function selectSingle($table, $where){
        $sql = $this->query("SELECT * FROM `$table` WHERE $where");
        $res = $sql->fetch(PDO::FETCH_ASSOC);
        $ar = new stdClass();
         foreach ($res as $key=>$value)
                $ar->$key = $value;
            $data[] = $ar;
        return $data;
    }
    
    
    public function update($table, $data, $where){
        ksort($data);
        $str = implode(', ', array_map(function($str){return '`'.$str.'` = :'.$str;}, array_keys($data)));
        $stn = $this->prepare("UPDATE $table SET $str WHERE $where");       
        $stn->execute($data);
    }
    
    public function updateMulti($table, $data, $where){
        try{
            if(count($data) > 0){
                foreach($data as $val){
                    if(!in_array($where, array_keys($val))){
                        throw new Exception('Wrong field where');
                        exit();
                    }
                    $ar = array_map(function($str){return '`'.$str.'` = :'.$str;}, array_keys($val));
                    $row = implode(', ', array_values($ar));
                    $stn = $this->prepare("UPDATE $table SET $row WHERE `$where` = ".$val[$where]);
                    $stn->execute($val);
                }
            }else{
                throw new Exception('Data is empty');
                exit();
            }
        }catch(PDOException $e){
            include './views/exception/index.php';
            exit();
        }catch(Exception $e){
            include './views/exception/index.php';
            exit();
        }
    }
    
    public function delete($table, $data){
        $fieldValues = implode(', ', array_map(function($str){return '`'.$str.'` = :'.$str;}, array_keys($data)));
        try{
            $stn = $this->prepare("DELETE FROM $table WHERE $fieldValues");
            
            foreach($data as $key=>$value){
                $stn->bindValue(":$key", $value);
            }
            
            $stn->execute();
        }catch(Exception $e){
            include './views/exception/index.php';
            exit();
        }
    }
    
    public function emptyTable($table){
        $stn = $this->prepare("TRUNCATE TABLE $table");
        return $stn->execute();
    }
}

<?php
class Database extends PDO{
	public function __construct($dbdriver, $hostname, $dbname, $username, $password, $char_set){
    	try{
    	parent::__construct($dbdriver . "::host=". $hostname ."; dbname=".$dbname, $username, $password,array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES '.$char_set));
            
        parent::setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        }catch(PDOException $e){
            exception_handler($e->getMessage(), 'Ошибка подключения к БД');
            exit();
        }
    }
    
    public function insert($table, $data){        
        $row = $this->generalImplodeArray($data);
        $stn = $this->prepare("INSERT INTO `$table` SET $row ");
        $stn->execute($data);
        return $this->lastInsertId();
    }

    public function insertMulti($table, $data){        
        foreach($data as $key=>$value){
            $this->insert($table, $value);
        }
    }
    
    public function select($table, $where){
        $sql = $this->query("SELECT * FROM `$table` WHERE $where");
        return $sql->fetch(PDO::FETCH_OBJ);
    }

    public function selectMulti($table){
        $sql = $this->query("SELECT * FROM `$table`");
        return $sql->fetchAll(PDO::FETCH_CLASS, "stdClass");
    
    }    
    
    public function update($table, $data, $where){
        $str = $this->generalImplodeArray($data);
        $stn = $this->prepare("UPDATE $table SET $str WHERE $where");       
        $stn->execute($data);
    }
    
    public function updateMulti($table, $data, $where){
        foreach($data as $val){    
            $row = $this->generalImplodeArray($val);
            $stn = $this->prepare("UPDATE $table SET $row WHERE `$where` = ".$val[$where]);
            $stn->execute($val);
        }        
    }
    
    public function delete($table, $data){
        $row = $this->generalImplodeArray($data);
        $stn = $this->prepare("DELETE FROM $table WHERE $row");
        $stn->execute($data);
    }
    
    
    public function cleanTable($table){
        $stn = $this->prepare("TRUNCATE TABLE $table");
        return $stn->execute();
    }
    
    
    private function generalImplodeArray($data){
        ksort($data);
        return implode(', ', array_map(function($str){return '`'.$str.'` = :'.$str;}, array_keys($data)));
    }
}