source: branches/version-2_11-dev/data/class/SC_Query.php @ 21371

Revision 21371, 32.5 KB checked in by Seasoft, 15 years ago (diff)

#1581 (SC_Query の一部メソッドで prepared query を開放せずメモリリーク)
  • Property svn:eol-style set to LF
  • Property svn:keywords set to Id
  • Property svn:mime-type set to text/x-httpd-php; charset=UTF-8
Line 
1<?php
2/*
3 * This file is part of EC-CUBE
4 *
5 * Copyright(c) 2000-2011 LOCKON CO.,LTD. All Rights Reserved.
6 *
7 * http://www.lockon.co.jp/
8 *
9 * This program is free software; you can redistribute it and/or
10 * modify it under the terms of the GNU General Public License
11 * as published by the Free Software Foundation; either version 2
12 * of the License, or (at your option) any later version.
13 *
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17 * GNU General Public License for more details.
18 *
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
22 */
23
24require_once realpath(dirname(__FILE__)) . '/../module/MDB2.php';
25
26/**
27 * SQLの構築・実行を行う
28 *
29 * TODO エラーハンドリング, ロギング方法を見直す
30 *
31 * @author LOCKON CO.,LTD.
32 * @version $Id$
33 */
34class SC_Query {
35
36    var $option = '';
37    var $where = '';
38    var $arrWhereVal = array();
39    var $conn;
40    var $groupby = '';
41    var $order = '';
42    var $force_run;
43
44    /**
45     * コンストラクタ.
46     *
47     * @param string $dsn データソース名
48     * @param boolean $force_run エラーが発生しても処理を続行する場合 true
49     * @param boolean $new 新規に接続を行うかどうか
50     */
51    function SC_Query($dsn = "", $force_run = false, $new = false) {
52
53        if ($dsn == "") {
54            $dsn = DEFAULT_DSN;
55        }
56
57        // Debugモード指定
58        // 常時ONにするとメモリが解放されない。
59        // 連続クエリ実行時に問題が生じる。
60        if(DEBUG_MODE) {
61            $options['debug'] = PEAR_DB_DEBUG;
62        } else {
63            $options['debug'] = 0;
64        }
65
66        // 持続的接続オプション
67        $options['persistent'] = PEAR_DB_PERSISTENT;
68
69        // バッファリング trueにするとメモリが解放されない。
70        // 連続クエリ実行時に問題が生じる。
71        $options['result_buffering'] = false;
72
73        if ($new) {
74            $this->conn = MDB2::connect($dsn, $options);
75        } else {
76            $this->conn = MDB2::singleton($dsn, $options);
77        }
78        if (!PEAR::isError($this->conn)) {
79            $this->conn->setCharset("utf8");
80            $this->conn->setFetchMode(MDB2_FETCHMODE_ASSOC);
81        }
82        $this->dbFactory = SC_DB_DBFactory_Ex::getInstance();
83        $this->force_run = $force_run;
84    }
85
86    /**
87     * シングルトンの SC_Query インスタンスを取得する.
88     *
89     * @param string $dsn データソース名
90     * @param boolean $force_run エラーが発生しても処理を続行する場合 true
91     * @param boolean $new 新規に接続を行うかどうか
92     * @return SC_Query シングルトンの SC_Query インスタンス
93     */
94    function getSingletonInstance($dsn = "", $force_run = false, $new = false) {
95        if (!isset($GLOBALS['_SC_Query_instance'])
96            || is_null($GLOBALS['_SC_Query_instance'])) {
97            $GLOBALS['_SC_Query_instance'] =& new SC_Query_Ex($dsn, $force_run, $new);
98        }
99        $GLOBALS['_SC_Query_instance']->where = '';
100        $GLOBALS['_SC_Query_instance']->arrWhereVal = array();
101        $GLOBALS['_SC_Query_instance']->order = '';
102        $GLOBALS['_SC_Query_instance']->groupby = '';
103        $GLOBALS['_SC_Query_instance']->option = '';
104        return $GLOBALS['_SC_Query_instance'];
105    }
106
107    /**
108     *  エラー判定を行う.
109     *
110     * @deprecated PEAR::isError() を使用して下さい
111     * @return boolean
112     */
113    function isError() {
114        if(PEAR::isError($this->conn)) {
115            return true;
116        }
117        return false;
118    }
119
120    /**
121     * COUNT文を実行する.
122     *
123     * @param string $table テーブル名
124     * @param string $where where句
125     * @param array $arrWhereVal プレースホルダ
126     * @return integer 件数
127     */
128    function count($table, $where = "", $arrWhereVal = array()) {
129        if(strlen($where) <= 0) {
130            $sqlse = "SELECT COUNT(*) FROM $table";
131        } else {
132            $sqlse = "SELECT COUNT(*) FROM $table WHERE $where";
133        }
134        $sqlse = $this->dbFactory->sfChangeMySQL($sqlse);
135        return $this->getOne($sqlse, $arrWhereVal);
136    }
137
138    /**
139     * SELECT文を実行する.
140     *
141     * @param string $col カラム名. 複数カラムの場合はカンマ区切りで書く
142     * @param string $table テーブル名
143     * @param string $where WHERE句
144     * @param array $arrWhereVal プレースホルダ
145     * @param integer $fetchmode 使用するフェッチモード。デフォルトは MDB2_FETCHMODE_ASSOC。
146     * @return array|null
147     */
148    function select($col, $table, $where = "", $arrWhereVal = array(), $fetchmode = MDB2_FETCHMODE_ASSOC) {
149        $sqlse = $this->getSql($col, $table, $where, $arrWhereVal);
150        return $this->getAll($sqlse, $arrWhereVal, $fetchmode);
151    }
152
153    /**
154     * 直前に実行されたSQL文を取得する.
155     *
156     * @param boolean $disp trueの場合、画面出力を行う.
157     * @return string SQL文
158     */
159    function getLastQuery($disp = true) {
160        $sql = $this->conn->last_query;
161        if ($disp) {
162            echo $sql . ";<br />\n";
163        }
164        return $sql;
165    }
166
167    /**
168     * トランザクションをコミットする.
169     *
170     * @return MDB2_OK 成功した場合は MDB2_OK;
171     *         失敗した場合は PEAR::Error オブジェクト
172     */
173    function commit() {
174        return $this->conn->commit();
175    }
176
177    /**
178     * トランザクションを開始する.
179     *
180     * @return MDB2_OK 成功した場合は MDB2_OK;
181     *         失敗した場合は PEAR::Error オブジェクト
182     */
183    function begin() {
184        return $this->conn->beginTransaction();
185    }
186
187    /**
188     * トランザクションをロールバックする.
189     *
190     * @return MDB2_OK 成功した場合は MDB2_OK;
191     *         失敗した場合は PEAR::Error オブジェクト
192     */
193    function rollback() {
194        return $this->conn->rollback();
195    }
196
197    /**
198     * トランザクションが開始されているかチェックする.
199     *
200     * @return boolean トランザクションが開始されている場合 true
201     */
202    function inTransaction() {
203        return $this->conn->inTransaction();
204    }
205
206    /**
207     * 更新系の SQL を実行する.
208     *
209     * この関数は SC_Query::query() のエイリアスです.
210     *
211     * FIXME MDB2::exec() の実装であるべき
212     */
213    function exec($str, $arrval = array()) {
214        return $this->query($str, $arrval);
215    }
216
217    /**
218     * クエリを実行し、結果行毎にコールバック関数を適用する
219     *
220     * @param callback $function コールバック先
221     * @param string $sql SQL クエリ
222     * @param array $arrVal プリペアドステートメントの実行時に使用される配列。配列の要素数は、クエリ内のプレースホルダの数と同じでなければなりません。
223     * @param integer $fetchmode 使用するフェッチモード。デフォルトは DB_FETCHMODE_ASSOC。
224     * @return boolean 結果
225     */
226    function doCallbackAll($cbFunc, $sql, $arrval = array(), $fetchmode = MDB2_FETCHMODE_ASSOC) {
227
228        $sql = $this->dbFactory->sfChangeMySQL($sql);
229
230        $sth =& $this->prepare($sql);
231        if (PEAR::isError($sth) && $this->force_run) {
232            return;
233        }
234
235        $affected =& $this->execute($sth, $arrval);
236        if (PEAR::isError($affected) && $this->force_run) {
237            return;
238        }
239
240        while($data = $affected->fetchRow($fetchmode)) {
241            $result = call_user_func($cbFunc, $data);
242            if($result === false) {
243                break;
244            }
245        }
246        $sth->free();
247        return $result;
248    }
249
250    /**
251     * クエリを実行し、全ての行を返す
252     *
253     * @param string $sql SQL クエリ
254     * @param array $arrVal プリペアドステートメントの実行時に使用される配列。配列の要素数は、クエリ内のプレースホルダの数と同じでなければなりません。
255     * @param integer $fetchmode 使用するフェッチモード。デフォルトは DB_FETCHMODE_ASSOC。
256     * @return array データを含む2次元配列。失敗した場合に 0 または DB_Error オブジェクトを返します。
257     */
258    function getAll($sql, $arrval = array(), $fetchmode = MDB2_FETCHMODE_ASSOC) {
259
260        $sql = $this->dbFactory->sfChangeMySQL($sql);
261
262        $sth =& $this->prepare($sql);
263        if (PEAR::isError($sth) && $this->force_run) {
264            return;
265        }
266
267        $affected =& $this->execute($sth, $arrval);
268        if (PEAR::isError($affected) && $this->force_run) {
269            return;
270        }
271
272        $sth->free();
273        return $affected->fetchAll($fetchmode);
274    }
275
276    /**
277     * 構築した SELECT 文を取得する.
278     *
279     * クラス変数から WHERE 句を組み立てる場合、$arrWhereVal を経由してプレースホルダもクラス変数のもので上書きする。
280     * @param string $col SELECT 文に含めるカラム名
281     * @param string $table SELECT 文に含めるテーブル名
282     * @param string $where SELECT 文に含める WHERE 句
283     * @param mixed $arrWhereVal プレースホルダ(参照)
284     * @return string 構築済みの SELECT 文
285     */
286    function getSql($col, $table, $where = '', &$arrWhereVal = null) {
287        $sqlse = "SELECT $col FROM $table";
288
289        // 引数の$whereを優先する。
290        if (strlen($where) >= 1) {
291            $sqlse .= " WHERE $where";
292        } elseif (strlen($this->where) >= 1) {
293            $sqlse .= " WHERE " . $this->where;
294            // 実行時と同じくキャストしてから評価する (空文字を要素1の配列と評価させる意図)
295            $arrWhereValForEval = (array)$arrWhereVal;
296            if (empty($arrWhereValForEval)) {
297                $arrWhereVal = $this->arrWhereVal;
298            }
299        }
300
301        $sqlse .= ' ' . $this->groupby . ' ' . $this->order . ' ' . $this->option;
302
303        return $sqlse;
304    }
305
306    /**
307     * SELECT 文の末尾に付与する SQL を設定する.
308     *
309     * この関数で設定した値は SC_Query::getSql() で使用されます.
310     *
311     * @param string $str 付与する SQL 文
312     * @return SC_Query 自分自身のインスタンス
313     */
314    function setOption($str) {
315        $this->option = $str;
316        return $this;
317    }
318
319    /**
320     * SELECT 文に付与する LIMIT, OFFSET 句を設定する.
321     *
322     * この関数で設定した値は SC_Query::getSql() で使用されます.
323     * TODO MDB2::setLimit() を使用する
324     *
325     * @param integer $limit LIMIT 句に付与する値
326     * @param integer $offset OFFSET 句に付与する値
327     * @return SC_Query 自分自身のインスタンス
328     */
329    function setLimitOffset($limit, $offset = 0) {
330        if (is_numeric($limit) && is_numeric($offset)){
331
332            $option = " LIMIT " . $limit;
333            $option.= " OFFSET " . $offset;
334            $this->option .= $option;
335        }
336        return $this;
337    }
338
339    /**
340     * SELECT 文に付与する GROUP BY 句を設定する.
341     *
342     * この関数で設定した値は SC_Query::getSql() で使用されます.
343     *
344     * @param string $str GROUP BY 句に付与する文字列
345     * @return SC_Query 自分自身のインスタンス
346     */
347    function setGroupBy($str) {
348        if (strlen($str) == 0) {
349            $this->groupby = '';
350        } else {
351            $this->groupby = "GROUP BY " . $str;
352        }
353        return $this;
354    }
355
356    /**
357     * SELECT 文の WHERE 句に付与する AND 条件を設定する.
358     *
359     * この関数で設定した値は SC_Query::getSql() で使用されます.
360     *
361     * @param string $str WHERE 句に付与する AND 条件の文字列
362     * @return SC_Query 自分自身のインスタンス
363     */
364    function andWhere($str) {
365        if($this->where != "") {
366            $this->where .= " AND " . $str;
367        } else {
368            $this->where = $str;
369        }
370        return $this;
371    }
372
373    /**
374     * SELECT 文の WHERE 句に付与する OR 条件を設定する.
375     *
376     * この関数で設定した値は SC_Query::getSql() で使用されます.
377     *
378     * @param string $str WHERE 句に付与する OR 条件の文字列
379     * @return SC_Query 自分自身のインスタンス
380     */
381    function orWhere($str) {
382        if($this->where != "") {
383            $this->where .= " OR " . $str;
384        } else {
385            $this->where = $str;
386        }
387        return $this;
388    }
389
390    /**
391     * SELECT 文に付与する WHERE 句を設定する.
392     *
393     * この関数で設定した値は SC_Query::getSql() で使用されます.
394     *
395     * @param string $where WHERE 句に付与する文字列
396     * @param mixed $arrWhereVal プレースホルダ
397     * @return SC_Query 自分自身のインスタンス
398     */
399    function setWhere($where = '', $arrWhereVal = array()) {
400        $this->where = $where;
401        $this->arrWhereVal = $arrWhereVal;
402        return $this;
403    }
404
405    /**
406     * SELECT 文に付与する ORDER BY 句を設定する.
407     *
408     * この関数で設定した値は SC_Query::getSql() で使用されます.
409     *
410     * @param string $str ORDER BY 句に付与する文字列
411     * @return SC_Query 自分自身のインスタンス
412     */
413    function setOrder($str) {
414        if (strlen($str) == 0) {
415            $this->order = '';
416        } else {
417            $this->order = "ORDER BY " . $str;
418        }
419        return $this;
420    }
421
422    /**
423     * SELECT 文に付与する LIMIT 句を設定する.
424     *
425     * この関数で設定した値は SC_Query::getSql() で使用されます.
426     *
427     * @param integer $limit LIMIT 句に設定する値
428     * @return SC_Query 自分自身のインスタンス
429     */
430    function setLimit($limit){
431        if ( is_numeric($limit)){
432            $this->option = " LIMIT " .$limit;
433        }
434        return $this;
435    }
436
437    /**
438     * SELECT 文に付与する OFFSET 句を設定する.
439     *
440     * この関数で設定した値は SC_Query::getSql() で使用されます.
441     *
442     * @param integer $offset LIMIT 句に設定する値
443     * @return SC_Query 自分自身のインスタンス
444     */
445    function setOffset($offset) {
446        if ( is_numeric($offset)){
447            $this->offset = " OFFSET " .$offset;
448        }
449        return $this;
450    }
451
452    /**
453     * INSERT文を実行する.
454     *
455     * @param string $table テーブル名
456     * @param array $sqlval array('カラム名' => '値',...)の連想配列
457     * @return
458     */
459    function insert($table, $sqlval) {
460        $strcol = '';
461        $strval = '';
462        $find = false;
463
464        if(count($sqlval) <= 0 ) return false;
465        foreach ($sqlval as $key => $val) {
466            $strcol .= $key . ',';
467            if(strcasecmp("Now()", $val) === 0) {
468                $strval .= 'Now(),';
469            } else if(strcasecmp('CURRENT_TIMESTAMP', $val) === 0) {
470                $strval .= 'CURRENT_TIMESTAMP,';
471            } else {
472                $strval .= '?,';
473                $arrval[] = $val;
474            }
475            $find = true;
476        }
477        if(!$find) {
478            return false;
479        }
480        // 文末の","を削除
481        $strcol = preg_replace("/,$/", "", $strcol);
482        $strval = preg_replace("/,$/", "", $strval);
483        $sqlin = "INSERT INTO $table(" . $strcol. ") VALUES (" . $strval . ")";
484        // INSERT文の実行
485        $ret = $this->query($sqlin, $arrval, false, null, MDB2_PREPARE_MANIP);
486
487        return $ret;
488    }
489
490    /**
491     * UPDATE文を実行する.
492     *
493     * @param string $table テーブル名
494     * @param array $sqlval array('カラム名' => '値',...)の連想配列
495     * @param string $where WHERE句
496     * @param array $arrWhereVal WHERE句用のプレースホルダ配列 (従来は追加カラム用も兼ねていた)
497     * @param array $arrRawSql 追加カラム
498     * @param array $arrRawSqlVal 追加カラム用のプレースホルダ配列
499     * @return
500     */
501    function update($table, $sqlval, $where = "", $arrWhereVal = array(), $arrRawSql = array(), $arrRawSqlVal = array()) {
502        $arrCol = array();
503        $arrVal = array();
504        $find = false;
505
506        foreach ($sqlval as $key => $val) {
507            if (strcasecmp("Now()", $val) === 0) {
508                $arrCol[] = $key . '= Now()';
509            } else if(strcasecmp('CURRENT_TIMESTAMP', $val) === 0) {
510                $arrCol[] = $key . '= CURRENT_TIMESTAMP';
511            } else {
512                $arrCol[] = $key . '= ?';
513                $arrVal[] = $val;
514            }
515            $find = true;
516        }
517
518        if ($arrRawSql != "") {
519            foreach($arrRawSql as $key => $val) {
520                $arrCol[] = "$key = $val";
521            }
522        }
523
524        $arrVal = array_merge($arrVal, $arrRawSqlVal);
525
526        if (empty($arrCol)) {
527            return false;
528        }
529
530        // 文末の","を削除
531        $strcol = implode(', ', $arrCol);
532
533        if (is_array($arrWhereVal)) { // 旧版との互換用
534            // プレースホルダー用に配列を追加
535            $arrVal = array_merge($arrVal, $arrWhereVal);
536        }
537
538        $sqlup = "UPDATE $table SET $strcol";
539        if (strlen($where) >= 1) {
540            $sqlup .= " WHERE $where";
541        }
542
543        // UPDATE文の実行
544        return $this->query($sqlup, $arrVal, false, null, MDB2_PREPARE_MANIP);
545    }
546
547    /**
548     * MAX文を実行する.
549     *
550     * @param string $table テーブル名
551     * @param string $col カラム名
552     * @param string $where 付与する WHERE 句
553     * @param array $arrval プレースホルダに挿入する値
554     * @return integer MAX文の実行結果
555     */
556    function max($col, $table, $where = "", $arrval = array()) {
557        $ret = $this->get("MAX($col)", $table, $where, $arrval);
558        return $ret;
559    }
560
561    /**
562     * MIN文を実行する.
563     *
564     * @param string $table テーブル名
565     * @param string $col カラム名
566     * @param string $where 付与する WHERE 句
567     * @param array $arrval プレースホルダに挿入する値
568     * @return integer MIN文の実行結果
569     */
570    function min($col, $table, $where = "", $arrval = array()) {
571        $ret = $this->get("MIN($col)", $table, $where, $arrval);
572        return $ret;
573    }
574
575    /**
576     * SQL を構築して, 特定のカラムの値を取得する.
577     *
578     * @param string $table テーブル名
579     * @param string $col カラム名
580     * @param string $where 付与する WHERE 句
581     * @param array $arrWhereVal プレースホルダに挿入する値
582     * @return mixed SQL の実行結果
583     */
584    function get($col, $table, $where = "", $arrWhereVal = array()) {
585        $sqlse = $this->getSql($col, $table, $where, $arrWhereVal);
586        // SQL文の実行
587        $ret = $this->getOne($sqlse, $arrWhereVal);
588        return $ret;
589    }
590
591    /**
592     * SQL を指定して, 特定のカラムの値を取得する.
593     *
594     * @param string $sql 実行する SQL
595     * @param array $arrval プレースホルダに挿入する値
596     * @return mixed SQL の実行結果
597     */
598    function getOne($sql, $arrval = array()) {
599
600        $sql = $this->dbFactory->sfChangeMySQL($sql);
601
602        $sth =& $this->prepare($sql);
603        if (PEAR::isError($sth) && $this->force_run) {
604            return;
605        }
606
607        $affected =& $this->execute($sth, $arrval);
608        if (PEAR::isError($affected) && $this->force_run) {
609            return;
610        }
611
612        $sth->free();
613        return $affected->fetchOne();
614    }
615
616    /**
617     * 一行をカラム名をキーとした連想配列として取得
618     *
619     * @param string $table テーブル名
620     * @param string $col カラム名
621     * @param string $where WHERE句
622     * @param array $arrWhereVal プレースホルダ配列
623     * @param integer $fetchmode 使用するフェッチモード。デフォルトは MDB2_FETCHMODE_ASSOC。
624     * @return array array('カラム名' => '値', ...)の連想配列
625     */
626    function getRow($col, $table, $where = "", $arrWhereVal = array(), $fetchmode = MDB2_FETCHMODE_ASSOC) {
627
628        $sql = $this->getSql($col, $table, $where, $arrWhereVal);
629        $sql = $this->dbFactory->sfChangeMySQL($sql);
630
631        $sth =& $this->prepare($sql);
632        if (PEAR::isError($sth) && $this->force_run) {
633            return;
634        }
635
636        $affected =& $this->execute($sth, $arrWhereVal);
637        if (PEAR::isError($affected) && $this->force_run) {
638            return;
639        }
640
641        $sth->free();
642        return $affected->fetchRow($fetchmode);
643    }
644
645    /**
646     * SELECT 文の実行結果を 1列のみ取得する.
647     *
648     * @param string $table テーブル名
649     * @param string $col カラム名
650     * @param string $where 付与する WHERE 句
651     * @param array $arrWhereVal プレースホルダに挿入する値
652     * @return array SQL の実行結果の配列
653     */
654    function getCol($col, $table, $where = "", $arrWhereVal = array()) {
655        $sql = $this->getSql($col, $table, $where, $arrWhereVal);
656        $sql = $this->dbFactory->sfChangeMySQL($sql);
657
658        $sth =& $this->prepare($sql);
659        if (PEAR::isError($sth) && $this->force_run) {
660            return;
661        }
662
663        $affected =& $this->execute($sth, $arrWhereVal);
664        if (PEAR::isError($affected) && $this->force_run) {
665            return;
666        }
667
668        $sth->free();
669        return $affected->fetchCol();
670    }
671
672    /**
673     * レコードの削除
674     *
675     * @param string $table テーブル名
676     * @param string $where WHERE句
677     * @param array $arrval プレースホルダ
678     * @return
679     */
680    function delete($table, $where = "", $arrval = array()) {
681        if(strlen($where) <= 0) {
682            $sqlde = "DELETE FROM $table";
683        } else {
684            $sqlde = "DELETE FROM $table WHERE $where";
685        }
686        $ret = $this->query($sqlde, $arrval, false, null, MDB2_PREPARE_MANIP);
687        return $ret;
688    }
689
690    /**
691     * 次のシーケンス値を取得する.
692     *
693     * @param string $seq_name 取得するシーケンス名
694     * @param integer 次のシーケンス値
695     */
696    function nextVal($seq_name) {
697        return $this->conn->nextID($seq_name);
698    }
699
700    /**
701     * 現在のシーケンス値を取得する.
702     *
703     * @param string $seq_name 取得するシーケンス名
704     * @return integer 現在のシーケンス値
705     */
706    function currVal($seq_name) {
707        return $this->conn->currID($seq_name);
708    }
709
710    /**
711     * シーケンス値を設定する.
712     *
713     * @param string $seq_name シーケンス名
714     * @param integer $start 設定するシーケンス値
715     * @return MDB2_OK
716     */
717    function setVal($seq_name, $start) {
718        $objManager =& $this->conn->loadModule('Manager');
719        // XXX エラーハンドリングを行う
720        $objManager->dropSequence($seq_name);
721        return $objManager->createSequence($seq_name, $start);
722    }
723
724    /**
725     * SQL を実行する.
726     *
727     * FIXME $ignore_errが無視されるようになっているが互換性として問題が無いか確認が必要
728     *
729     * @param string $n 実行する SQL 文
730     * @param array $arr プレースホルダに挿入する値
731     * @param boolean $ignore_err MDB2切替で無効化されている (エラーが発生しても処理を続行する場合 true)
732     * @param mixed $types プレースホルダの型指定 デフォルトnull = string
733     * @param mixed $result_types 返値の型指定またはDML実行(MDB2_PREPARE_MANIP)
734     * @return array SQL の実行結果の配列
735     */
736    function query($n ,$arr = array(), $ignore_err = false, $types = null, $result_types = MDB2_PREPARE_RESULT ){
737
738        $n = $this->dbFactory->sfChangeMySQL($n);
739
740        $sth =& $this->prepare($n, $types, $result_types);
741        if (PEAR::isError($sth) && $this->force_run) {
742            return $sth;
743        }
744
745        $result = $this->execute($sth, $arr);
746        if (PEAR::isError($result) && $this->force_run) {
747            return $sth;
748        }
749
750        //PREPAREの解放
751        $sth->free();
752
753        return $result;
754    }
755
756    /**
757     * シーケンスの一覧を取得する.
758     *
759     * @return array シーケンス名の配列
760     */
761    function listSequences() {
762        $objManager =& $this->conn->loadModule('Manager');
763        return $objManager->listSequences();
764    }
765
766    /**
767     * テーブル一覧を取得する.
768     *
769     * @return array テーブル名の配列
770     */
771    function listTables() {
772        $objManager =& $this->conn->loadModule('Manager');
773        return $objManager->listTables();
774    }
775
776    /**
777     * テーブルのカラム一覧を取得する.
778     *
779     * @param string $table テーブル名
780     * @return array 指定のテーブルのカラム名の配列
781     */
782    function listTableFields($table) {
783        $objManager =& $this->conn->loadModule('Manager');
784        return $objManager->listTableFields($table);
785    }
786
787    /**
788     * テーブルのインデックス一覧を取得する.
789     *
790     * @param string $table テーブル名
791     * @return array 指定のテーブルのインデックス一覧
792     */
793    function listTableIndexes($table) {
794        $objManager =& $this->conn->loadModule('Manager');
795        return $objManager->listTableIndexes($table);
796    }
797
798    /**
799     * テーブルにインデックスを付与する
800     *
801     * @param string $table テーブル名
802     * @param string $name インデックス名
803     * @param array $definition フィールド名など　通常のフィールド指定時は、$definition=array('fields' => array('フィールド名' => array()));
804     *               MySQLのtext型フィールドを指定する場合は $definition['length'] = 'text_field(NNN)' が必要
805     */
806    function createIndex($table, $name, $definition) {
807        $definition = $this->dbFactory->sfGetCreateIndexDefinition($table, $name, $definition);
808        $objManager =& $this->conn->loadModule('Manager');
809        return $objManager->createIndex($table, $name, $definition);
810    }
811
812    /**
813     * テーブルにインデックスを破棄する
814     *
815     * @param string $table テーブル名
816     * @param string $name インデックス名
817     */
818    function dropIndex($table, $name) {
819        $objManager =& $this->conn->loadModule('Manager');
820        return $objManager->dropIndex($table, $name);
821    }
822
823    /**
824     * テーブルの詳細情報を取得する。
825     *
826     * @param string $table テーブル名
827     * @return array テーブル情報の配列
828     */
829    function getTableInfo($table) {
830        $objManager =& $this->conn->loadModule('Reverse');
831        return $objManager->tableInfo($table, NULL);
832    }
833
834    /**
835     * 値を適切にクォートする.
836     *
837     * TODO MDB2 に対応するための暫定的な措置.
838     *      プレースホルダが使用できない実装があるため.
839     *      本来であれば, MDB2::prepare() を適切に使用するべき
840     *
841     * @see MDB2::quote()
842     * @param string $val クォートを行う文字列
843     * @return string クォートされた文字列
844     */
845    function quote($val) {
846        return $this->conn->quote($val);
847    }
848
849    /**
850     * パラメーターの連想配列から, テーブルに存在する列のみを取得する.
851     *
852     * @param string $table テーブル名
853     * @param array プレースホルダの連想配列
854     * @return array テーブルに存在する列のみ抽出した連想配列
855     */
856    function extractOnlyColsOf($table, $arrParams) {
857        $arrCols = $this->listTableFields($table);
858        $arrResults = array();
859        foreach ($arrParams as $key => $val) {
860            if (in_array($key, $arrCols)) {
861                $arrResults[$key] = $val;
862            }
863        }
864        return $arrResults;
865    }
866
867    /**
868     * プリペアドステートメントを構築する.
869     *
870     * @access private
871     * @param string $sql プリペアドステートメントを構築する SQL
872     * @param mixed $types プレースホルダの型指定 デフォルト null
873     * @param mixed $result_types 返値の型指定またはDML実行(MDB2_PREPARE_MANIP)、nullは指定無し
874     * @return MDB2_Statement_Common プリペアドステートメントインスタンス
875     */
876    function prepare($sql, $types = null, $result_types = MDB2_PREPARE_RESULT) {
877        $sth =& $this->conn->prepare($sql, $types, $result_types);
878        if (PEAR::isError($sth)) {
879            if (!$this->force_run) {
880                trigger_error($this->traceError($sth, $sql), E_USER_ERROR);
881            } else {
882                error_log($this->traceError($sth, $sql), 3, LOG_REALFILE);
883            }
884        }
885        return $sth;
886    }
887
888    /**
889     * プリペアドクエリを実行する.
890     *
891     * @access private
892     * @param MDB2_Statement_Common プリペアドステートメントインスタンス
893     * @param array $arrVal プレースホルダに挿入する配列
894     * @return MDB2_Result 結果セットのインスタンス
895     */
896    function execute(&$sth, $arrVal = array()) {
897        $timeStart = SC_Utils_Ex::sfMicrotimeFloat();
898        $affected =& $sth->execute((array)$arrVal);
899
900        // 一定以上時間かかったSQLの場合、ログ出力する。
901        if(defined('SQL_QUERY_LOG_MODE') && SQL_QUERY_LOG_MODE == true) {
902            $timeEnd = SC_Utils_Ex::sfMicrotimeFloat();;
903            $timeExecTime = $timeEnd - $timeStart;
904            if(defined('SQL_QUERY_LOG_MIN_EXEC_TIME') && $timeExecTime >= (float)SQL_QUERY_LOG_MIN_EXEC_TIME) {
905                $logMsg = sprintf("SQL_LOG [%.2fsec]\n%s", $timeExecTime, $sth->query);
906                error_log($logMsg, 3, LOG_REALFILE);
907            }
908        }
909
910        if (PEAR::isError($affected)) {
911            $sql = isset($sth->query) ? $sth->query : '';
912            if (!$this->force_run) {
913                trigger_error($this->traceError($affected, $sql, $arrVal), E_USER_ERROR);
914            } else {
915                error_log($this->traceError($affected, $sql, $arrVal), 3, LOG_REALFILE);
916            }
917        }
918        $this->conn->last_query = stripslashes($sth->query);
919        return $affected;
920    }
921
922    /**
923     * エラーの内容をトレースする.
924     *
925     * @access private
926     * @param PEAR::Error $error PEAR::Error インスタンス
927     * @param string $sql エラーの発生した SQL 文
928     * @param array $arrVal プレースホルダ
929     * @return string トレースしたエラー文字列
930     */
931    function traceError($error, $sql = "", $arrVal = false) {
932        $scheme = '';
933        if (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] != 'off') {
934            $scheme = "http://";
935        } else {
936            $scheme = "https://";
937        }
938
939        $err = $scheme . $_SERVER['HTTP_HOST'] . $_SERVER['REQUEST_URI'] . "\n\n"
940            . "SERVER_ADDR: " . $_SERVER['SERVER_ADDR'] . "\n"
941            . "REMOTE_ADDR: " . $_SERVER['REMOTE_ADDR'] . "\n"
942            . "USER_AGENT: " . $_SERVER['HTTP_USER_AGENT'] . "\n\n"
943            . "SQL: " . $sql . "\n\n";
944        if ($arrVal !== false) {
945            $err .= "PlaceHolder: " . var_export($arrVal, true) . "\n\n";
946        }
947        $err .= $error->getMessage() . "\n\n";
948        $err .= $error->getUserInfo() . "\n\n";
949
950        $err .= SC_Utils_Ex::sfBacktraceToString($error->getBackTrace());
951
952        return $err;
953    }
954
955    /**
956     * SQLクエリの結果セットのカラム名だけを取得する
957     *
958     * @param string $n 実行する SQL 文
959     * @param array $arr プレースホルダに挿入する値
960     * @param boolean エラーが発生しても処理を続行する場合 true
961     * @param mixed $types プレースホルダの型指定 デフォルトnull = string
962     * @param mixed $result_types 返値の型指定またはDML実行(MDB2_PREPARE_MANIP)
963     * @return array 実行結果の配列
964     */
965    function getQueryDefsFields($n ,$arr = array(), $ignore_err = false, $types = null, $result_types = MDB2_PREPARE_RESULT ){
966
967        $n = $this->dbFactory->sfChangeMySQL($n);
968
969        $sth =& $this->prepare($n, $types, $result_types);
970        if (PEAR::isError($sth) && ($this->force_run || $ignore_err)) {
971            return;
972        }
973
974        $result = $this->execute($sth, $arr);
975        if (PEAR::isError($result) && ($this->force_run || $ignore_err)) {
976            return;
977        }
978        $arrRet = $result->getColumnNames();
979        //PREPAREの解放
980        $sth->free();
981
982        return $arrRet;
983    }
984
985}
986
987?>
Note: See TracBrowser for help on using the repository browser.