source: branches/comu-ver2/data/class/SC_Query.php @ 18280

Revision 18280, 13.9 KB checked in by Seasoft, 13 years ago (diff)

SC_Query#update にパラメータを追加。

  • 追加カラム用のプレースホルダ配列 (従来はWHERE句用で兼用していた)
  • 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-2007 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
24/**
25 * SQLの構築・実行を行う
26 *
27 * @author LOCKON CO.,LTD.
28 * @version $Id$
29 */
30class SC_Query {
31    var $option;
32    var $where;
33    var $conn;
34    var $groupby;
35    var $order;
36
37    /**
38     * コンストラクタ.
39     *
40     * @param $dsn
41     * @param boolean $err_disp エラー表示を行うかどうか
42     * @param boolean $new 新規に接続を行うかどうか
43     * @return SC_Query
44     */
45    function SC_Query($dsn = "", $err_disp = true, $new = false) {
46        $this->conn = new SC_DBconn($dsn, $err_disp, $new);
47        $this->where = "";
48    }
49
50    /**
51     *  エラー判定を行う.
52     *
53     * @return boolean
54     */
55    function isError() {
56        if(PEAR::isError($this->conn->conn)) {
57            return true;
58        }
59        return false;
60    }
61
62    /**
63     * COUNT文を実行する.
64     *
65     * @param string $table テーブル名
66     * @param string $where where句
67     * @param array $arrval プレースホルダ
68     * @return integer 件数
69     */
70    function count($table, $where = "", $arrval = array()) {
71        if(strlen($where) <= 0) {
72            $sqlse = "SELECT COUNT(*) FROM $table";
73        } else {
74            $sqlse = "SELECT COUNT(*) FROM $table WHERE $where";
75        }
76        // カウント文の実行
77        $ret = $this->conn->getOne($sqlse, $arrval);
78        return $ret;
79    }
80
81    /**
82     * SELECT文を実行する.
83     *
84     * @param string $col カラム名. 複数カラムの場合はカンマ区切りで書く
85     * @param string $table テーブル名
86     * @param string $where WHERE句
87     * @param array $arrval プレースホルダ
88     * @return array|null
89     */
90    function select($col, $table, $where = "", $arrval = array()){
91        $sqlse = $this->getsql($col, $table, $where);
92        $ret = $this->conn->getAll($sqlse, $arrval);
93        return $ret;
94    }
95
96    /**
97     * 直前に実行されたSQL文を取得する.
98     * SC_DBconn::getLastQuery() を利用.
99     *
100     * @param boolean $disp trueの場合、画面出力を行う.
101     * @return string SQL文
102     */
103    function getLastQuery($disp = true) {
104        return $this->conn->getLastQuery($disp);
105    }
106
107    function commit() {
108        $this->conn->query("COMMIT");
109    }
110
111    function begin() {
112        $this->conn->query("BEGIN");
113    }
114
115    function rollback() {
116        $this->conn->query("ROLLBACK");
117    }
118
119    function exec($str, $arrval = array()) {
120        $this->conn->query($str, $arrval);
121    }
122
123    function autoselect($col, $table, $arrwhere = array(), $arrcon = array()) {
124        $strw = "";
125        $find = false;
126        foreach ($arrwhere as $key => $val) {
127            if(strlen($val) > 0) {
128                if(strlen($strw) <= 0) {
129                    $strw .= $key ." LIKE ?";
130                } else if(strlen($arrcon[$key]) > 0) {
131                    $strw .= " ". $arrcon[$key]. " " . $key ." LIKE ?";
132                } else {
133                    $strw .= " AND " . $key ." LIKE ?";
134                }
135
136                $arrval[] = $val;
137            }
138        }
139
140        if(strlen($strw) > 0) {
141            $sqlse = "SELECT $col FROM $table WHERE $strw ".$this->option;
142        } else {
143            $sqlse = "SELECT $col FROM $table ".$this->option;
144        }
145        $ret = $this->conn->getAll($sqlse, $arrval);
146        return $ret;
147    }
148
149    function getall($sql, $arrval = array()) {
150        $ret = $this->conn->getAll($sql, $arrval);
151        return $ret;
152    }
153
154    function getsql($col, $table, $where) {
155        if($where != "") {
156            // 引数の$whereを優先して実行する。
157            $sqlse = "SELECT $col FROM $table WHERE $where " . $this->groupby . " " . $this->order . " " . $this->option;
158        } else {
159            if($this->where != "") {
160                    $sqlse = "SELECT $col FROM $table WHERE $this->where " . $this->groupby . " " . $this->order . " " . $this->option;
161                } else {
162                    $sqlse = "SELECT $col FROM $table " . $this->groupby . " " . $this->order . " " . $this->option;
163            }
164        }
165        return $sqlse;
166    }
167
168    function setoption($str) {
169        $this->option = $str;
170    }
171
172    function setlimitoffset($limit, $offset = 0, $return = false) {
173        if (is_numeric($limit) && is_numeric($offset)){
174
175            $option = " LIMIT " . $limit;
176            $option.= " OFFSET " . $offset;
177
178            if($return){
179                return $option;
180            }else{
181                $this->option.= $option;
182            }
183        }
184    }
185
186    function setgroupby($str) {
187        if (strlen($str) == 0) {
188            $this->groupby = '';
189        } else {
190            $this->groupby = "GROUP BY " . $str;
191        }
192    }
193
194    function andwhere($str) {
195        if($this->where != "") {
196            $this->where .= " AND " . $str;
197        } else {
198            $this->where = $str;
199        }
200    }
201
202    function orwhere($str) {
203        if($this->where != "") {
204            $this->where .= " OR " . $str;
205        } else {
206            $this->where = $str;
207        }
208    }
209
210    function setwhere($str) {
211        $this->where = $str;
212    }
213
214    function setorder($str) {
215        if (strlen($str) == 0) {
216            $this->order = '';
217        } else {
218            $this->order = "ORDER BY " . $str;
219        }
220    }
221
222
223    function setlimit($limit){
224        if ( is_numeric($limit)){
225            $this->option = " LIMIT " .$limit;
226        }
227    }
228
229    function setoffset($offset) {
230        if ( is_numeric($offset)){
231            $this->offset = " OFFSET " .$offset;
232        }
233    }
234
235    /**
236     * INSERT文を実行する.
237     *
238     * @param string $table テーブル名
239     * @param array $sqlval array('カラム名' => '値',...)の連想配列
240     * @return
241     */
242    function insert($table, $sqlval) {
243        $strcol = '';
244        $strval = '';
245        $find = false;
246
247        if(count($sqlval) <= 0 ) return false;
248
249        foreach ($sqlval as $key => $val) {
250            $strcol .= $key . ',';
251            if(eregi("^Now\(\)$", $val)) {
252                $strval .= 'Now(),';
253            } else {
254                $strval .= '?,';
255                $arrval[] = $val;
256            }
257            $find = true;
258        }
259        if(!$find) {
260            return false;
261        }
262        // 文末の","を削除
263        $strcol = ereg_replace(",$","",$strcol);
264        // 文末の","を削除
265        $strval = ereg_replace(",$","",$strval);
266        $sqlin = "INSERT INTO $table(" . $strcol. ") VALUES (" . $strval . ")";
267        // INSERT文の実行
268        $ret = $this->conn->query($sqlin, $arrval);
269
270        return $ret;
271    }
272
273    /**
274     * UPDATE文を実行する.
275     *
276     * @param string $table テーブル名
277     * @param array $sqlval array('カラム名' => '値',...)の連想配列
278     * @param string $where WHERE句
279     * @param array $arrValIn WHERE句用のプレースホルダ配列 (従来は追加カラム用も兼ねていた)
280     * @param array $arrRawSql 追加カラム
281     * @param array $arrRawSqlVal 追加カラム用のプレースホルダ配列
282     * @return
283     */
284    function update($table, $sqlval, $where = "", $arrValIn = array(), $arrRawSql = array(), $arrRawSqlVal = array()) {
285        $arrCol = array();
286        $arrVal = array();
287        $find = false;
288        foreach ($sqlval as $key => $val) {
289            if (eregi("^Now\(\)$", $val)) {
290                $arrCol[] = $key . '= Now()';
291            } else {
292                $arrCol[] = $key . '= ?';
293                $arrVal[] = $val;
294            }
295            $find = true;
296        }
297
298        if ($arrRawSql != "") {
299            foreach($arrRawSql as $key => $val) {
300                $arrCol[] = "$key = $val";
301            }
302        }
303       
304        $arrVal = array_merge($arrVal, $arrRawSqlVal);
305       
306        if (empty($arrCol)) {
307            return false;
308        }
309
310        // 文末の","を削除
311        $strcol = implode(', ', $arrCol);
312
313        if (is_array($arrValIn)) { // 旧版との互換用
314            // プレースホルダー用に配列を追加
315            $arrVal = array_merge($arrVal, $arrValIn);
316        }
317
318        $sqlup = "UPDATE $table SET $strcol";
319        if (strlen($where) >= 1) {
320            $sqlup .= " WHERE $where";
321        }
322
323        // UPDATE文の実行
324        return $this->conn->query($sqlup, $arrVal);
325    }
326
327    // MAX文の実行
328    function max($table, $col, $where = "", $arrval = array()) {
329        if(strlen($where) <= 0) {
330            $sqlse = "SELECT MAX($col) FROM $table";
331        } else {
332            $sqlse = "SELECT MAX($col) FROM $table WHERE $where";
333        }
334        // MAX文の実行
335        $ret = $this->conn->getOne($sqlse, $arrval);
336        return $ret;
337    }
338
339    // MIN文の実行
340    function min($table, $col, $where = "", $arrval = array()) {
341        if(strlen($where) <= 0) {
342            $sqlse = "SELECT MIN($col) FROM $table";
343        } else {
344            $sqlse = "SELECT MIN($col) FROM $table WHERE $where";
345        }
346        // MIN文の実行
347        $ret = $this->conn->getOne($sqlse, $arrval);
348        return $ret;
349    }
350
351    // 特定のカラムの値を取得
352    function get($table, $col, $where = "", $arrval = array()) {
353        if(strlen($where) <= 0) {
354            $sqlse = "SELECT $col FROM $table";
355        } else {
356            $sqlse = "SELECT $col FROM $table WHERE $where";
357        }
358        // SQL文の実行
359        $ret = $this->conn->getOne($sqlse, $arrval);
360        return $ret;
361    }
362
363    function getone($sql, $arrval = array()) {
364        // SQL文の実行
365        $ret = $this->conn->getOne($sql, $arrval);
366        return $ret;
367
368    }
369
370    /**
371     * 一行をカラム名をキーとした連想配列として取得
372     *
373     * @param string $table テーブル名
374     * @param string $col カラム名
375     * @param string $where WHERE句
376     * @param array $arrVal プレースホルダ配列
377     * @param integer $fetchmode 使用するフェッチモード。デフォルトは DB_FETCHMODE_ASSOC。
378     * @return array array('カラム名' => '値', ...)の連想配列
379     */
380    function getRow($table, $col, $where = "", $arrVal = array(), $fetchmode = DB_FETCHMODE_ASSOC) {
381        $sqlse = "SELECT $col FROM $table";
382       
383        if (strlen($where) >= 1) {
384            $sqlse .= " WHERE $where";
385        }
386        // SQL文の実行
387        return $this->conn->getRow($sqlse, $arrVal ,$fetchmode);
388    }
389
390    // 1列取得
391    function getCol($table, $col, $where = "", $arrval = array()) {
392        if (strlen($where) <= 0) {
393            $sqlse = "SELECT $col FROM $table";
394        } else {
395            $sqlse = "SELECT $col FROM $table WHERE $where";
396        }
397        // SQL文の実行
398        return $this->conn->getCol($sqlse, 0, $arrval);
399    }
400
401    /**
402     * レコードの削除
403     *
404     * @param string $table テーブル名
405     * @param string $where WHERE句
406     * @param array $arrval プレースホルダ
407     * @return
408     */
409    function delete($table, $where = "", $arrval = array()) {
410        if(strlen($where) <= 0) {
411            $sqlde = "DELETE FROM $table";
412        } else {
413            $sqlde = "DELETE FROM $table WHERE $where";
414        }
415        $ret = $this->conn->query($sqlde, $arrval);
416        return $ret;
417    }
418
419    function nextval($table, $colname) {
420        $sql = "";
421        // postgresqlとmysqlとで処理を分ける
422        if (DB_TYPE == "pgsql") {
423            $seqtable = $table . "_" . $colname . "_seq";
424            $sql = "SELECT NEXTVAL('$seqtable')";
425        }else if (DB_TYPE == "mysql") {
426            $sql = "SELECT last_insert_id();";
427        }
428        $ret = $this->conn->getOne($sql);
429
430        return $ret;
431    }
432
433    function currval($table, $colname) {
434        $sql = "";
435        if (DB_TYPE == "pgsql") {
436            $seqtable = $table . "_" . $colname . "_seq";
437            $sql = "SELECT CURRVAL('$seqtable')";
438        }else if (DB_TYPE == "mysql") {
439            $sql = "SELECT last_insert_id();";
440        }
441        $ret = $this->conn->getOne($sql);
442
443        return $ret;
444    }
445
446    function setval($table, $colname, $data) {
447        $sql = "";
448        if (DB_TYPE == "pgsql") {
449            $seqtable = $table . "_" . $colname . "_seq";
450            $sql = "SELECT SETVAL('$seqtable', $data)";
451            $ret = $this->conn->getOne($sql);
452        }else if (DB_TYPE == "mysql") {
453            $sql = "ALTER TABLE $table AUTO_INCREMENT=$data";
454            $ret = $this->conn->query($sql);
455        }
456
457        return $ret;
458    }
459
460    function query($n ,$arr = "", $ignore_err = false){
461        $result = $this->conn->query($n, $arr, $ignore_err);
462        return $result;
463    }
464
465    /**
466     * auto_incrementを取得する.
467     *
468     * @param string $table_name テーブル名
469     * @return integer
470     */
471    function get_auto_increment($table_name){
472        // ロックする
473        $this->query("LOCK TABLES $table_name WRITE");
474
475        // 次のIncrementを取得
476        $arrRet = $this->getAll("SHOW TABLE STATUS LIKE ?", array($table_name));
477        $auto_inc_no = $arrRet[0]["Auto_increment"];
478
479        // 値をカウントアップしておく
480        $this->conn->query("ALTER TABLE $table_name AUTO_INCREMENT=?" , $auto_inc_no + 1);
481
482        // 解除する
483        $this->query('UNLOCK TABLES');
484
485        return $auto_inc_no;
486    }
487}
488
489?>
Note: See TracBrowser for help on using the repository browser.