コミュニティ 学ぶ ツールライブラリ レジャー
検索
日本語
ホームページ > バックエンド開発 > PHPチュートリアル > php pdoデータベース操作のカプセル化クラスコード

php pdoデータベース操作のカプセル化クラスコード

WBOY
リリース： 2016-07-25 08:51:52
オリジナル
1081 人が閲覧しました

  3. /**

  4. * データベース PDO 操作
  5. */
  6. class MysqlPdo {
  7. public static $PDOStatement = null;
  8. /**
  9. * データベース接続パラメータの設定
  10. * @var array
  11. * @access public
  12. */
  13. public static $config = array();
  14. /**
  15. * 永続接続を使用するかどうか
  16. * @var bool
  17. * @access public
  18. */
  19. public static $pconnect = false;
  20. /**
  21. * エラーメッセージ
  22. * @var string
  23. * @access public
  24. */
  25. public static $error = '';
  26. /**
  27. * シングルトン モード、Pdo クラスの唯一のインスタンスとデータベースの接続リソースを保存します
  28. * @var object
  29. * @access public
  30. */
  31. protected static $link;
  32. /**
  33. * データベースが接続されているかどうか
  34. * @var bool
  35. * @access public
  36. */
  37. public static $connected = false;
  38. /**
  39. * データベースのバージョン
  40. * @var string
  41. * @access public
  42. */
  43. public static $dbVersion = null;
  44. /**
  45. * 現在の SQL ステートメント
  46. * @var string
  47. * @access public
  48. */
  49. public static $queryStr = '';
  50. /**
  51. * 最後に挿入されたレコードの ID
  52. * @var integer
  53. * @access public
  54. */
  55. public static $lastInsertId = null;
  56. /**
  57. * 影響を受けるレコードの数を返します
  58. * @var integer
  59. * @access public
  60. */
  61. public static $numRows = 0;
  62. // トランザクション命令の数
  63. public static $ transTimes = 0;
  64. /**
  65. * コンストラクター、
  66. * @param $dbconfig データベース接続関連情報、array('ServerName', 'UserName', 'Password', 'DefaultDb', 'DB_Port', 'DB_TYPE')
  67. */
  68. public function __construct($dbConfig=''){
  69. if (!class_exists('PDO')) self::throw_Exception("サポートされていません: PDO");
  70. //パラメータが送信されない場合、デフォルトのデータ定義が使用されます
  71. if (!is_array($dbConfig)) {
  72. $dbConfig = array(
  73. 'hostname' => DB_HOST,
  74. 'username' => DB_USER,
  75. 'パスワード' =>
  76. 'データベース' => DB_PORT,
  77. 'dbms' => . DB_HOST.";dbname=".DB_NAME
  78. );
  79. }
  80. if(empty($dbConfig['hostname'])) self::throw_Exception("データベース構成が定義されていません");
  81. self::$config = $ dbConfig ;
  82. if(empty(self::$config['params'])) self::$config['params'] = array();
  83. /***************************************ゴージャスな仕切り************ *****************************/
  84. if (!isset(self) : :$link) ) {
  85. $configs = self::$config;
  86. if(self::$pconnect) {
  87. $configs['params'][constant('PDO::ATTR_PERSISTENT')] = true;
  89. try {
  90. self::$link = new PDO( $configs['dsn'], $configs['username'], $configs['password'],$configs['params']);
  91. } catch ( PDOException $e) {
  92. self::throw_Exception($e->getMessage());
  93. }
  94. if(!self::$link) {
  95. self::throw_Exception('PDO CONNECT ERROR');
  96. return false ;
  97. }
  98. self::$link->exec('SET NAMES '.DB_CHARSET);
  99. self::$dbVersion = self::$link->getAttribute(constant("PDO::ATTR_SERVER_INFO")) ;
  100. // 接続に成功をマークします
  101. self::$connected = true;
  102. // データベース接続構成情報をログアウトします
  103. unset($configs);
  104. }
  105. return self::$link;
  106. }
  107. /**
  108. * クエリ結果を公開
  109. * @access関数
  110. * /
  111. static function free() {
  112. self::$PDOStatement = null;
  113. }
  114. /************************/
  115. /* データベース操作*/
  116. /************************/
  117. / **
  118. * すべてのクエリデータを取得します
  119. * @access 関数
  120. * @return 配列
  121. */
  122. static function getAll($sql=null) {
  123. if($sql != null)
  124. {
  125. self::query($sql);
  126. }
  127. //データセットを返す
  128. $ result = self:: $PDOStatement->fetchAll(constant('PDO::FETCH_ASSOC'));
  129. return $result;
  130. }
  131. /**
  132. * クエリ結果の取得
  133. * @access 関数
  134. * @param string $sql SQL コマンド
  135. * @param integer $seek ポインタ位置
  136. * @return array
  137. */
  138. static function getRow($sql=null) {
  139. if($sql != null)
  140. {
  141. self::query($sql);
  142. }
  143. // 配列セットを返す
  144. $result = self::$PDOStatement->fetch(constant('PDO::FETCH_ASSOC) '),constant( 'PDO::FETCH_ORI_NEXT'));
  145. return $result;
  146. }
  147. /**
  148. * SQL ステートメントを実行し、クエリまたは操作を自動的に判断します
  149. * @access 関数
  150. * @param string $sql SQL コマンド
  151. * @return 混合
  152. */
  153. 静的関数 doSql($sql='') {
  154. if(self::isMainIps( $sql)) {
  155. return self::execute($sql);
  156. }else {
  157. return self::getAll($sql);
  158. }
  159. }
  160. /**
  161. * 指定された ID に基づいてテーブル内のレコードを検索します (単一テーブル操作の場合のみ)
  162. * @access 関数
  163. * @param integer $priId 主キー ID
  164. * @param string $tables データテーブル名
  165. * @param string $フィールド フィールド名
  166. * @return ArrayObject テーブル レコード
  167. */
  168. static function findById($ tabName,$priId, $fields='*'){
  169. $sql = 'SELECT %s FROM %s WHERE id=%d';
  170. return self::getRow(sprintf($sql, self::parseFields($fields) )、$tabName、$priId));
  171. }
  172. /**
  173. * レコード検索
  174. * @access関数
  175. * @param string $tables データテーブル名
  176. * @parammixed $where クエリ条件
  177. * @param string $fields フィールド名
  178. * @param string $order Sort
  179. * @param string $limit 取得するデータの個数
  180. * @param string $group グループ化
  181. * @param string $having
  182. * @param boolean $lock ロックするか否か
  183. * @return ArrayObject
  184. */
  185. 静的関数 find($tables,$where="",$fields='*',$order=null,$limit=null,$group=null,$having=null) {
  186. $sql = 'SELECT '.self::parseFields($fields)
  187. .' FROM '.$tables
  188. .self::parseWhere($where)
  189. .self::parseGroup($group)
  190. .self::parseHaving($having)
  191. .self::parseOrder($order)
  192. .self:: parseLimit($limit);
  193. $dataAll = self::getAll($sql);
  194. if(count($dataAll)==1){$rlt=$dataAll[0];}else{$rlt=$dataAll; }
  195. return $rlt;
  196. }
  197. /**
  198. * (単一) レコードを挿入します
  199. * @access 関数
  200. * @param 混合 $data データ
  201. * @param string $table データ テーブル名
  202. * @return false |*/
  203. function add($data,$table) {
  204. //过滤提交数据
  205. $data=self::filterPost($table,$data);
  206. foreach ($data as $key=>$val){
  207. if(is_array($val) && strto lower($val[0]) == 'exp') {
  208. $val = $val[1]; // 表达式を使用します ???
  209. }elseif (is_scalar($val)){
  210. $val = self::fieldFormat($val);
  211. }else{
  212. // 去掉复合对象
  213. continue;
  214. }
  215. $data [$key] = $val;
  216. }
  217. $fields = array_keys($data);
  218. array_walk($fields, array($this, 'addSpecialChar'));
  219. $fieldsStr = implode(',', $fields);
  220. $values = array_values($data);
  221. $valuesStr = implode(',', $values);
  222. $sql = 'INSERT INTO '.$table.' ('.$fieldsStr.') VALUES ('.$valuesStr.')';
  223. return self::execute($sql);
  224. }
  225. /**
  226. * レコード更新
  227. * @access関数
  228. * @parammixed $sets data
  229. * @param string $table データテーブル名
  230. * @param string $where更新条件
  231. * @param string $limit
  232. * @param string $order
  233. * @return false
  234. */
  235. static function update($sets,$ table,$where,$limit=0,$order='') {
  236. $sets = self::filterPost($table,$sets);
  237. $sql = 'UPDATE '.$table.' SET '.self::parseSets($sets).self::parseWhere($where).self::parseOrder($order).self::parseLimit($limit);
  238. return self::execute($sql);
  239. }
  240. /**
  241. * 特定のフィールドの値を保存します
  242. * @access関数
  243. * @param string $field 保存するフィールドの名前
  244. * @param string $value フィールドの値
  245. * @param string $table データテーブル
  246. * @ param string $where 保存条件
  247. * @param boolean $asString フィールド値が文字列かどうか
  248. * @return void
  249. */
  250. static function setField($field, $value, $table, $condition="", $asString=false) {
  251. // 如果有'(' 参照 SQL命令更新if(false === strpos($value,'(') || $asString) $value = '"'.$value.'"';
  252. $sql = 'UPDATE ' .$table.' SET '.$field.'='.$value.self::parseWhere($condition);
  253. return self::execute($sql);
  254. }
  255. /**
  256. * レコードを削除します
  257. * @access 関数
  258. * @parammixed $where は条件付きマップ、配列、または文字列です
  259. * @param string $table データテーブル名
  260. * @param string $limit
  261. * @param string $order
  262. * @ false を返します |*/
  263. 静的関数の削除($where,$table,$limit='',$order='') {
  264. $sql = 'DELETE FROM '.$table.self::parseWhere($where).self::parseOrder($ order).self::parseLimit($limit);
  265. return self::execute($sql);
  266. }
  267. /**
  268. +------------------------------------------------ ----------
  269. * データの変更または保存（単一テーブル操作のみ）
  270. * 主キーIDがある場合は変更、主キーIDがない場合は追加
  271. *修正記録:
  272. +---- -------------------------------------- --------- ----
  273. * @アクセス機能
  274. +---------------------------- --------- -------------------
  275. * @param $tabName テーブル名
  276. * @param $aPost $_POST でフォームを送信
  277. * @param $priId 主キー ID
  278. * @param $aNot 除外されるフィールドまたは配列
  279. * @param $aCustom データベースに追加され、保存されるカスタマイズされた配列
  280. * @param $isExits すでに存在するかどうか: true、存在しません: false
  281. +----- -------------------------------------- ------------ ---
  282. * @return Boolean 変更または保存が成功したかどうか
  283. +--------------------- ------------------------------------------
  284. */
  285. function saveOrUpdate($tabName, $aPost, $priId="", $aNot="", $aCustom="", $isExits=false) {
  286. if(empty($tabName) || !is_array($aPost) || is_int($aNot)) return false;
  287. if(is_string( $aNot) && !empty($aNot)) $aNot = array($aNot);
  288. if(is_array($aNot) && is_int(key($aNot))) $aPost = array_diff_key($aPost, array_flip($aNot) ));
  289. if(is_array($aCustom) && is_string(key($aCustom))) $aPost = array_merge($aPost,$aCustom);
  290. if (empty($priId) && !$isExits) { //新增
  291. $a​​Post = array_filter($aPost, array($this, 'removeEmpty'));
  292. return self::add($aPost, $tabName);
  293. }else { //修改
  294. return self::update($aPost, $tabName, "id=".$priId);
  295. }
  296. }
  297. /**
  298. * 最新のクエリの SQL ステートメントを取得します
  299. * @access function
  300. * @param
  301. * @return String 実行された SQL
  302. */
  303. static function getLastSql() {
  304. $link = self::$link;
  305. if ( !$link ) return false;
  306. return self::$queryStr;
  307. }
  308. /**
  309. * 最後に挿入された ID を取得します
  310. * @access function
  311. * @param
  312. * @return integer 最後に挿入されたデータ ID
  313. */
  314. static function getLastInsId(){
  315. $link = self:: $link;
  316. if ( !$link ) return false;
  317. return self::$lastInsertId;
  318. }
  319. /**
  320. * DB バージョンの取得
  321. * @access 関数
  322. * @param
  323. * @return string
  324. */
  325. static function getDbVersion(){
  326. $link = self::$link;
  327. if ( !$link ) return false;
  328. return self::$dbVersion;
  329. }
  330. /**
  331. * データベーステーブル情報を取得します
  332. * @access関数
  333. * @return array
  334. */
  335. static function getTables() {
  336. $info = array();
  337. if(self::query ("SHOW TABLES")) {
  338. $result = self::getAll();
  339. foreach ($result as $key => $val) {
  340. $info[$key] = current($val);
  341. }
  342. }
  343. return $info;
  344. }
  345. /**
  346. * データテーブルのフィールド情報を取得
  347. * @access関数
  348. * @return array
  349. */
  350. static function getFields($tableName) {
  351. // 获取数据库联接
  352. $link = self::$link;
  353. $sql = "SELECT
  354. ORDINAL_POSITION 、COLUMN_NAME、COLUMN_TYPE、DATA_TYPE、
  355. IF(ISNULL(CHARACTER_MAXIMUM_LENGTH)、(NUMERIC_PRECISION + NUMERIC_SCALE)、CHARACTER_MAXIMUM_LENGTH) AS MAXCHAR、
  356. IS_NULLABLE、COLUMN_DEFAULT、COLUMN_KEY、EXTRA、 _COMMENT
  357. FROM
  358. INFORMATION_SCHEMA.COLUMNS
  359. WHERE
  360. TABLE_NAME = :tabName AND TABLE_SCHEMA='".DB_NAME."'";
  361. self::$queryStr = sprintf($sql, $tableName);
  362. $sth = $link->prepare($sql);
  363. $sth->bindParam (':tabName', $tableName);
  364. $sth->execute();
  365. $result = $sth->fetchAll(constant('PDO::FETCH_ASSOC'));
  366. $info = array();
  367. foreach ($result as $key => $val) {
  368. $info[$val['COLUMN_NAME']] = array(
  369. 'postion' => $val['ORDINAL_POSITION'],
  370. 'name' => $val['COLUMN_NAME'],
  371. 'type' => $val['COLUMN_TYPE'],
  372. 'd_type' => $val['DATA_TYPE'],
  373. 'length' => $val['MAXCHAR'],
  374. 'notnull' => ; (strto lower($val['IS_NULLABLE']) == "いいえ"),
  375. 'default' => $val['COLUMN_DEFAULT'],
  376. 'primary' => ]) == 'pri'),
  377. 'autoInc' => (strto lower($val['EXTRA']) == 'auto_increment'),
  378. 'comment' => $val['COLUMN_COMMENT']
  379. ) ;
  380. }
  381. // 有错误则抛出异常
  382. self::haveErrorThrowException();
  383. return $info;
  384. }
  385. /**
  386. * データベースを閉じる
  387. * @access 関数
  388. */
  389. static function close() {
  390. self::$link = null;
  391. }
  392. /**
  393. * SQL コマンドのセキュリティ フィルタリング
  394. * @access 関数
  395. * @param string $str SQL コマンド
  396. * @return string
  397. */
  398. static functionscape_string($str) {
  399. returnaddslashes($str);
  400. }
  401. /************************/
  402. /* 内部操作方法 */
  403. /************************/
  404. /**
  405. * エラーがある場合は例外がスローされます
  406. * @access 関数
  407. * @return
  408. */
  409. 静的関数 haveErrorThrowException() {
  410. $obj = empty(self::$PDOStatement) ? self::$link : self::$PDOStatement;
  411. $arrError = $obj->errorInfo();
  412. if($arrError[0] !== '00000') { // 有错误情報
  413. self:: $error = $arrError[0]."|".$arrError[2]。 "
    [ SQL ] : ".self::$queryStr."
    ";
  414. self::throw_Exception(self::$error);
  415. return false;
  416. }
  417. //主要针对execute() メソッド抛出异常
  418. if(self::$queryStr=='')self::throw_Exception('クエリは空でした

    [ SQL语句 ] :');
  419. }
  420. /**
  421. * where 分析
  422. * @access 関数
  423. * @param 混合 $where クエリ条件
  424. * @return string
  425. */
  426. 静的関数 parseWhere($where) {
  427. $whereStr = '';
  428. if(is_string($where) || is_null($where)) {
  429. $whereStr = $where ;
  430. }
  431. return empty($whereStr)?'':' WHERE '.$whereStr;
  432. }
  433. /**
  434. * 順序分析
  435. * @access 関数
  436. * @param 混合 $order ソート
  437. * @return string
  438. */
  439. 静的関数 parseOrder($order) {
  440. $orderStr = '';
  441. if (is_array($order))
  442. $orderStr .= ' ORDER BY '.implode(',', $order);
  443. else if(is_string($order) && !empty($order))
  444. $orderStr .= ' ORDER BY '.$order;
  445. return $orderStr;
  446. }
  447. /**
  448. * 制限分析
  449. * @access 関数
  450. * @param string $limit
  451. * @return string
  452. */
  453. 静的関数 parseLimit($limit) {
  454. $limitStr = '';
  455. if(is_array($limit)) {
  456. if(count($limit)>1)
  457. $limitStr .= ' LIMIT '.$limit[0].' 、「.$limit[1].」 ';
  458. else
  459. $limitStr .= ' LIMIT '.$limit[0].' ';
  460. } else if(is_string($limit) && !empty($limit)) {
  461. $limitStr .= ' LIMIT '.$limit.' ';
  462. }
  463. $limitStr;
  464. を返す
  465. /**
  466. * グループ分析
  467. * @access 関数
  468. * @parammixed $group
  469. * @return string
  470. */
  471. 静的関数 parseGroup($group) {
  472. $groupStr = '';
  473. if(is_array($group))
  474. $groupStr .= ' GROUP BY '.implode(',', $group);
  475. else if(is_string($group) && !empty($group))
  476. $groupStr .= ' GROUP BY '.$group;
  477. return empty($groupStr)?'':$groupStr;
  478. }
  479. /**
  480. * 分析を持っています
  481. * @access 関数
  482. * @param string $having
  483. * @return string
  484. */
  485. 静的関数 parseHaving($having) {
  486. $havingStr = '';
  487. if(is_string($having) && !empty($having))
  488. $havingStr .= ' HAVING '。 $having;
  489. return $havingStr;
  490. }
  491. /**
  492. * フィールド分析
  493. * @access 関数
  494. * @parammixed $fields
  495. * @return string
  496. */
  497. function parseFields($fields) {
  498. if(is_array($fields)) {
  499. array_walk($fields, array($this, 'addSpecialChar) '));
  500. $fieldsStr = implode(',', $fields);
  501. }else if(is_string($fields) && !empty($fields)) {
  502. if( false === strpos($fields,' `') ) {
  503. $fields =explode(',',$fields);
  504. array_walk($fields, array($this, 'addSpecialChar'));
  505. $fieldsStr = implode(',', $fields);
  506. }else {
  507. $fieldsStr = $fields;
  508. }
  509. }else $fieldsStr = '*';
  510. return $fieldsStr;
  511. }
  512. /**
  513. * データ更新時に呼び出される分析を設定します
  514. * @access 関数
  515. * @parammixed $values
  516. * @return string
  517. */
  518. プライベート関数 parseSets($sets) {
  519. $ setStr = '';
  520. if(is_array($sets)){
  521. foreach ($sets as $key=>$val){
  522. $key = self::addSpecialChar($key);
  523. $val = self:: fieldFormat($val);
  524. $setsStr .= "$key = ".$val.",";
  525. }
  526. $setsStr = substr($setsStr,0,-1);
  527. }else if(is_string($sets) )) {
  528. $setsStr = $sets;
  529. }
  530. return $setsStr;
  531. }
  532. /**
  533. * フィールドの書式設定
  534. * @access 関数
  535. * @parammixed $value
  536. * @returnmixed
  537. */
  538. 静的関数 fieldFormat(&$value) {
  539. if(is_int($value)) {
  540. $ value = intval($value);
  541. } else if(is_float($value)) {
  542. $value = floatval($value);
  543. } elseif(preg_match('/^(w*(+|-|*|/ )?w*)$/i',$value)){
  544. // 在字段の值里面直接使用をサポート
  545. // 例 (score+1) (name) 必须包含号
  546. $value = $value;
  547. }else if(is_string($value)) {
  548. $value = '''.self::escape_string($value).''';
  549. }
  550. return $value;
  551. }
  552. /**
  553. * フィールド名とテーブル名に ` を追加すると、命令内でキーワードを使用するときにエラーが発生しないようにするための
  554. * に準拠します。
  555. * @access 関数
  556. * @parammixed $value
  557. * @returnmixed
  558. * /
  559. 静的関数 addSpecialChar(&$value) {
  560. if( '*' == $value || false !== strpos($value,'(') || false !== strpos($value,'.') || false !== strpos($value,'`')) {
  561. //如果包含* または使用了sqlメソッド则不作处理
  562. } elseif(false === strpos($value,'`') ) {
  563. $value = '`'.trim($value).'`';
  564. }
  565. return $value;
  566. }
  567. /**
  568. +------------------------------------------------ ----------
  569. * 空の要素を削除します
  570. +--------------------------------- -----------------------------
  571. * @アクセス機能
  572. +-------------- ---- --------------------------------------
  573. * @param 混合$値
  574. +- ---------------------------------------------- ---- -------
  575. * @return 混合
  576. +-------------------------------- ---- -----------------------
  577. */
  578. static function RemoveEmpty($value){
  579. return !empty($value);
  580. }
  581. /**
  582. * SELECT、SHOWなどの命令を中心にクエリを実行
  583. * @access関数
  584. * @param string $sql SQL命令
  585. * @returnmixed
  586. */
  587. static function query($sql ='') {
  588. // 获取数据库联接
  589. $link = self::$link;
  590. if ( !$link ) return false;
  591. self::$queryStr = $sql;
  592. //释放前回の查询結果
  593. if ( !empty(self::$PDOStatement) ) self::free();
  594. self::$PDOStatement = $link->prepare(self::$queryStr);
  595. $bol = self::$PDOStatement ->execute();
  596. // 有错误则抛出异常
  597. self::haveErrorThrowException();
  598. return $bol;
  599. }
  600. /**
  601. * データベース操作方法
  602. * @access関数
  603. * @param string $sql実行文
  604. * @param boolean $lock ロックするかどうか（デフォルトはロックなし）
  605. * @return void
  606. public functionexecute($sql='') ,$ lock=false) {
  607. if(empty($sql)) $sql = $this->queryStr;
  608. return $this->execute($sql);*/
  609. /**
  610. * INSERT、UPDATE、DELETE の実行ステートメント
  611. * @access 関数
  612. * @param string $sql SQL コマンド
  613. * @return integer
  614. */
  615. static functionexecute($sql='') {
  616. // 获取数据库联接
  617. $link = self::$link;
  618. if ( !$link ) return false;
  619. self::$queryStr = $sql;
  620. //释放前次的查询結果
  621. if ( !empty(self::$PDOStatement) ) self::free();
  622. $result = $link->exec(self::$queryStr);
  623. // 有错误则抛出异常
  624. self::haveErrorThrowException();
  625. if ( false === $result) {
  626. return false;
  627. } else {
  628. self::$numRows = $result;
  629. self::$lastInsertId = $link- >lastInsertId();
  630. return self::$numRows;
  631. }
  632. }
  633. /**
  634. * データベース変更操作かどうか
  635. * @access private
  636. * @param string $query SQL コマンド
  637. * @return boolen クエリ操作の場合は false を返す
  638. */
  639. 静的関数 isMainIps($query) {
  640. $queryIps = 'INSERT|UPDATE|DELETE|REPLACE|CREATE|DROP|LOAD DATA|SELECT .* INTO|COPY|ALTER|GRANT|REVOKE |LOCK|UNLOCK';
  641. if (preg_match('/^s*"?(' . $queryIps . ')s+/i', $query)) {
  642. return true;
  643. }
  644. return false;
  645. }
  646. / **
  647. * POST 送信データをフィルターします
  648. * @access private
  649. * @parammixed $data POST 送信データ
  650. * @param string $table データテーブル名
  651. * @returnmixed$newdata
  652. */
  653. 静的関数 filterPost($table,$data) {
  654. $table_column = self::getFields($table);
  655. $newdata=array();
  656. foreach ($table_column as $key=>) ;$val){
  657. if(array_key_exists($key,$data) && ($data[$key])!==''){
  658. $newdata[$key] = $data[$key];
  659. }
  660. }
  661. return $newdata;
  662. }
  663. /**
  664. * トランザクションを開始します
  665. * @access 関数
  666. * @return void
  667. */
  668. static function startTrans() {
  669. //データロールバックサポート
  670. $link = self::$link;
  671. if ( !$link ) return false;
  672. if (self::$transTimes == 0) {
  673. $link->beginTransaction();
  674. }
  675. self::$transTimes++;
  676. return ;
  677. }
  678. /**
  679. * 非自動送信ステータスでのクエリの送信に使用されます
  680. * @access 関数
  681. * @return boolen
  682. */
  683. 静的関数コミット() {
  684. $link = self::$link;
  685. if ( !$link ) return false;
  686. if (self::$transTimes > 0) {
  687. $result = $link->commit();
  688. self::$transTimes = 0;
  689. if(!$result){
  690. self::throw_Exception(self::$error());
  691. return false;
  692. }
  693. }
  694. return true;
  695. }
  696. /**
  697. * トランザクションのロールバック
  698. * @access 関数
  699. * @return boolen
  700. */
  701. public function rollback() {
  702. $link = self::$link;
  703. if ( !$link ) return false;
  704. if (self::$transTimes > 0) {
  705. $result = $link->rollback();
  706. self::$transTimes = 0;
  707. if(!$result){
  708. self::throw_Exception(self::$error());
  709. return false;
  710. }
  711. }
  712. return true;
  713. }

  714. /**

  715. * エラー処理
  716. * @access 関数
  717. * @return void
  718. */
  719. static function throw_Exception($err){
  720. echo '
    エラー:'.$err.'
  721. }
  722. }

复制代


関連ラベル：
php pdo数据库操作封装类代码
ソース：php.cn
前の記事：ITチュートリアルの共有~! PHP/Linux/html/JS/モバイル ゲーム開発/MySQL/などのチュートリアル 次の記事：PHP 画像透かしクラス、PHP は画像に透かし関数コードを追加します
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
著者別の最新記事
最新の問題
function_exists() はカスタム関数を決定できません Function test () {return true;} if (function_exists ('test')) {echo "テストは関数です";
から 2024-04-29 11:01:01
0
3
2042
Google Chromeのモバイル版を表示する方法 こんにちは、先生、Google Chrome をモバイル版に変更するにはどうすればよいですか?
から 2024-04-23 00:22:19
0
11
2201
子ウィンドウは親ウィンドウを操作しますが、出力は応答しません。 最初の 2 つの文は実行可能ですが、最後の文は実装できません。
から 2024-04-19 15:37:47
0
1
1858
親ウィンドウには出力がありません document.onclick = function(){ window.opener.document.write('私は子ウィンドウの出力です');
から 2024-04-18 23:52:34
0
1
1745
CSS マインド マッピングに関するコースウェアはどこにありますか? コースウェア
から 2024-04-16 10:10:18
0
0
1766
関連トピック
詳細>
人気のおすすめ
人気のチュートリアル
詳細>
関連するチュートリアル
人気のおすすめ
最新のコース
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート