Pdo.php

Go to the documentation of this file.

<?php

 
namespace Depage\Db;
 
class Pdo
{
    public $prefix = "";
    private $pdo = null;
    private $dsn;
    private $username;
    private $password;
    private $driver_options;

    public function __construct($dsn, $username = '', $password = '', $driver_options = [])
    {
        $this->dsn = $dsn;
        if (strpos($dsn, "mysql:") === 0) {
            $this->dsn .= ";charset=utf8mb4";
        }
        $this->username = $username;
        $this->password = $password;
 
        if (isset($driver_options['prefix'])) {
            $this->prefix = $driver_options['prefix'];
            unset($driver_options['prefix']);
        }
        $this->driver_options = $driver_options;
    }

    public function __destruct()
    {
        $this->pdo = null;
    }

    private function lateInitialize()
    {
        $this->pdo = new \PDO($this->dsn, $this->username, $this->password, $this->driver_options);
 
        // set error mode to exception by default
        $this->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
 
        // disable emulated prepares
        // @todo check why this does not work with some queries
        $this->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false);
    }
 
    public function getPdoObject()
    {
        if (is_null($this->pdo)) {
            $this->lateInitialize();
        }
 
        return $this->pdo;
    }

    public static function unbuffered(): array
    {
        if (defined("Pdo\Mysql::ATTR_USE_BUFFERED_QUERY")) {
            return [\Pdo\Mysql::ATTR_USE_BUFFERED_QUERY => false];
        } else {
            return [\PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => false];
        }
    }

    public function __set($name, $value)
    {
        if (is_null($this->pdo)) {
            $this->lateInitialize();
        }
        $this->$name = $value;
    }

    public function __get($name)
    {
        if (is_null($this->pdo)) {
            $this->lateInitialize();
        }
 
        return $this->$name;
    }

    public function __call($name, $arguments)
    {
        if (is_null($this->pdo)) {
            $this->lateInitialize();
        }
 
        try {
            return call_user_func_array([$this->pdo, $name], $arguments);
        } catch (\PDOException $e) {
            $message = "";
            if (in_array($name, ["prepare", "exec", "query"])) {
                $message = "\non the following query: \n" . $arguments[0];
            }
            throw new \Depage\Db\Exceptions\PdoException($e->getMessage() . $message, (int) $e->getCode(), $e);
        }
    }

    public static function __callStatic($name, $arguments)
    {
        try {
            return call_user_func_array("pdo::$name", $arguments);
        } catch (\PDOException $e) {
            throw new \Depage\Db\Exceptions\PdoException($e->getMessage(), (int) $e->getCode(), $e);
        }
    }

    public function __sleep(): array
    {
        return [
            'dsn',
            'username',
            'password',
            'driver_options',
            'prefix',
        ];
    }

    public function __wakeup() {}

    public static function parse_dsn($dsn)
    {
        $info = [];
 
        list($info['protocol'], $rest) = explode(":", $dsn, 2);
 
        $parts = explode(";", $rest);
 
        foreach ($parts as $part) {
            list($name, $value) = explode("=", $part, 2);
            $info[$name] = $value;
        }
 
        return $info;
    }
}
 
/* vim:set ft=php sw=4 sts=4 fdm=marker et : */