-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Implemented lazyload PDO
- Loading branch information
Showing
4 changed files
with
223 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,217 @@ | ||
| <?php | ||
| /** | ||
| * This class is a part of reSlim project | ||
| * @author M ABD AZIZ ALFIAN <github.com/aalfiann> | ||
| * | ||
| * Don't remove this class unless You know what to do | ||
| * | ||
| */ | ||
| namespace classes; | ||
| use PDO; | ||
| /** | ||
| * A class for handle Lazyload PDO | ||
| * | ||
| * @package Core reSlim | ||
| * @author M ABD AZIZ ALFIAN <github.com/aalfiann> | ||
| * @copyright Copyright (c) 2018 M ABD AZIZ ALFIAN | ||
| * @license https://github.com/aalfiann/reSlim/blob/master/license.md MIT License | ||
| */ | ||
| class LazyPDO extends PDO { | ||
|
|
||
| /** | ||
| * @var string | ||
| */ | ||
| protected $dsn; | ||
|
|
||
| /** | ||
| * @var string | ||
| */ | ||
| protected $username; | ||
|
|
||
| /** | ||
| * @var string | ||
| */ | ||
| protected $password; | ||
|
|
||
| /** | ||
| * @var array | ||
| */ | ||
| protected $options = []; | ||
|
|
||
| /** | ||
| * @var boolean True if PDO was initialized | ||
| */ | ||
| protected $initialized = false; | ||
|
|
||
| /** | ||
| * @var array Storage for attributes which are set before initializing connection | ||
| */ | ||
| protected $attributes = []; | ||
|
|
||
| /** | ||
| * Creates a lazy-loaded PDO instance representing a connection to a database | ||
| * | ||
| * @param string $dsn | ||
| * @param string $username | ||
| * @param string $password | ||
| * @param array $options | ||
| * @return PDO | ||
| */ | ||
| public function __construct($dsn, $username = null, $password = null, array $options = []){ | ||
| $this->dsn = $dsn; | ||
| $this->username = $username; | ||
| $this->password = $password; | ||
| $this->options = $options; | ||
| } | ||
|
|
||
| /** | ||
| * Init PDO once, if not already initialized | ||
| * | ||
| */ | ||
| protected function initialize(){ | ||
| if (!$this->initialized) { | ||
| parent::__construct($this->dsn, $this->username, $this->password, $this->options); | ||
|
|
||
| foreach ($this->attributes as $key => $value) { | ||
| parent::setAttribute($key, $value); | ||
| } | ||
|
|
||
| $this->initialized = true; | ||
| } | ||
| } | ||
|
|
||
| ### Overloaded PDO methods | ||
|
|
||
| /** | ||
| * Initiates a transaction | ||
| * | ||
| * @return boolean | ||
| */ | ||
| public function beginTransaction(){ | ||
| $this->initialize(); | ||
| return parent::beginTransaction(); | ||
| } | ||
|
|
||
| /** | ||
| * Commits a transaction | ||
| * | ||
| * @return boolean | ||
| */ | ||
| public function commit(){ | ||
| $this->initialize(); | ||
| return parent::commit(); | ||
| } | ||
|
|
||
| /** | ||
| * Fetch the SQLSTATE associated with the last operation on the database handle | ||
| * | ||
| * @return mixed | ||
| */ | ||
| public function errorCode(){ | ||
| $this->initialize(); | ||
| return parent::errorCode(); | ||
| } | ||
|
|
||
| /** | ||
| * Fetch extended error information associated with the last operation on the database handle | ||
| * | ||
| * @return array | ||
| */ | ||
| public function errorInfo(){ | ||
| $this->initialize(); | ||
| return parent::errorInfo(); | ||
| } | ||
|
|
||
| /** | ||
| * Execute an SQL statement and return the number of affected rows | ||
| * | ||
| * @param string $statement | ||
| * @return int | ||
| */ | ||
| public function exec($statement){ | ||
| $this->initialize(); | ||
| return parent::exec($statement); | ||
| } | ||
|
|
||
| /** | ||
| * Retrieve a database connection attribute | ||
| * | ||
| * @param int $attribute | ||
| * @return mixed | ||
| */ | ||
| public function getAttribute($attribute){ | ||
| $this->initialize(); | ||
| return parent::getAttribute($attribute); | ||
| } | ||
|
|
||
| /** | ||
| * Checks if inside a transaction | ||
| * | ||
| * @return boolean | ||
| */ | ||
| public function inTransaction(){ | ||
| $this->initialize(); | ||
| return parent::inTransaction(); | ||
| } | ||
|
|
||
| /** | ||
| * Returns the ID of the last inserted row or sequence value | ||
| * | ||
| * @param string $name | ||
| * @return string | ||
| */ | ||
| public function lastInsertId($name = null){ | ||
| $this->initialize(); | ||
| return parent::lastInsertId($name); | ||
| } | ||
|
|
||
| /** | ||
| * Prepares a statement for execution and returns a statement object | ||
| * | ||
| * @param string $statement | ||
| * @param array $driver_options | ||
| * @return \PDOStatement | ||
| */ | ||
| public function prepare($statement, $driver_options = []){ | ||
| $this->initialize(); | ||
| return parent::prepare($statement, $driver_options); | ||
| } | ||
|
|
||
| /** | ||
| * Executes an SQL statement, returning a result set as a PDOStatement object | ||
| * | ||
| * @param string $statement | ||
| * @return \PDOStatement | ||
| */ | ||
| public function query($statement){ | ||
| $this->initialize(); | ||
| return call_user_func_array('parent::query', func_get_args()); | ||
| } | ||
|
|
||
| /** | ||
| * Rolls back a transaction | ||
| * | ||
| * @return boolean | ||
| */ | ||
| public function rollback(){ | ||
| $this->initialize(); | ||
| return parent::rollBack(); | ||
| } | ||
|
|
||
| /** | ||
| * Set an attribute | ||
| * | ||
| * @param int $attribute | ||
| * @param mixed $value | ||
| * @return boolean | ||
| */ | ||
| public function setAttribute($attribute, $value){ | ||
| if ($this->initialized) { | ||
| return parent::setAttribute($attribute, $value); | ||
| } else { | ||
| $this->attributes[$attribute] = $value; | ||
| return true; | ||
| } | ||
| } | ||
|
|
||
| } |