社群 學習 工具庫 休閒
搜尋
繁体中文
首頁 > 後端開發 > php教程 > 主體

超輕量的 PHP 資料庫工具包

WBOY
發布： 2016-07-25 09:09:49
原創
1911 人瀏覽過
複製程式碼
一個很輕的 PHP 資料庫工具包，誕生時間兩天（足以證明很輕了 ）。
兩個類，一個 Connection 管理 PDO 連線（支援多資料庫），一個 QuickQuery 用來快速執行資料庫操作（不用在 PDO 和 PDOStatement 之間來回折騰）
不用下載，線上就能看完。
  1. use PersistenceDbAccess;
  3. // 在框架初始化的地方加入連線資訊
  4. DbAccessConnection::add(
  5. 'default',
  6. ' sqlite',
  7. '/db/mydb.sqlite',
  8. null, null, false
  9. );
  11. // 下面是使用
  12. $conn = DbAccessConnection::instance( 'default');
  14. // 查詢
  15. $query = new DbAccessQuickQuery($conn);
  16. $query->prepare('select :name as name')->execute(array( ':name'=>'tonyseek'));
  18. // 物件直接作為迭代器產生資料數組
  19. foreach($query as $i) {
  20. var_dump($i);
  21. }
  23. // 如果有偏執的話，輸出回應之前手動斷開連接
  24. DbAccessConnection::disconnectAll();
複製程式碼
複製程式碼複製程式碼複製程式碼
  1. namespace PersistenceDbAccess;
  2. use PDO, ArrayObject, DateTime;
  3. use LogicException, InvalidArgumentException;
  4. use LogicException, InvalidArgumentException; >*/
  5. class QuickQuery implements IteratorAggregate
  6. {
  7. /**
  8. * 快速查詢頻道
  9. *
  10. * @version 0.3
  11. * @author tonyseek
  12. * @link http://stu.szu.edu.cn
  13. * @license http: //www.opensource.org/licenses/mit-license.html
  14. * @copyright StuCampus Development Team, Shenzhen University
  15. *
  16. */
  17. private $connection = null;
  19. /
  20. * 資料庫連線
  21. *
  22. * @var PersistenceDbAccessConnection
  23. > private $stmt = null;
  25. /**
  26. * PDO 語句
  27. *
  28. * @var PDOStatement
  29. */
  30. private $checkedParams = array();
  33. /**
  34. * 被檢查參數集
  35. *
  36. * @var array
  37. *
  38. * 建構查詢通道
  39. *
  40. * @param PersistenceDbAccessConnection $connection 資料庫連線
  41. *
  42. public function __construct(Connection $connection)
  43. {
  44. $this->connection = $connection;
  45. }
  47. /**
  48. * 預先編譯 SQL 語句
  49. *
  50. * @param string $sqlCommand SQL語句
  51. * @return PersistenceDbAccessQuickQuery
  52. */
  53. publicunc. ($sqlCommand)
  54. {
  55. // 從連線取得PDO, 並對SQL 語句執行prepare, 產生PDO Statement
  56. $this->stmt = $this->connection->getPDO()->prepare ($sqlCommand);
  57. // 修改PDO Statement 模式為關聯數組資料
  58. $this->stmt->setFetchMode(PDO::FETCH_ASSOC);
  59. // 傳回方法鏈
  60. return $this ;
  61. }
  63. /**
  64. * 執行資料查詢
  65. *
  66. * @throws PDOException
  67. * @return PersistenceDbAccessQuickQuery
  68. */
  69. public function execute($params = array())
  70. {
  71. $stmt = $this->getStatement() ;
  73. // 參數檢查
  74. $diff = array_diff($this->checkedParams, array_keys($params));
  75. if (count($this->checkedParams) && count($diff )) {
  76. throw new InvalidArgumentException('缺少必備參數：'.implode(' | ', $diff));
  77. }
  79. // 將PHP 資料型別對應到資料庫資料型態
  80. foreach($params as $key => $value) {
  81. $type = null;
  82. switch(true) {
  83. case is_int($value):
  84. $type = PDO: :PARAM_INT;
  85. break;
  86. case is_bool($value):
  87. $type = PDO::PARAM_BOOL;
  88. break;
  89. case ($value instanceof DateTime): $value = $value->format(DateTime::W3C);
  90. break;
  91. case is_null($value):
  92. $type = PDO::PARAM_NULL;
  93. break;
  94. default:
  95. $type = PDO::PARAM_STR;
  96. }
  98. $stmt->bindValue($key, $value, $type);
  99. $stmt->bindValue($key, $value, $type);
  100. }
  102. $stmt->execute();
  103. $this->checkedParams = array(); // 清空參數檢定
  104. return $this;
  105. }
  107. /**
  108. * 取得 Statement 物件
  109. *
  110. * 傳回物件可以被綁定參數重新執行, 也可以被當作迭代器遍歷取得資料。
  111. *
  112. * @return PDOStatement
  113. */
  114. public function getStatement()
  115. {
  116. if (!$this->stmt) {
  117. throw new LogicException('''pSQL處理');
  118. }
  120. return $this->stmt;
  121. }
  123. /**
  124. * getStatement 方法的替代名稱
  125. *
  126. * 實作 PHP 標準函式庫 中的 IteratorAggregate 介面, 外部可以直接將本物件作為迭代器遍
  127. * 歷。和 getStatment 唯一不同之處, 是本方法不會拋出 LogicException 例外。如果
  128. * 沒有事先使用 prepare 和 execute, 會回傳一個空迭代器。
  129. *
  130. * @return Traversable
  131. */
  132. public function getIterator()*/
  133. public function getIterator() {
  134. try {
  135. return $this->getStatement();
  136. } catch (LogicException $ex) {
  137. return new ArrayObject();
  138. }
  139. }
  141. /**
  142. * 設定查詢參數檢查
  143. *
  144. * 透過此處匯入的被檢查查詢​​參數, 如果沒有得到賦值, 則查詢時會拋出LogicException 例外。
  145. *
  146. * @param array $params
  147. * @return PersistenceDbAccessQuickQuery
  148. */
  149. public function setParamsCheck(array $params)
  150. return $this;
  151. }
  153. /**
  154. * 將結果集轉換為陣列
  155. *
  156. * @return array
  157. */
  158. public function toArray()
  159. {
  160. return iterator_this_array($ ->getStatement());
  161. }
  163. /**
  164. * 取得最後一個插入結果（或序列）的 ID
  165. *
  166. * @param string $name
  167. * @return int
  168. */
  169. public function getLastInsertId($name=null)
  170. {
  171. return $this->connection $this->connection ->getPDO()->lastInsertId($name);
  172. }
  173. }
複製程式碼
  1. namespace PersistenceDbAccess;
  2. use InvalidArgumentException, BadMethodCallException;
  3. >**Exception; *
  4. * @version 0.3
  5. * @author tonyseek
  6. * @link http://stu.szu.edu.cn
  7. * @license http://www.opensource.org /licenses/mit-license.html
  8. * @copyright 深圳大學StuCampus 開發團隊
  9. *
  10. */
  11. 期末班連接
  12. {
  13. /**
  14. * Connector 實例集合
  15. *
  16. * @var array
  17. */
  18. static private $instances = array();
  20. /**
  21. * 資料庫驅動名稱
  22. *
  23. * @var string
  24. */
  25. private $driver = '';
  27. /**
  28. * 資料庫連接字串(Database Source Name)
  29. *
  30. * @var string
  31. */
  32. * PDO 實例
  33. *
  34. * @var PDO
  35. * 🎜> private $dsn = '';
  37. /**
  38. * 使用者名稱
  39. *
  40. * @var string
  41. */
  42. private $pdo = null;
  44. /**
  45. * 密碼
  46. *
  47. * @var string
  48. */
  49. 私人$使用者名稱= '';
  51. /**
  52. * 是否開啟持久連線
  53. *
  54. * @var bool
  55. */
  56. 私人$密碼= '';
  58. /**
  59. * 是否開啟模擬預編譯
  60. *
  61. * @var bool
  62. */
  63. 私人$ isPersisten = false;
  65. /**
  66. * 是否在交易中
  67. *
  68. * @var bool
  69. */
  70. private $isEmulate = false;
  72. /**
  73. * 私有建構函數，阻止外部使用 new 運算子實例化
  74. */
  75. private $isalation
  77. /**
  78. * 生產 Connector 實例（多例）
  79. *
  80. * @param string $name
  81. * @return StuCampusDataModelConnector
  82. */
  83. private function __construct(){}
  85. /**
  86. * 中斷所有資料庫實例的連線
  87. */
  88. static public function getgetstance($name = ' default')
  89. {
  90. if (!isset(self::$instances[$name])) {
  91. // 存取的實例不存在則發送錯誤異常
  92. throw new InvalidArgumentException( 如果" [{$name}] 不存在");
  93. }
  95. return self::$instances[$name];
  96. }
  98. /**
  99. * 新增資料庫
  100. *
  101. * 在實例群組中加入Connector
  102. *
  103. * @param string $name 識別名稱
  104. * @param string $driver 驅動名
  105. * @ param string $dsn 連接字串
  106. * @param string $usr 資料庫使用者名稱
  107. * @param string $pwd 資料庫密碼
  108. * @param bool $emulate 模擬預編譯查詢
  109. * @param bool $persisten 是否持久連接
  110. * /
  111. static public functiondetachAll()
  112. {
  113. foreach (self::$instances as $instance) {
  114. $instance->disconnect();
  115. }
  116. }
  117. }
  118. 🎜> /**
  119. * 取得 PHP Database Object
  120. *
  121. * @return PDO
  122. */
  123. 靜態公用函數登錄($name, $driver, $dsn, $usr, $pwd, $emulate = false, $persisten = false)
  124. {
  125. {
  126. if (isset(self::$instances[$name])) {
  127. // 如果新增的實例名已經存在則發送例外狀況
  128. throw new BadMethodCallException("[{$name}] 已註冊" );
  129. }
  131. // 實例化自身，並推入倉庫中
  132. self::$instances[$name] = new self();
  133. self:: $instances[ $name]->dsn = $driver 。 '：'。 $dsn;
  134. self::$instances[$name]->使用者名稱= $usr;
  135. self::$instances[$name]->password = $pwd;
  136. self::$ instances [$name]->driver = $driver;
  137. self::$instances[$name]->isPersisten = (bool)$persisten;
  138. self::$instances[$name]-> ;isEmulate = (bool)$emulate;
  139. }
  141. /**
  142. * 取得資料庫驅動名稱
  143. *
  144. * @return string
  145. */
  146. public function getPDO()
  147. {
  148. if (!$this-> pdo) {
  149. // 檢查PDO 是否已經實例化，否則先實例化PDO
  150. $this->pdo = new PDO($this->dsn, $this->username, $this- >password);
  151. // 錯誤模式為傳送PDOException 例外
  152. $this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  153. // 開啟查詢佇列
  154. $this->pdo->setAttribute->setAttribute->setAttribute->setAttribute->setAttribute->setAttrib 。 > }
  156. return $this->pdo;
  157. }
  159. /**
  160. * 開始事務
  161. * /
  162. public function getDriverName()
  163. {
  164. return $ this->driver;
  165. }
  167. /**
  168. * 提交交易
  169. */
  170. public function transationBegin()
  171. {
  172. $this->isInTransation = $this->getPDO( )->beginTransaction();
  173. }
  175. /**
  176. * 回滾事務
  177. * @return bool
  178. */
  179. public function transationCommit()
  180. {
  181. if ($this->isInTransation) {
  182. $this->getPDO()->commit();
  183. } else {
  184. trigger_error ('transationBegin 應該先於transationCommit 呼叫');
  185. }
  186. }
  189. /***/
  190. public function transationRollback()
  191. {
  192. if ( $this->isInTransation) {
  193. $this->getPDO()->rollBack();
  194. } else {
  195. trigger_error('transationBegin 應該先於transationRollback 呼叫');
  196. }
  197. }
  199. /**
  200. * 連線是否在交易中
  201. *
  202. * @return bool
  203. */
  204. public function isInTransation()
  205. {
  206. return $this->isInTransation;
  207. }
  209. /
  210. * 在交易中執行回呼函數
  211. *
  212. * @param function $callback 匿名函數或閉包函數
  213. * @param bool $autoRollback 異常發生時是否自動回滾
  214. * @param bool $autoRollback 異常發生時是否自動回滾
  215. * @ throws PDOException
  216. * @return bool
  217. */
  218. public function transationExecute($callback, $autoRollback = true)
  219. {
  220. try {
  221. // 開始交易
  222. $this->transationBegin();
  223. // 開始交易
  224. $this->transationBegin();
  225. / 呼叫回呼函數
  226. if (is_callable($callback)) {
  227. $callback();
  228. } else {
  229. throw new InvalidArgumentException('$callback應該為回呼函數}
  230. // 提交事務
  231. return $this->transationCommit();
  232. } catch(PDOException $pex) {
  233. // 如果開啟了自動回滾, 則捕捉到PDO 異常時先回滾再拋出
  234. if ($autoRollback) {
  235. $this->transationRollback();
  236. }
  237. throw $pex;
  238. }
  239. }
  242. /**
  243. * 安全地斷開資料庫連線
  244. */
  245. public function disconnect()
  246. {
  247. if ($this->pdo) {
  248. // 檢查PDO 是否已經實例化，是則設為null
  249. $this->pdo = null;
  250. }
  251. }
  253. /**
  254. * 阻止複製
  255. */
  256. public function __clone()
  257. {
trigger_error('被封鎖的__clone 方法, Connector 是單例類別');
}}


相關標籤：
超轻的 PHP 数据库工具包
來源：php.cn
上一篇：php 擴充sqlsrv呼叫mssql預存程序 下一篇：設定Mysql執行逾時時間
本網站聲明
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
作者最新文章
最新問題
MYSQL 查詢將列中的所有資料從一個資料庫複製到另一個資料庫 我不小心使用了OpencartSEO工具上的「生成描述」功能，它用產品標題覆蓋了我的所有產品描述。我有超過600種產品，重新全部重新製作會很痛苦。我有一個2個月前的MYSQL備份，...
來自於 2024-04-01 00:00:37
0
1
375
相關專題
更多>
熱門推薦
熱門教學
更多>
相關教學
熱門推薦
最新課程
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板