diff options
Diffstat (limited to 'modules/database/classes/driver/pdo/db.php')
| -rw-r--r-- | modules/database/classes/driver/pdo/db.php | 70 |
1 files changed, 70 insertions, 0 deletions
diff --git a/modules/database/classes/driver/pdo/db.php b/modules/database/classes/driver/pdo/db.php new file mode 100644 index 0000000..89c7165 --- /dev/null +++ b/modules/database/classes/driver/pdo/db.php @@ -0,0 +1,70 @@ +<?php + +/** + * PDO Database implementation. + */ +class DB_PDO_Driver extends DB{ + + /** + * Connection object + * @var PDO + * @access public + * @link http://php.net/manual/en/class.pdo.php + */ + public $conn; + + /** + * Initializes database connection + * + * @param string $config Name of the connection to initialize + * @return void + * @access public + */ + public function __construct($config) { + $this->conn = new PDO( + Config::get("database.{$config}.connection"), + Config::get("database.{$config}.user",''), + Config::get("database.{$config}.password",'') + ); + } + + /** + * Builds a new Query implementation + * + * @param string $type Query type. Available types: select,update,insert,delete,count + * @return Query_PDO_Driver Returns a PDO implementation of a Query. + * @access public + * @see Query_Database + */ + public function build_query($type) { + return new Query_PDO_Driver($this,$type); + } + + /** + * Gets the id of the last inserted row. + * + * @return mixed Row id + * @access public + */ + public function get_insert_id() { + return $this->conn->lastInsertId(); + } + + /** + * Executes a prepared statement query + * + * @param string $query A prepared statement query + * @param array $params Parameters for the query + * @return Result_PDO_Driver PDO implementation of a database result + * @access public + * @throws Exception If the query resulted in an error + * @see Database_Result + */ + public function execute($query, $params = array()) { + $cursor = $this->conn->prepare($query); + if(!$cursor->execute($params)) + throw new Exception("Database error: ".implode(' ',$this->conn->errorInfo())." \n in query:\n{$query}"); + + return new Result_PDO_Driver($cursor); + } +}
\ No newline at end of file |