超輕量的 PHP 資料庫工具包

複製程式碼

一個很輕的 PHP 資料庫工具包，誕生時間兩天（足以證明很輕了 ）。
兩個類，一個 Connection 管理 PDO 連線（支援多資料庫），一個 QuickQuery 用來快速執行資料庫操作（不用在 PDO 和 PDOStatement 之間來回折騰）
不用下載，線上就能看完。

use PersistenceDbAccess;

// 在框架初始化的地方加入連線資訊
DbAccessConnection::add(
 'default',
 ' sqlite',
 '/db/mydb.sqlite',
 null, null, false
);

// 下面是使用
$conn = DbAccessConnection::instance( 'default');

// 查詢
$query = new DbAccessQuickQuery($conn);
$query->prepare('select :name as name')->execute(array( ':name'=>'tonyseek'));

// 物件直接作為迭代器產生資料數組
foreach($query as $i) {
 var_dump($i);
}

// 如果有偏執的話，輸出回應之前手動斷開連接
DbAccessConnection::disconnectAll();

複製程式碼複製程式碼複製程式碼

namespace PersistenceDbAccess;
use PDO, ArrayObject, DateTime;
use LogicException, InvalidArgumentException;
use LogicException, InvalidArgumentException; >*/
class QuickQuery implements IteratorAggregate
{
 /**
 * 快速查詢頻道
 *
 * @version 0.3
 * @author tonyseek
 * @link http://stu.szu.edu.cn
 * @license http: //www.opensource.org/licenses/mit-license.html
 * @copyright StuCampus Development Team, Shenzhen University
 *
*/
 private $connection = null;

 /
 * 資料庫連線
 *
 * @var PersistenceDbAccessConnection
 > private $stmt = null;

 /**
 * PDO 語句
 *
 * @var PDOStatement
*/
 private $checkedParams = array();


 /**
 * 被檢查參數集
 *
 * @var array
*
 * 建構查詢通道
 *
 * @param PersistenceDbAccessConnection $connection 資料庫連線
*
 public function __construct(Connection $connection)
 {
 $this->connection = $connection;
 }

 /**
 * 預先編譯 SQL 語句
 *
 * @param string $sqlCommand SQL語句
 * @return PersistenceDbAccessQuickQuery
*/
 publicunc. ($sqlCommand)
 {
 // 從連線取得PDO, 並對SQL 語句執行prepare, 產生PDO Statement
 $this->stmt = $this->connection->getPDO()->prepare ($sqlCommand);
 // 修改PDO Statement 模式為關聯數組資料
 $this->stmt->setFetchMode(PDO::FETCH_ASSOC);
 // 傳回方法鏈
 return $this ;
 }

 /**
 * 執行資料查詢
 *
 * @throws PDOException
 * @return PersistenceDbAccessQuickQuery
*/
 public function execute($params = array())
 {
 $stmt = $this->getStatement() ;

 // 參數檢查
 $diff = array_diff($this->checkedParams, array_keys($params));
 if (count($this->checkedParams) && count($diff )) {
 throw new InvalidArgumentException('缺少必備參數：'.implode(' | ', $diff));
 }

 // 將PHP 資料型別對應到資料庫資料型態
 foreach($params as $key => $value) {
 $type = null;
 switch(true) {
 case is_int($value):
 $type = PDO: :PARAM_INT;
 break;
 case is_bool($value):
 $type = PDO::PARAM_BOOL;
 break;
 case ($value instanceof DateTime): $value = $value->format(DateTime::W3C);
 break;
 case is_null($value):
 $type = PDO::PARAM_NULL;
 break;
 default:
 $type = PDO::PARAM_STR;
 }

 $stmt->bindValue($key, $value, $type);
 $stmt->bindValue($key, $value, $type);
 }

 $stmt->execute();
 $this->checkedParams = array(); // 清空參數檢定
 return $this;
 }

 /**
 * 取得 Statement 物件
 *
 * 傳回物件可以被綁定參數重新執行, 也可以被當作迭代器遍歷取得資料。
 *
 * @return PDOStatement
*/
 public function getStatement()
 {
 if (!$this->stmt) {
 throw new LogicException('''pSQL處理');
 }

 return $this->stmt;
 }

 /**
 * getStatement 方法的替代名稱
 *
 * 實作 PHP 標準函式庫 中的 IteratorAggregate 介面, 外部可以直接將本物件作為迭代器遍
 * 歷。和 getStatment 唯一不同之處, 是本方法不會拋出 LogicException 例外。如果
 * 沒有事先使用 prepare 和 execute, 會回傳一個空迭代器。
 *
 * @return Traversable
*/
 public function getIterator()*/
 public function getIterator() {
 try {
 return $this->getStatement();
 } catch (LogicException $ex) {
 return new ArrayObject();
 }
 }

 /**
 * 設定查詢參數檢查
 *
 * 透過此處匯入的被檢查查詢​​參數, 如果沒有得到賦值, 則查詢時會拋出LogicException 例外。
 *
 * @param array $params
 * @return PersistenceDbAccessQuickQuery
 */
 public function setParamsCheck(array $params)
 return $this;
 }

 /**
 * 將結果集轉換為陣列
 *
 * @return array
*/
 public function toArray()
 {
 return iterator_this_array($ ->getStatement());
 }

 /**
 * 取得最後一個插入結果（或序列）的 ID
 *
 * @param string $name
 * @return int
*/
 public function getLastInsertId($name=null)
 {
 return $this->connection $this->connection ->getPDO()->lastInsertId($name);
 }
}