source: branches/version-2_12-dev/data/class/db/dbfactory/SC_DB_DBFactory_PGSQL.php @ 21544

Revision 21544, 8.7 KB checked in by Seasoft, 10 years ago (diff)

#1656 (カテゴリ登録のロジックを高速化)
#1661 (共通ロジックを利用する)

  • SC_Query#getCol

#1660 (SC_Helper_DB#sfCountCategory メモリ消費が激しい)
#1659 (SC_Helper_DB#sfCountCategory メモリリークが発生する)

  • 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
24/**
25 * PostgreSQL 固有の処理をするクラス.
26 *
27 * このクラスを直接インスタンス化しないこと.
28 * 必ず SC_DB_DBFactory クラスを経由してインスタンス化する.
29 * また, SC_DB_DBFactory クラスの関数を必ずオーバーライドしている必要がある.
30 *
31 * @package DB
32 * @author LOCKON CO.,LTD.
33 * @version $Id:SC_DB_DBFactory_PGSQL.php 15532 2007-08-31 14:39:46Z nanasess $
34 */
35class SC_DB_DBFactory_PGSQL extends SC_DB_DBFactory {
36
37    /**
38     * DBのバージョンを取得する.
39     *
40     * @param string $dsn データソース名
41     * @return string データベースのバージョン
42     */
43    function sfGetDBVersion($dsn = '') {
44        $objQuery =& SC_Query_Ex::getSingletonInstance($dsn);
45        $val = $objQuery->getOne('select version()');
46        $arrLine = explode(' ' , $val);
47        return $arrLine[0] . ' ' . str_replace(',', '', $arrLine[1]);
48    }
49
50    /**
51     * MySQL 用の SQL 文に変更する.
52     *
53     * DB_TYPE が PostgreSQL の場合は何もしない
54     *
55     * @access private
56     * @param string $sql SQL 文
57     * @return string MySQL 用に置換した SQL 文
58     */
59    function sfChangeMySQL($sql) {
60        return $sql;
61    }
62
63    /**
64     * 昨日の売上高・売上件数を算出する SQL を返す.
65     *
66     * @param string $method SUM または COUNT
67     * @return string 昨日の売上高・売上件数を算出する SQL
68     */
69    function getOrderYesterdaySql($method) {
70        return 'SELECT '.$method.'(total) FROM dtb_order '
71               . 'WHERE del_flg = 0 '
72               . "AND to_char(create_date,'YYYY/MM/DD') = to_char(CURRENT_TIMESTAMP - interval '1 days','YYYY/MM/DD') "
73               . 'AND status <> ' . ORDER_CANCEL;
74    }
75
76    /**
77     * 当月の売上高・売上件数を算出する SQL を返す.
78     *
79     * @param string $method SUM または COUNT
80     * @return string 当月の売上高・売上件数を算出する SQL
81     */
82    function getOrderMonthSql($method) {
83        return 'SELECT '.$method.'(total) FROM dtb_order '
84               . 'WHERE del_flg = 0 '
85               . "AND to_char(create_date,'YYYY/MM') = ? "
86               . "AND to_char(create_date,'YYYY/MM/DD') <> to_char(CURRENT_TIMESTAMP,'YYYY/MM/DD') "
87               . 'AND status <> ' . ORDER_CANCEL;
88    }
89
90    /**
91     * 昨日のレビュー書き込み件数を算出する SQL を返す.
92     *
93     * @return string 昨日のレビュー書き込み件数を算出する SQL
94     */
95    function getReviewYesterdaySql() {
96        return 'SELECT COUNT(*) FROM dtb_review AS A '
97               . 'LEFT JOIN dtb_products AS B '
98               . 'ON A.product_id = B.product_id '
99               . 'WHERE A.del_flg=0 '
100               . 'AND B.del_flg = 0 '
101               . "AND to_char(A.create_date, 'YYYY/MM/DD') = to_char(CURRENT_TIMESTAMP - interval '1 days','YYYY/MM/DD') "
102               . "AND to_char(A.create_date,'YYYY/MM/DD') != to_char(CURRENT_TIMESTAMP,'YYYY/MM/DD')";
103    }
104
105    /**
106     * メール送信履歴の start_date の検索条件の SQL を返す.
107     *
108     * @return string 検索条件の SQL
109     */
110    function getSendHistoryWhereStartdateSql() {
111        return "start_date BETWEEN current_timestamp + '- 5 minutes' AND current_timestamp + '5 minutes'";
112    }
113
114    /**
115     * ダウンロード販売の検索条件の SQL を返す.
116     *
117     * @param string $dtb_order_alias
118     * @return string 検索条件の SQL
119     */
120    function getDownloadableDaysWhereSql($dtb_order_alias = 'dtb_order') {
121        $baseinfo = SC_Helper_DB_Ex::sfGetBasisData();
122        //downloadable_daysにNULLが入っている場合(無期限ダウンロード可能時)もあるので、NULLの場合は0日に補正
123        $downloadable_days = $baseinfo['downloadable_days'];
124        if($downloadable_days ==null || $downloadable_days == '')$downloadable_days=0;
125        $sql = <<< __EOS__
126            (
127                SELECT
128                    CASE
129                        WHEN (SELECT d1.downloadable_days_unlimited FROM dtb_baseinfo d1) = 1 AND $dtb_order_alias.payment_date IS NOT NULL THEN 1
130                        WHEN DATE(CURRENT_TIMESTAMP) <= DATE($dtb_order_alias.payment_date + '$downloadable_days days') THEN 1
131                        ELSE 0
132                    END
133            )
134__EOS__;
135        return $sql;
136    }
137
138    /**
139     * 売上集計の期間別集計のSQLを返す
140     *
141     * @param mixed $type
142     * @return string 検索条件のSQL
143     */
144    function getOrderTotalDaysWhereSql($type) {
145        switch ($type) {
146            case 'month':
147                $format = 'MM';
148                break;
149            case 'year':
150                $format = 'YYYY';
151                break;
152            case 'wday':
153                $format = 'Dy';
154                break;
155            case 'hour':
156                $format = 'HH24';
157                break;
158            default:
159                $format = 'YYYY-MM-DD';
160                break;
161        }
162
163        return "to_char(create_date, '".$format."') AS str_date,
164            COUNT(order_id) AS total_order,
165            SUM(CASE WHEN order_sex = 1 THEN 1 ELSE 0 END) AS men,
166            SUM(CASE WHEN order_sex = 2 THEN 1 ELSE 0 END) AS women,
167            SUM(CASE WHEN customer_id <> 0 AND order_sex = 1 THEN 1 ELSE 0 END) AS men_member,
168            SUM(CASE WHEN customer_id <> 0 AND order_sex = 2 THEN 1 ELSE 0 END) AS women_member,
169            SUM(CASE WHEN customer_id = 0 AND order_sex = 1 THEN 1 ELSE 0 END) AS men_nonmember,
170            SUM(CASE WHEN customer_id = 0 AND order_sex = 2 THEN 1 ELSE 0 END) AS women_nonmember,
171            SUM(total) AS total,
172            AVG(total) AS total_average";
173    }
174
175    /**
176     * 売上集計の年代別集計の年代抽出部分のSQLを返す
177     *
178     * @return string 年代抽出部分の SQL
179     */
180    function getOrderTotalAgeColSql() {
181        return 'TRUNC(CAST(EXTRACT(YEAR FROM AGE(create_date, order_birth)) AS INT), -1)';
182    }
183
184    /**
185     * 文字列連結を行う.
186     *
187     * @param array $columns 連結を行うカラム名
188     * @return string 連結後の SQL 文
189     */
190    function concatColumn($columns) {
191        $sql = '';
192        $i = 0;
193        $total = count($columns);
194        foreach ($columns as $column) {
195            $sql .= $column;
196            if ($i < $total -1) {
197                $sql .= ' || ';
198            }
199            $i++;
200        }
201        return $sql;
202    }
203
204    /**
205     * テーブルを検索する.
206     *
207     * 引数に部分一致するテーブル名を配列で返す.
208     *
209     * @deprecated SC_Query::listTables() を使用してください
210     * @param string $expression 検索文字列
211     * @return array テーブル名の配列
212     */
213    function findTableNames($expression = '') {
214        $objQuery =& SC_Query_Ex::getSingletonInstance();
215        $sql = '   SELECT c.relname AS name, '
216            .  '     CASE c.relkind '
217            .  "     WHEN 'r' THEN 'table' "
218            .  "     WHEN 'v' THEN 'view' END AS type "
219            .  '     FROM pg_catalog.pg_class c '
220            .  'LEFT JOIN pg_catalog.pg_namespace n '
221            .  '       ON n.oid = c.relnamespace '
222            .  "    WHERE c.relkind IN ('r','v') "
223            .  "      AND n.nspname NOT IN ('pg_catalog', 'pg_toast') "
224            .  '      AND pg_catalog.pg_table_is_visible(c.oid) '
225            .  '      AND c.relname LIKE ?'
226            .  ' ORDER BY 1,2;';
227        $arrColList = $objQuery->getAll($sql, array('%' . $expression . '%'));
228        $arrColList = SC_Utils_Ex::sfSwapArray($arrColList, false);
229        return $arrColList[0];
230    }
231
232    /**
233     * 文字コード情報を取得する
234     *
235     * @return array 文字コード情報
236     */
237    function getCharSet() {
238        // 未実装
239        return array();
240    }
241
242    /**
243     * 擬似表を表すSQL文(FROM 句)を取得する
244     *
245     * @return string
246     */
247    function getDummyFromClauseSql() {
248        return '';
249    }
250}
Note: See TracBrowser for help on using the repository browser.