Вход Регистрация
Файл: app/db.php
Строк: 61
<?php 
# Check system constant;
if (!defined("APP")) die('access denied');

if (!
class_exists('PDO')) 
{
    die(
'Fatal Error: For work need support PDO');


class 
PDO_ extends PDO 
{
    function 
__construct($dsn$username$password
    {
        
parent :: __construct($dsn$username$password);
        
$this -> setAttribute(PDO :: ATTR_ERRMODEPDO :: ERRMODE_EXCEPTION);
        
$this -> setAttribute(PDO :: ATTR_DEFAULT_FETCH_MODEPDO :: FETCH_ASSOC);
    } 

    function 
prepare($sql$params = []) 
    {
        
$stmt parent :: prepare($sql, [
                
PDO :: ATTR_STATEMENT_CLASS => ['PDOStatement_']]);
        return 
$stmt;
    } 

    function 
query($sql$params = []) 
    {
        
$stmt $this -> prepare($sql);
        
$stmt -> execute($params); 
        return 
$stmt;
    } 

    function 
querySingle($sql$params = []) 
    {
        
$stmt $this -> query($sql$params);
        
$stmt -> execute($params);
        return 
$stmt -> fetchColumn(0);
    } 

    function 
queryFetch($sql$params = []) 
    {
        
$stmt $this -> query($sql$params);
        
$stmt -> execute($params);
        return 
$stmt -> fetch();
    } 


class 
PDOStatement_ extends PDOStatement 
{
    function 
execute($params = []) 
    {
        if (
func_num_args() == 1
        {
            
$params func_get_arg(0);
        } 
        else 
        {
            
$params func_get_args();
        } 

        if (!
is_array($params)) 
        {
            
$params = [$params];
        } 

        
parent :: execute($params);
        return 
$this;
    }

    function 
fetchSingle() 
    {
        return 
$this -> fetchColumn(0);
    } 

    function 
fetchAssoc() 
    {
        
$this -> setFetchMode(PDO :: FETCH_NUM);
        
$data = [];
        while (
$row $this -> fetch()) 
        {
            
$data[$row[0]] = $row[1];
        } 
        return 
$data;
    } 
}

class 
DB 
{
    static 
$dbs;
    public function 
__construct() 
    {
        try 
        {
            
self :: $dbs = new PDO_('mysql:host=' DBHOST ';port=' DBPORT ';dbname=' DBNAMEDBUSERDBPASS);
            
self :: $dbs -> exec('SET CHARACTER SET utf8');
            
self :: $dbs -> exec('SET NAMES utf8');
        }
        catch (
PDOException $e
        {
            die(
'Connection failed: ' $e -> getMessage());
        }         
    } 


$db = new DB();
Онлайн: 1
Реклама