Warning: Can't use blame annotator:
svn blame failed on branches/version-2_12-dev/data/class/db/dbfactory/SC_DB_DBFactory_PGSQL.php: バイナリファイル 'file:///home/svn/open/branches/version-2_12-dev/data/class/db/dbfactory/SC_DB_DBFactory_PGSQL.php' に対しては blame で各行の最終変更者を計算できません 195004

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

Revision 22019, 9.2 KB checked in by Seasoft, 12 years ago (diff)

#1716 (Postgres Plus Advanced Server 9.1 対応)

  • テーブル一覧にシステムテーブルが混在する不具合を回避。
  • 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
RevLine 
1<?php
2/*
3 * This file is part of EC-CUBE
4 *
5 * Copyright(c) 2000-2012 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        // FIXME 怪しい比較「== null」
125        if ($downloadable_days == null || $downloadable_days == '') {
126            $downloadable_days = 0;
127        }
128        $sql = <<< __EOS__
129            (
130                SELECT
131                    CASE
132                        WHEN (SELECT d1.downloadable_days_unlimited FROM dtb_baseinfo d1) = 1 AND $dtb_order_alias.payment_date IS NOT NULL THEN 1
133                        WHEN DATE(CURRENT_TIMESTAMP) <= DATE($dtb_order_alias.payment_date + interval '$downloadable_days days') THEN 1
134                        ELSE 0
135                    END
136            )
137__EOS__;
138        return $sql;
139    }
140
141    /**
142     * 売上集計の期間別集計のSQLを返す
143     *
144     * @param mixed $type
145     * @return string 検索条件のSQL
146     */
147    function getOrderTotalDaysWhereSql($type) {
148        switch ($type) {
149            case 'month':
150                $format = 'MM';
151                break;
152            case 'year':
153                $format = 'YYYY';
154                break;
155            case 'wday':
156                $format = 'Dy';
157                break;
158            case 'hour':
159                $format = 'HH24';
160                break;
161            default:
162                $format = 'YYYY-MM-DD';
163                break;
164        }
165
166        return "to_char(create_date, '".$format."') AS str_date,
167            COUNT(order_id) AS total_order,
168            SUM(CASE WHEN order_sex = 1 THEN 1 ELSE 0 END) AS men,
169            SUM(CASE WHEN order_sex = 2 THEN 1 ELSE 0 END) AS women,
170            SUM(CASE WHEN customer_id <> 0 AND order_sex = 1 THEN 1 ELSE 0 END) AS men_member,
171            SUM(CASE WHEN customer_id <> 0 AND order_sex = 2 THEN 1 ELSE 0 END) AS women_member,
172            SUM(CASE WHEN customer_id = 0 AND order_sex = 1 THEN 1 ELSE 0 END) AS men_nonmember,
173            SUM(CASE WHEN customer_id = 0 AND order_sex = 2 THEN 1 ELSE 0 END) AS women_nonmember,
174            SUM(total) AS total,
175            AVG(total) AS total_average";
176    }
177
178    /**
179     * 売上集計の年代別集計の年代抽出部分のSQLを返す
180     *
181     * @return string 年代抽出部分の SQL
182     */
183    function getOrderTotalAgeColSql() {
184        return 'TRUNC(CAST(EXTRACT(YEAR FROM AGE(create_date, order_birth)) AS INT), -1)';
185    }
186
187    /**
188     * 文字列連結を行う.
189     *
190     * @param array $columns 連結を行うカラム名
191     * @return string 連結後の SQL 文
192     */
193    function concatColumn($columns) {
194        $sql = '';
195        $i = 0;
196        $total = count($columns);
197        foreach ($columns as $column) {
198            $sql .= $column;
199            if ($i < $total -1) {
200                $sql .= ' || ';
201            }
202            $i++;
203        }
204        return $sql;
205    }
206
207    /**
208     * テーブルを検索する.
209     *
210     * 引数に部分一致するテーブル名を配列で返す.
211     *
212     * @deprecated SC_Query::listTables() を使用してください
213     * @param string $expression 検索文字列
214     * @return array テーブル名の配列
215     */
216    function findTableNames($expression = '') {
217        $objQuery =& SC_Query_Ex::getSingletonInstance();
218        $sql = '   SELECT c.relname AS name, '
219            .  '     CASE c.relkind '
220            .  "     WHEN 'r' THEN 'table' "
221            .  "     WHEN 'v' THEN 'view' END AS type "
222            .  '     FROM pg_catalog.pg_class c '
223            .  'LEFT JOIN pg_catalog.pg_namespace n '
224            .  '       ON n.oid = c.relnamespace '
225            .  "    WHERE c.relkind IN ('r','v') "
226            .  "      AND n.nspname NOT IN ('pg_catalog', 'pg_toast') "
227            .  '      AND pg_catalog.pg_table_is_visible(c.oid) '
228            .  '      AND c.relname LIKE ?'
229            .  ' ORDER BY 1,2;';
230        $arrColList = $objQuery->getAll($sql, array('%' . $expression . '%'));
231        $arrColList = SC_Utils_Ex::sfSwapArray($arrColList, false);
232        return $arrColList[0];
233    }
234
235    /**
236     * 文字コード情報を取得する
237     *
238     * @return array 文字コード情報
239     */
240    function getCharSet() {
241        // 未実装
242        return array();
243    }
244
245    /**
246     * 擬似表を表すSQL文(FROM 句)を取得する
247     *
248     * @return string
249     */
250    function getDummyFromClauseSql() {
251        return '';
252    }
253
254    /**
255     * テーブル一覧を取得する
256     *
257     * MDB2_Driver_Manager_pgsql#listTables の不具合回避を目的として独自実装している。
258     * @return array テーブル名の配列
259     */
260    function listTables(SC_Query &$objQuery) {
261        $col = 'tablename';
262        $from = 'pg_tables';
263        $where = "schemaname NOT IN ('pg_catalog', 'information_schema', 'sys')";
264        return $objQuery->getCol($col, $from, $where);
265    }
266}
Note: See TracBrowser for help on using the repository browser.