検索

ホームページ  >  記事  >  バックエンド開発  >  超軽量の PHP データベース ツールキット

超軽量の PHP データベース ツールキット

WBOY
WBOYオリジナル
2016-07-25 09:09:491916ブラウズ
2 日前に誕生した非常に軽い PHP データベース ツールキット (これは、非常に軽いことを証明するのに十分です) ）。
2 つのクラス、1 つは PDO 接続を管理する Connection (複数のデータベースをサポート)、もう 1 つはデータベース操作を迅速に実行するために使用される 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. PDO、ArrayObject、DateTimeを使用;
  3. LogicException、InvalidArgumentExceptionを使用;
  5. /**
  6. * クイッククエリチャンネル
  7. *
  8. * @version 0.3
  9. * @author tonyseek
  10. * @link http://stu.szu.edu.cn
  11. * @license http://www.opensource.org/licenses/mit- License.html
  12. * @copyright 深セン大学 StuCampus 開発チーム
  13. *
  14. */
  15. class QuickQueryはIteratorAggregateを実装します
  16. {
  17. /**
  18. * データベース接続
  19. *
  20. * @var PersistenceDbAccessConnection
  21. */
  22. private $connection = null;
  24. /**
  25. * PDO ステートメント
  26. *
  27. * @var PDOStatement
  28. */
  29. private $stmt = null;
  31. /**
  32. * チェックされたパラメータセット
  33. *
  34. * @var array
  35. */
  36. private $checkedParams = array();
  39. /* *
  40. * クエリチャネルを構築します
  41. *
  42. * @param PersistenceDbAccessConnection $connection データベース接続
  43. */
  44. public function __construct(Connection $connection)
  45. {
  46. $this->connection = $connection;
  47. }
  49. /**
  50. * プリコンパイルされた SQL ステートメント
  51. *
  52. * @param string $sqlCommand SQL ステートメント
  53. * @return PersistenceDbAccessQuickQuery
  54. */
  55. public function prepare($sqlCommand)
  56. {
  57. // 接続から PDO を取得し、SQL ステートメントで prepare を実行して PDO ステートメントを生成します
  58. $this->stmt = $this->connection->getPDO()->prepare($sqlCommand);
  59. // PDO ステートメントのモードを連想配列データに変更します
  60. $this->stmt->setFetchMode(PDO::FETCH_ASSOC);
  61. // メソッド チェーンを返す
  62. return $this;
  63. }
  65. /**
  66. * データクエリを実行します
  67. *
  68. * @throws PDOException
  69. * @return PersistenceDbAccessQuickQuery
  70. */
  71. public functionexecute($params = array())
  72. {
  73. $stmt = $this->getStatement();
  75. // パラメータチェック
  76. $diff = array_diff($this->checkedParams, array_keys( $params) );
  77. if (count($this->checkedParams) && count($diff)) {
  78. throw new InvalidArgumentException('必須パラメータがありません: '.implode(' | ', $diff));
  79. }
  81. // PHP データ型をデータベースのデータ型に対応させる
  82. foreach($params as $key => $value) {
  83. $type = null;
  84. switch(true) {
  85. case is_int($value):
  86. $type = PDO::PARAM_INT;
  87. ブレーク;
  88. case is_bool($value):
  89. $type = PDO::PARAM_BOOL;
  90. ブレーク;
  91. case ($value instanceof DateTime):
  92. $type = PDO::PARAM_STR; = $value->format(DateTime::W3C);
  93. ブレーク;
  94. case is_null($value):
  95. $type = PDO::PARAM_NULL;
  96. ブレーク;
  97. デフォルト:
  98. $type = PDO::PARAM_STR; }
  100. $stmt->bindValue($key, $value, $type);
  101. }
  103. $stmt->execute();
  104. $this->checkedParams = array(); // パラメータのチェックをクリアします。
  105. return $this;
  106. }
  108. /**
  109. * Get Statement オブジェクト
  110. *
  111. * 返されたオブジェクトは、バインドされたパラメーターを使用して再実行することも、データを走査して取得するための反復子として使用することもできます。
  112. *
  113. * @return PDOStatement
  114. */
  115. public function getStatement()
  116. {
  117. if (!$this->stmt) {
  118. throw new LogicException('SQL ステートメントは QuickQuery.prepare である必要があります最初の前処理');
  119. }
  121. return $this->stmt;
  122. }
  124. /**
  125. * getStatement メソッドの代替名
  126. *
  127. * PHP 標準ライブラリに IteratorAggregate インターフェイスを実装し、外部関係者はこのオブジェクトを反復子として直接使用して
  128. * を走査できます。 getStatment との唯一の違いは、このメソッドが LogicException をスローしないことです。
  129. * prepare とexecute が事前に使用されていない場合は、空のイテレータが返されます。
  130. *
  131. * @return Traversable
  132. */
  133. public function getIterator()
  134. {
  135. try {
  136. return $this->getStatement() ;
  137. } catch (LogicException $ex) {
  138. return new ArrayObject();
  139. }
  140. }
  142. /**
  143. * クエリ パラメータの設定 check
  144. *
  145. * ここにインポートされたクエリ パラメータをチェックし、割り当てられていない場合は、LogicException が発生します。クエリ中にスローされます。
  146. *
  147. * @param array $params
  148. * @return PersistenceDbAccessQuickQuery
  149. */
  150. public function setParamsCheck(array $params)
  151. {
  152. $this->checkedParams = $params;
  154. return $this;
  155. }
  157. / **
  158. * 結果セットを配列に変換します
  159. *
  160. * @return array
  161. */
  162. public function toArray()
  163. {
  164. return iterator_to_array($this->getStatement());
  165. }
  167. /**
  168. * 最後に挿入された結果 (またはシーケンス) の ID を取得します
  169. *
  170. * @param string $name
  171. * @return int
  172. */
  173. public function getLastInsertId($name=null) )
  174. {
  175. return $this->connection->getPDO()->lastInsertId($name);
  176. }
  177. }
复制代
  1. namespace PersistenceDbAccess;
  2. use InvalidArgumentException、BadMethodCallException;
  3. use PDO、PDOException;
  5. /**
  6. * 接続ファクトリー、グローバル PDO オブジェクトを提供し、トランザクションを管理します。
  7. *
  8. * @version 0.3
  9. * @author tonyseek
  10. * @link http://stu.szu.edu.cn
  11. * @license http://www.opensource.org/licenses/mit-license.html
  12. * @copyright 深セン大学 StuCampus 開発チーム
  13. *
  14. */
  15. 最終クラス Connection
  16. {
  17. /**
  18. * コネクタ インスタンス コレクション
  19. *
  20. * @var array
  21. */
  22. static private $instances = array();
  24. /**
  25. * データベースドライバー名
  26. *
  27. * @var string
  28. */
  29. private $driver = '';
  31. /**
  32. * データベース接続文字列 (データベース ソース名)
  33. *
  34. * @var string
  35. */
  36. プライベート $dsn = '';
  38. /**
  39. * PDO インスタンス
  40. *
  41. * @var PDO
  42. */
  43. プライベート $pdo = null;
  45. /**
  46. * ユーザー名
  47. *
  48. * @var 文字列
  49. * /
  50. private $username = '';
  52. /**
  53. * パスワード
  54. *
  55. * @var 文字列
  56. */
  57. private $password = '';
  59. /**
  60. * 永続的な接続を有効にするかどうか
  61. *
  62. * @var bool
  63. */
  64. private $isPersisten = false;
  66. /**
  67. * シミュレーションのプリコンパイルを有効にするかどうか
  68. *
  69. * @var bool
  70. */
  71. private $isEmulate = false;
  73. /**
  74. * トランザクション中かどうか
  75. *
  76. * @var bool
  77. */
  78. private $isInTransation = false;
  80. /**
  81. * プライベート コンストラクター、new 演算子を使用した外部インスタンス化を防止します
  82. */
  83. プライベート関数 __construct(){}
  85. /* *
  86. * Production Connector インスタンス (複数のインスタンス)
  87. *
  88. * @param string $name
  89. * @return StuCampusDataModelConnector
  90. */
  91. static public function getInstance($name = 'default')
  92. {
  93. if (!isset(self::$instances[$name])) {
  94. // アクセスされたインスタンスが存在しない場合はスローされますエラーが発生しました
  95. throw new InvalidArgumentException("[{$name}] が存在しません");
  96. }
  98. return self::$instances[$name];
  99. }
  101. /**
  102. * すべてのデータベースインスタンスを切断します
  103. */
  104. static public functiondetachAll()
  105. {
  106. foreach (self::$instances as $instance) {
  107. $instance->disconnect();
  108. }
  109. }
  111. /**
  112. * データベースを追加
  113. *
  114. * コネクタをインスタンス グループに追加
  115. *
  116. * @param string $name 識別名
  117. * @param string $driver ドライバー名
  118. * @param string $dsn 接続文字列
  119. * @param string $usrデータベースのユーザー名
  120. * @param string $pwd データベースのパスワード
  121. * @param bool $emulate シミュレーションのプリコンパイルされたクエリ
  122. * @param bool $persisten 接続を維持するかどうか
  123. */
  124. static public function registry( $ name, $driver, $dsn, $usr, $pwd, $emulate = false, $persisten = false)
  125. {
  126. if (isset(self::$instances[$name])) {
  127. // 追加された場合インスタンス名がすでに存在する場合、例外がスローされます
  128. throw new BadMethodCallException("[{$name}] が登録されました");
  129. }
  131. // 自身をインスタンス化し、配列にプッシュします
  132. self::$instances [$name] = 新しい self();
  133. self::$instances[$name]->dsn = $driver . $dsn;
  134. self::$instances[$name]->username = $usr;
  135. self::$instances[$name]->パスワード = $pwd;
  136. self::$instances[$name]->driver = $driver;
  137. self::$instances[$name]- >isPersisten = (bool)$persisten;
  138. self::$instances[$name]->isEmulate = (bool)$emulate;
  139. }
  141. /**
  142. * PHP データベース オブジェクトを取得します
  143. *
  144. * @return PDO
  145. */
  146. public function getPDO()
  147. {
  148. if ( !$this->pdo) {
  149. // PDO がインスタンス化されているかどうかを確認し、そうでない場合は最初に PDO をインスタンス化します
  150. $this->pdo = new PDO($this->dsn, $this->gt; username, $ this->password);
  151. // エラー モードは PDOException 例外をスローします
  152. $this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  153. // クエリを有効にするキャッシュ
  154. $this->pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, $this->isEmulate);
  155. // 永続的な接続を有効にする
  156. $this->pdo->setAttribute(PDO::ATTR_PERSISTENT, $ this->isPersisten );
  158. }
  160. return $this->pdo;
  161. }
  163. /**
  164. * データベースドライバー名を取得します
  165. *
  166. * @return string
  167. */
  168. public function getDriverName()
  169. {
  170. return $this->gt;driver;
  171. }
  173. /* *
  174. * 取引を開始します
  175. */
  176. public function translationBegin()
  177. {
  178. $this->isInTransation = $this->getPDO()->beginTransaction();
  179. }
  181. /**
  182. * トランザクションを送信する
  183. */
  184. public function transationCommit()
  185. {
  186. if ($this->isInTransation) {
  187. $this->getPDO()->commit();
  188. } else {
  189. trigger_error('transationBegin は次のようになります) transationCommit') ;
  190. }
  191. }
  193. /**
  194. * トランザクションのロールバック
  195. * @return bool
  196. */
  197. public function translationRollback()
  198. {
  199. if ($this->isInTransation) {
  200. $this->getPDO()-> ;rollBack();
  201. } else {
  202. trigger_error('transationRollbackの前にtransationBeginを呼び出す必要があります');
  203. }
  204. }
  206. /**
  207. * 接続がトランザクション内にあるかどうか
  208. *
  209. * @return bool
  210. */
  211. public function isInTransation()
  212. {
  213. return $this->isInTransation;
  214. }
  216. /**
  217. * トランザクション内でコールバック関数を実行します
  218. *
  219. * @param function $callback匿名関数またはクロージャ関数
  220. * @param bool $autoRollback 例外発生時に自動的にロールバックするかどうか
  221. * @throws PDOException
  222. * @return bool
  223. */
  224. public function transationExecute($callback, $autoRollback = true)
  225. {
  226. try {
  227. // トランザクションを開始
  228. $this->transationBegin();
  229. // コールバック関数を呼び出す
  230. if (is_callable($callback)) {
  231. $callback();
  232. } else {
  233. throw new InvalidArgumentException('$callback はコールバック関数である必要があります');
  234. }
  235. // トランザクションをコミットします
  236. return $this->transationCommit();
  237. } catch(PDOException $pex) {
  238. // 自動ロールバックが有効な場合, 次に、PDO 例外をキャッチするときに、最初にロールバックしてからスローします
  239. if ($autoRollback) {
  240. $this->transationRollback();
  241. }
  242. throw $pex;
  243. }
  244. }
  246. /**
  247. * データベースから安全に切断します
  248. */
  249. public functiondetach()
  250. {
  251. if ($this->pdo) {
  252. // PDO がインスタンス化されているかどうかを確認し、インスタンス化されている場合は null に設定します
  253. $this->pdo = null;
  254. }
  255. }
  257. /**
  258. * ブロッククローン
  259. */
  260. public function __clone()
  261. {
  262. trigger_error('ブロックされた__cloneメソッド、コネクタはシングルトンクラス');
  263. }
  264. }
コードをコピー


声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：PHP は sqlsrv を拡張して mssql ストアド プロシージャを呼び出す次の記事：PHP は sqlsrv を拡張して mssql ストアド プロシージャを呼び出す

関連記事

続きを見る