source: branches/dev/data/class/SC_DbConn.php @ 15963

<?php
/*
 * Copyright(c) 2000-2007 LOCKON CO.,LTD. All Rights Reserved.
 *
 * http://www.lockon.co.jp/
 */

$current_dir = realpath(dirname(__FILE__));
require_once($current_dir . "/../module/DB.php");
require_once($current_dir . "/../module/MDB2.php");
require_once($current_dir . "/../module/MDB2/Extended.php");

$objDbConn = "";
$objDbConnMDB2 = "";

class SC_DbConn{

    var $conn;
    var $conn_mdb2;
    var $result; 
    var $includePath;
    var $error_mail_to;
    var $error_mail_title;
    var $dsn;
    var $err_disp = true;
    
    // ¥³¥ó¥¹¥È¥é¥¯¥¿
    function SC_DbConn($dsn = "", $err_disp = true, $new = false){
        global $objDbConn;
        
        // Debug¥â¡¼¥É»ØÄê
        $options['debug'] = PEAR_DB_DEBUG;
        // ´û¤ËÀܳ¤µ¤ì¤Æ¤¤¤Ê¤¤¤«¡¢¿·µ¬ÀܳÍ×˾¤Î¾ì¹ç¤ÏÀܳ¤¹¤ë¡£
        if(!isset($objDbConn->connection) || $new) {
            if($dsn != "") {
                $objDbConn = DB::connect($dsn, $options);
                $objDbConnMDB2 = MDB2::factory($dsn, $options); 
                $objDbConnMDB2 ->loadModule('Extended', null, false);
                $this->dsn = $dsn;
            } else {
                if(defined('DEFAULT_DSN')) {
                    $objDbConn = DB::connect(DEFAULT_DSN, $options);
                    $objDbConnMDB2 = MDB2::factory(DEFAULT_DSN, $options); 
                    $objDbConnMDB2 ->loadModule('Extended', null, false);
                    $this->dsn = DEFAULT_DSN;
                } else {
                    return;
                }
            }
        }
        $this->conn = $objDbConn;
        $this->conn_mdb2 = $objDbConnMDB2;
        $this->error_mail_to = DB_ERROR_MAIL_TO;
        $this->error_mail_title = DB_ERROR_MAIL_SUBJECT;
        $this->err_disp = $err_disp;
    }
    
    // ¥¯¥¨¥ê¤Î¼Â¹Ô
    function query($n ,$arr = "", $ignore_err = false){
        // mysql¤Î¾ì¹ç¤Ë¤Ï¥Ó¥å¡¼É½¤òÊÑ´¹¤¹¤ë
        if (DB_TYPE == "mysql") $n = sfChangeMySQL($n);

        if ( $arr ) {
            $result = $this->conn->query($n, $arr); 
        } else {
            $result = $this->conn->query($n);
        }
    
        if ($this->conn->isError($result) && !$ignore_err){
            $this->send_err_mail ($result, $n);
        }
        
        $this->result = $result;
        return $this->result;
    }

    // °ì·ï¤Î¤ß¼èÆÀ
    function getOne($n, $arr = ""){
        
        // mysql¤Î¾ì¹ç¤Ë¤Ï¥Ó¥å¡¼É½¤òÊÑ´¹¤¹¤ë
        if (DB_TYPE == "mysql") $n = sfChangeMySQL($n);
        
        if ( $arr ) {
            $result = $this->conn->getOne($n, $arr);
        } else {
            $result = $this->conn->getOne($n);
        }       
        if ($this->conn->isError($result)){
            $this->send_err_mail ($result ,$n);
        }
        $this->result = $result;
        
        return $this->result;
    }
    
    function getRow($n, $arr = ""){

        // mysql¤Î¾ì¹ç¤Ë¤Ï¥Ó¥å¡¼É½¤òÊÑ´¹¤¹¤ë
        if (DB_TYPE == "mysql") $n = sfChangeMySQL($n);

        if ( $arr ) {
            $result = $this->conn->getRow($n, $arr);
        } else {
            $result = $this->conn->getRow($n);
        }       
        if ($this->conn->isError($result)){
            $this->send_err_mail ($result ,$n);
        }
        $this->result = $result;
        return $this->result;
    }

    // SELECTʸ¤Î¼Â¹Ô·ë²Ì¤òÁ´¤Æ¼èÆÀ
    function getAll($n, $arr = ""){

        // mysql¤Î¾ì¹ç¤Ë¤Ï¥Ó¥å¡¼É½¤òÊÑ´¹¤¹¤ë
        if (DB_TYPE == "mysql") $n = sfChangeMySQL($n);
        
        if(PEAR::isError($this->conn)) {
            sfErrorHeader("DB¤Ø¤ÎÀܳ¤Ë¼ºÇÔ¤·¤Þ¤·¤¿¡£");
            gfPrintLog("couldn't connect : " . $this->dsn);
            return 0;
        }

        if ( $arr ){
            //$result = $this->conn->getAll($n, $arr, DB_FETCHMODE_ASSOC);
            $result = $this->conn_mdb2->extended->getAll($n, null, $arr, DB_FETCHMODE_ASSOC);
        } else {
            //$result = $this->conn->getAll($n, DB_FETCHMODE_ASSOC);
            $result = $this->conn_mdb2->extended->getAll($n, null, DB_FETCHMODE_ASSOC);
        }
        
        if ($this->conn->isError($result)){
            $this->send_err_mail ($result, $n);
        }
        $this->result = $result;
        
        return $this->result;
    }   
    
    function autoExecute($table_name, $fields_values, $sql_where = null){
    
        if ( $sql_where ) {
            $result = $this->conn->autoExecute( $table_name, $fields_values, DB_AUTOQUERY_UPDATE, $sql_where);
        } else {
            $result = $this->conn->autoExecute( $table_name, $fields_values, DB_AUTOQUERY_INSERT);
        }
        
        if ($this->conn->isError($result)){
            $this->send_err_mail ($result, $n);
        }
        $this->result = $result;
        return $this->result;
    }
    
    
    function prepare($n){
        global $sql;
        $sql = $n;      
        $result = $this->conn->prepare($n);
        $this->result = $result;
        return $this->result;
    }
    
    function execute($n, $obj){
        global $sql;
        $sql = $n;
        $result = $this->conn->execute($n, $obj);
        $this->result = $result;
        return $this->result;
    }   
    
    function reset(){
        $this->conn->disconnect();
    }

    function debug_print($result, $sql){
        $this->send_err_mail($result, $sql);
    }
    
    function send_err_mail($result, $sql){
        $url = '';
        $errmsg = '';
        
        if ($_SERVER['HTTPS'] == "on") {
            $url = "https://";
        } else {
            $url = "http://";
        }
        $url .= $_SERVER['HTTP_HOST'] . $_SERVER['REQUEST_URI'];
        
        $errmsg  = $url."\n\n";
        $errmsg .= $sql . "\n";
        $errmsg .= $result->message . "\n\n";
        $errmsg .= $result->userinfo . "\n\n";
        
        if ($this->err_disp && DEBUG_MODE === true) {
            print('<pre>');
            print_r(htmlspecialchars($errmsg, ENT_QUOTES, CHAR_CODE));
            print('</pre>');
        }
        
        gfDebugLog($errmsg, DB_ERR_LOG_PATH);
        
        exit();
    }
}

?>