<?php
/**
 * 数据层基础类
 *
 * @author wangyong1
 * @version 1.0
 * @package data
 */

class dBase extends publicBase {
    private $table;
    private $logpath;

    protected $fieldlist;
    protected $fields;

    protected $primary_keys;
    protected $primary_key;

    protected $dbflag = 'simplyphp';
    private static $db_w = null;
    private static $db_r = null;
    private static $link;

    private $ismaster = false;

    protected $rownum;

    public function __construct() {
        $this->logpath = LOG_PATH_BASE.'/mysql_index/%s/%s_%s.log';
    }
    private function getInstance() {
        $dbpara = $this->ismaster==false ? 'db_r' : 'db_w';

        if(!is_null(self::$$dbpara)) {
            self::$link = self::$$dbpara;

            // 判断mysql是否gone away
            $status = self::$link->getAttribute(PDO::ATTR_SERVER_INFO);
            if($status == 'MySQL server has gone away') {
                self::$link = self::$$dbpara = $this->toDb();
            }
        } else {
           self::$link = self::$$dbpara = $this->toDb();
        }
        return self::$link;
    }

    private function __clone() {}

    private function initDb($table, $ismaster=false) {
        $this->table = $table;
        $this->ismaster = $ismaster;

        $this->fields = $this->fieldlist[$this->table];
        $this->primary_key = empty($this->primary_keys[$this->table]) ? 'id' : $this->primary_keys[$this->table];

        return self::getInstance();
    }

    private function toDb() {
        $type = strtolower($this->dbflag);
        $cnf = $this->parseDbCnf($this->dbflag, $this->ismaster);

        if (count($cnf)<=0 && $cnf['host'] == '') {
         return false;
        }
        try {
            $conn[PDO::ATTR_TIMEOUT] = 3;
            if($GLOBALS['pconnect_db']===true) $conn[PDO::ATTR_PERSISTENT] = true;
            $conn[PDO::MYSQL_ATTR_INIT_COMMAND] = "SET NAMES UTF8;";
            $db = new PDO('mysql:host='.$cnf['host'].';port='.$cnf['port'].';dbname='.$cnf['db'],$cnf['user'],$cnf['pwd'], $conn);
        } catch(PDOException $e) {
            //error_log('['.date('Y-m-d H:i:s').'][first-fail]'.implode('|', $cnf).':'.$e->getMessage()."\n", 3, LOG_PATH_BASE.'/mysql/stat_todb_'.date('Y-m-d').'.log');

            try {
                $conn[PDO::ATTR_TIMEOUT] = 3;
                if($GLOBALS['pconnect_db']===true) $conn[PDO::ATTR_PERSISTENT] = true;
                $conn[PDO::MYSQL_ATTR_INIT_COMMAND] = "SET NAMES UTF8;";
                $db = new PDO('mysql:host='.$cnf['host'].';port='.$cnf['port'].';dbname='.$cnf['db'],$cnf['user'],$cnf['pwd'], $conn);
            } catch(PDOException $e) {
                //error_log('['.date('Y-m-d H:i:s').'][second-fail]'.implode('|', $cnf).':'.$e->getMessage()."\n", 3, LOG_PATH_BASE.'/mysql/stat_todb_'.date('Y-m-d').'.log');
                return false;
            }

            //error_log('['.date('Y-m-d H:i:s').'][second-succ]'.implode('|', $cnf)."\n", 3, LOG_PATH_BASE.'/mysql/stat_todb_'.date('Y-m-d').'.log');
            return $db;
        }

        //error_log('['.date('Y-m-d H:i:s').'][first-succ]'.implode('|', $cnf)."\n", 3, LOG_PATH_BASE.'/mysql/stat_todb_'.date('Y-m-d').'.log');
        return $db;
    }

    /**
     * 数据库Insert
     * 封装标准方法
     * @param string $table 表名
     * @param array $array 一维数组 key:表字段 value:值
     */
    public function insert($table, $array, $action='INSERT') {
        if(empty($array)) return false;

        $this->initDb($table, true);
        try {
            $keys = array_keys($array);
            $newkeys = array_intersect($this->fields, $keys);
            foreach ($newkeys as $k) {
                $vals[] = $array[$k];
            }
            $vnum = count($newkeys);
            $sql = $action." INTO `{$this->table}`(`".implode('`, `', $newkeys)."`) value(".substr(str_pad('',2*$vnum,',?'),1).")";

            $st = self::$link->prepare($sql);
            $res = $st->execute($vals);
            if(!$res) {
                error_log('['.date('Y-m-d H:i:s').']'.$sql.'|'.json_encode($vals).':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/insert_'.date('Y-m-d').'.log');
                return false;
            }

            $last_id = self::$link->lastInsertId();
            return $last_id > 0 ? $last_id : true;
        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 批量插入
     * 封装标准方法
     * @param string $table 表名
     * @param array $array 二维数组 key:表字段 value:值
     */
    public function mutiInsert($table, $arrays) {
        if(empty($arrays)) return false;

        $this->initDb($table, true);
        try {
            $newkeys = array_intersect($this->fields, array_keys($arrays[0]));
            $vnum = count($newkeys);

            $sql = "INSERT IGNORE INTO `{$this->table}`(`".implode('`, `', $newkeys)."`) values";
            foreach ($arrays as $array) {
                foreach ($newkeys as $k) {
                    $vals[] = $array[$k];
                }
                $sql2 .= ",(".substr(str_pad('',2*$vnum,',?'),1).")";
            }

            $sql .= substr($sql2, 1);
            $st = self::$link->prepare($sql);
            $res = $st->execute($vals);
            if(!$res) {
                error_log('['.date('Y-m-d H:i:s').']'.$sql.'|'.json_encode($vals).':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/insert_'.date('Y-m-d').'.log');
                return false;
            }

            return true;
        } catch(PDOException $e) {
            return false;
        }
    }


    /**
     * 数据库Replace
     * 封装标准方法
     * @param string $table 表名
     * @param array $array 一维数组 key:表字段 value:值
     */
    public function replace($table, $array) {
        return $this->insert($table, $array, 'REPLACE');
    }


    private function logSql($table, $flag, $sql, $vals) {
        return ;
        $logpath = sprintf($this->logpath, $table, $flag, date('Y-m-d'));
        if(!is_dir(dirname($logpath))) mkdir(dirname($logpath), 0775, true);
        error_log($sql.'|'.json_encode($vals)."\n", 3, $logpath);
    }

    public function sqlSlow($sql_arr){
        $logpath = sprintf($this->logpath, 'sqlslow', '', date('Y-m-d'));
        if(!is_dir(dirname($logpath))) mkdir(dirname($logpath), 0775, true);
        if($sql_arr[0]>=0.5) error_log(date('Y-m-d H:i:s').'|'.implode('|', $sql_arr)."\n", 3, $logpath);
    }

    /**
     * 数据库select in
     * 封装标准方法
     * @param string $table 表名
     * @param array $array 数组,只支持一个 key(in的字段),多个 value
     */
    public function selectIn($table, $array, $where=array(), $orderby='', $limit=array()) {
        $this->initDb($table, true);
        try {
            $keys = array_keys($array);
            $values = array_values($array);
            $values = (array)$values[0];
            sort($values);
            $vnum = count($values);
            $sql = "SELECT `".implode('`, `',$this->fields)."` FROM `{$this->table}` WHERE `{$keys[0]}` in (".substr(str_pad('',2*$vnum,',?'),1).")";
            if(!empty($where)) {
                $sql .= " and {$where['sql']}";
                $values = array_merge($values, $where['vals']);
            }
            $sql .= empty($orderby) ? $orderby = '' : " ORDER BY {$orderby} ";
            $sql .= empty($limit) ? '' : "LIMIT {$limit[0]}, {$limit[1]}";

            $this->logSql($table, 'selectin', $sql, $values);

            $st = self::$link->prepare($sql);

            $start_time = $this->microtime_float();

            $res = $st->execute($values);

            $finish_time = $this->microtime_float();
            $this->sqlSlow(array($finish_time-$start_time,$sql));

            if(!$res) return false;

            return $st->fetchAll(PDO::FETCH_ASSOC);
        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 数据库select in
     * 封装标准方法
     * @param string $table 表名
     * @param array $array 数组,只支持一个 key(in的字段),多个 value
     */
    public function selectInMulti($table, $array, $where=array(), $orderby='', $limit=array()) {
        $this->initDb($table, true);
        try {
            $keys = array_keys($array);
            $vs = array_values($array);

            $values = array();
            $sql = "SELECT `".implode('`, `',$this->fields)."` FROM `{$this->table}` WHERE";
            foreach ($keys as $k => $key) {
                $vals = $vs[$k];
                sort($vals);
                $vnum = count($vals);

                $values = array_merge($values, $vals);

                $sql .= " `{$key}` in (".substr(str_pad('',2*$vnum,',?'),1).") and";
            }
            $sql = rtrim($sql, 'and');
            if(!empty($where)) {
                $sql .= " and {$where['sql']}";
                $values = array_merge($values, $where['vals']);
            }
            $sql .= empty($orderby) ? $orderby = '' : " ORDER BY {$orderby} ";
            $sql .= empty($limit) ? '' : "LIMIT {$limit[0]}, {$limit[1]}";

            $this->logSql($table, 'selectin', $sql, $values);

            $st = self::$link->prepare($sql);

            $start_time = $this->microtime_float();

            $res = $st->execute($values);
            $finish_time = $this->microtime_float();
            $this->sqlSlow(array($finish_time-$start_time,$sql));

            if(!$res) return false;

            return $st->fetchAll(PDO::FETCH_ASSOC);
        } catch(PDOException $e) {
            return false;
        }
    }


    /**
     * 数据库Select单条数据
     * 封装标准方法
     * @param string $table 表名
     * @param string $where where条件，比如：array('sql'=>'name1=? and name2=?', 'vals'=>array('name1', 'name2'))
     */
    public function select($table, $where=array(), $orderby='') {
        $this->initDb($table);

        try {
            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = $where['vals'];
            }

            $orderby = empty($orderby) ? $orderby = '' : "ORDER BY {$orderby}";
            $sql = "SELECT `".implode('`, `',$this->fields)."` FROM `{$this->table}` {$wheresql} {$orderby}";

            $this->logSql($table, 'select', $sql, $vals);

            $st = self::$link->prepare($sql);

            $start_time = $this->microtime_float();

            $res = $st->execute($vals);

            $finish_time = $this->microtime_float();
            $this->sqlSlow(array($finish_time-$start_time,$sql));

            if(!$res) return false;

            return $st->fetch(PDO::FETCH_ASSOC);

        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 数据库Select多数据
     * 封装标准方法
     * @param string $table 表名
     * @param string $where where条件，比如：array('sql'=>'name1=? and name2=?', 'vals'=>array('name1', 'name2'))
     * @param string $orderby 排序，比如："ctime desc, name asc"
     * @param array $limit 读取数量 array(起始数, 数量)
     */
    public function selectAll($table, $where=array(), $orderby='', $limit=array()) {
        $this->initDb($table);

        try {
            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = $where['vals'];
            }

            $orderby = empty($orderby) ? $orderby = "ORDER BY {$this->primary_key} DESC" : "ORDER BY {$orderby}";
            if($orderby === null) $orderby = '';

            $limitstr = empty($limit) ? '' : "LIMIT {$limit[0]}, {$limit[1]}";
            $sql = "SELECT `".implode('`, `',$this->fields)."` FROM `{$this->table}` {$wheresql} {$orderby} {$limitstr}";
            $this->logSql($table, 'selectAll', $sql, $vals);
            $st = self::$link->prepare($sql);
            $start_time = $this->microtime_float();
            $res = $st->execute($vals);

            $finish_time = $this->microtime_float();
            $this->sqlSlow(array($finish_time-$start_time,$sql));

            if(!$res) return false;

            $this->rownum = $st->rowCount();
            return $st->fetchAll(PDO::FETCH_ASSOC);

        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 数据库Select多数据 大数据分页查询
     * 封装标准方法
     * @param string $table 表名
     * @param string $where where条件，比如：array('sql'=>'name1=? and name2=?', 'vals'=>array('name1', 'name2'))
     * @param string $orderby 排序，比如："ctime desc, name asc"
     * @param array $limit 读取数量 array(起始数, 数量)
     */
    public function selectAllForLimit($table, $where=array(), $orderby='', $limit=array(), $condition = array(), $key_name = '') {
        $this->initDb($table);

        try {
            if($condition['end_page']>0 || $condition['maxid']>0) $orderby = str_replace('desc', 'asc', $orderby);
            if($condition['end_page']<=0 && $condition['maxid']>0) $where['sql'] .= " and `id` > {$condition['maxid']} ";
            if($condition['end_page']<=0 &&  $condition['minid']>0) $where['sql'] .= " and `id` < {$condition['minid']} ";

            if($condition['jump_to_page']>0) {
                $key_name = $key_name ? $key_name : $this->primary_key;
                $where['sql'] .= " and `{$key_name}`<=(select `{$key_name}` from {$table} where {$where['sql']} order by {$orderby} limit ".($condition['jump_to_page']-1)*$limit[1].",1)";
            }
            if($condition['end_page']>0 || $condition['maxid']>0 || $condition['minid']>0 || $condition['jump_to_page']>0) $limit[0] = 0;

            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = $where['vals'];
            }

            $orderby = empty($orderby) ? $orderby = "ORDER BY {$this->primary_key} DESC" : "ORDER BY {$orderby}";
            if($orderby === null) $orderby = '';

            $limitstr = empty($limit) ? '' : "LIMIT {$limit[0]}, {$limit[1]}";
            $sql = "SELECT `".implode('`, `',$this->fields)."` FROM `{$this->table}` {$wheresql} {$orderby} {$limitstr}";
            $this->logSql($table, 'selectAll', $sql, $vals);
            $st = self::$link->prepare($sql);
            $start_time = $this->microtime_float();
            $res = $st->execute($vals);

            $finish_time = $this->microtime_float();
            $this->sqlSlow(array($finish_time-$start_time,$sql));

            if(!$res) return false;

            $this->rownum = $st->rowCount();
            return $st->fetchAll(PDO::FETCH_ASSOC);

        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 数据库统计条数
     * 封装标准方法
     * @param string $table 表名
     * @param array $where where条件，比如：array('sql'=>'name1=? and name2=?', 'vals'=>array('name1', 'name2'))
     * @param string $orderby 排序，比如："ctime desc, name asc"
     * @param array $limit 读取数量 array(起始数, 数量)
     */
    public function count($table, $where=array(), $orderby='', $limit=array()) {
        $this->initDb($table);

        try {
            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = $where['vals'];
            }

            $orderby = empty($orderby) ? $orderby = "ORDER BY {$this->primary_key} DESC" : "ORDER BY {$orderby}";
            $limitstr = empty($limit) ? '' : "LIMIT {$limit[0]}, {$limit[1]}";
            $sql = "SELECT count(*) as num FROM `{$this->table}` {$wheresql} {$orderby} {$limitstr}";

            $this->logSql($table, 'count', $sql, $vals);

            $st = self::$link->prepare($sql);

            $start_time = $this->microtime_float();

            $res = $st->execute($vals);

            $finish_time = $this->microtime_float();
            $this->sqlSlow(array($finish_time-$start_time,$sql));

            if(!$res) return false;

            $info = $st->fetch(PDO::FETCH_ASSOC);
            return $info['num']+0;
        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 数据库Update
     * 封装标准方法
     * @param string $table 表名
     * @param array $array 更新数据 key:表字段 value:值
     * @param string $where where条件，比如：array('sql'=>'name1=? and name2=?', 'vals'=>array('name1', 'name2'))
     */
    public function update($table, $array, $where='') {
        $this->initDb($table, true);

        try {
            $keys = array_keys($array);
            $newkeys = array_intersect($this->fields, $keys);
            foreach ($newkeys as $k) {
                $setstr .= ",`$k`=?";
                $vals[] = $array[$k];
            }
            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = array_merge($vals, $where['vals']);
            }
            $setstr = substr($setstr, 1);

            $sql = "UPDATE `{$this->table}` SET {$setstr} {$wheresql}";

            $st = self::$link->prepare($sql);
            $res = $st->execute($vals);
            if(!$res) {
               error_log('['.date('Y-m-d H:i:s').']'.$sql.'|'.json_encode($vals).':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/update_'.date('Y-m-d').'.log');
                return false;
            }

            return true;

        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 数据库UpdateIn
     * 更新多个符合条件的某字段数据值
     * @param string $table 表名
     * @param array $array 更新数据 key:表字段 value:值
     * @param array $where 数组,只支持一个 key(in的字段),多个 value
     */
    public function updateIn($table, $array, $where) {
        $this->initDb($table, true);

        try {
            $keys = array_keys($array);
            $newkeys = array_intersect($this->fields, $keys);
            foreach ($newkeys as $k) {
                $setstr .= ",`$k`=?";
                $vals[] = $array[$k];
            }

            $wheresql = '';
            $keys = array_keys($where);
            $values = array_values($where);
            $values = $values[0];
            sort($values);
            $vals = array_merge($vals, $values);
            $vnum = count($values);
            $wheresql = " WHERE `{$keys[0]}` in (".substr(str_pad('',2*$vnum,',?'),1).")";
            $setstr = substr($setstr, 1);

            $sql = "UPDATE `{$this->table}` SET {$setstr} {$wheresql}";
            $st = self::$link->prepare($sql);
            $res = $st->execute($vals);
            if(!$res) {
                error_log('['.date('Y-m-d H:i:s').']'.$sql.'|'.json_encode($vals).':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/updatein_'.date('Y-m-d').'.log');
                return false;
            }
            return true;

        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 数据库Delete
     * 封装标准方法
     * @param string $table 表名
     * @param string $where where条件
     * 字符串,比如："name1='***' and name2='***'"
     * 数组，比如：array('sql'=>'name1=? and name2=?', 'vals'=>array('name1', 'name2'))
     */
    public function delete($table, $where=array()) {
        $this->initDb($table, true);

        try {
            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = $where['vals'];
            }
            $sql = "DELETE FROM `{$this->table}` {$wheresql}";
            $st = self::$link->prepare($sql);
            $res = $st->execute($vals);
            if(!$res) {
                error_log('['.date('Y-m-d H:i:s').']'.$sql.'|'.json_encode($vals).':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/delete_'.date('Y-m-d').'.log');
                return false;
            }
            return true;

        } catch(PDOException $e) {
            return false;
        }
    }


    /**
     * 数据库累加
     * 封装标准方法
     * @param string $table 表名
     * @param string $where where条件
     * 字符串,比如："name1='***' and name2='***'"
     * @param string $field 字段名 / array('field'=>int/float) 逐渐改为数组
     * @param int $num 增量数
     * true/false
     */
    public function increase($table, $where, $fields, $num=1) {
        $this->initDb($table, true);

        if(is_array($fields)) {
            try {
                $wheresql = '';
                if(!empty($where)) {
                    $wheresql = "WHERE {$where['sql']}";
                    $vals = $where['vals'];
                }

                // 判断是否存在记录
                $chksql = "SELECT `".implode('`, `',$this->fields)."` FROM `{$this->table}` {$wheresql}";
                $st = self::$link->prepare($chksql);
                $res = $st->execute($vals);
                if(!$res) return false;

                $rownum = $st->rowCount();
                $st->closeCursor();

                foreach ($fields as $field => $num) {
                    $setdata .= ",`$field`=`$field`+$num";
                }
                $setdata = substr($setdata, 1);

                if($rownum>0) {
                    $sql = "UPDATE `{$this->table}` SET {$setdata} {$wheresql}";
                } else {
                    $sql = "REPLACE INTO `{$this->table}` SET {$setdata} ";
                    if(!empty($where))  $sql .= ",".str_replace('WHERE', '', str_replace(array('and', 'AND'), ",", $wheresql));
                }
                $st = self::$link->prepare($sql);
                $res = $st->execute($vals);
                if(!$res) {
                    error_log('['.date('Y-m-d H:i:s').']'.$sql.'|'.json_encode($vals).':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/increase_'.date('Y-m-d').'.log');
                    return false;
                }
                return true;

            } catch(PDOException $e) {
                return false;
            }

            return false;
        }

        try {
            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = $where['vals'];
            }

            // 判断是否存在记录
            $chksql = "SELECT `".implode('`, `',$this->fields)."` FROM `{$this->table}` {$wheresql}";
            $st = self::$link->prepare($chksql);
            $res = $st->execute($vals);
            if(!$res) return false;

            $rownum = $st->rowCount();

            $st->closeCursor();
            if($rownum==1) {
               $sql = "UPDATE `{$this->table}` SET `$fields`=`$fields`+$num {$wheresql}";
            } else {
               $sql = "REPLACE INTO `{$this->table}` SET `$fields`=`$fields`+$num ";
               if(!empty($where))  $sql .= ",".str_replace('WHERE', '', str_replace(array('and', 'AND'), ",", $wheresql));
            }
            $st = self::$link->prepare($sql);
            $res = $st->execute($vals);
            if(!$res) {
                error_log('['.date('Y-m-d H:i:s').']'.$sql.'|'.json_encode($vals).':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/increase_'.date('Y-m-d').'.log');
                return false;
            }
            return true;

        } catch(PDOException $e) {
            return false;
        }
    }


    /**
     * 数据库减
     * 封装标准方法
     * @param string $table 表名
     * @param string $where where条件
     * 字符串,比如："name1='***' and name2='***'"
     * @param string $field 字段名
     * @param int $num 增量数
     * true/false
     */
    public function decrease($table, $where, $field, $num=1) {
        $this->initDb($table, true);

        try {
            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = $where['vals'];
            }
            $sql = "UPDATE `{$this->table}` SET `$field`=`$field`-$num {$wheresql}";

            $st = self::$link->prepare($sql);
            $res = $st->execute($vals);
            if(!$res) {
                error_log('['.date('Y-m-d H:i:s').']'.$sql.'|'.json_encode($vals).':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/decrease_'.date('Y-m-d').'.log');
                return false;
            }
            return true;

        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 执行SQL查询语句
     *
     * 当SQL语句为查询语句时返回执行后的全部数据
     * @access public
     * @param string $sql SQL语句
     * @param boolean $all_rows 是否显示全部数据开关，当为true时，显示全部数据，为false时，显示一行数据，默认为true
     * @param boolean $is_select 是否为查询语句
     * @return array | void
     */
    public function execute($sql, $all_rows=true, $is_select=false) {
        $sql = trim($sql);
        if(!$sql) return false;

        $this->ismaster = $is_select==false ? true : false;
        self::getInstance();
        try {
            $st = self::$link->prepare($sql);
            $res = $st->execute();
            if(!$res) {
                error_log('['.date('Y-m-d H:i:s').']'.$sql.':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/execute_'.date('Y-m-d').'.log');
                return false;
            }

            if(!$is_select) return $res;
            $this->logSql('execute', 'execute', $sql, array());
            if($all_rows==true) {
                $this->rownum = $st->rowCount();
                return $st->fetchAll(PDO::FETCH_ASSOC);
            } else {
                return $st->fetch(PDO::FETCH_ASSOC);
            }
        } catch(PDOException $e) {
            return false;
        }
    }

    /*
     * 数据库事务操作
     * 封装标准方法
     * @param string $sqls sql语句数组
     * 将根据sql数组index顺序执行，执行SQL的表必须是innodb
     */
    public function execTrans($sqls) {
        $this->ismaster = true;
        self::getInstance();

        try {
            self::$link->beginTransaction();	// 开启事务处

            foreach ($sqls as $sql) {
                if(trim($sql)=='') continue;

                $st = self::$link->prepare($sql);
                $res = $st->execute();
                if(!$res) {
                    self::$link->rollBack();
                    return false;
                }
                $st->closeCursor();
            }

            self::$link->commit();				// 事务处理结束

        } catch(PDOException $e) {
        	return false;
        }
        return true;
    }


    /**
     * 执行自定义SQL语句
     * @param unknown $sql
     * @param boolean $is_list 是否为列表，否则单条记录
     */
    public function exec($sql, $is_list=true) {
        self::getInstance();

        try {
            $st = self::$link->prepare($sql['sql']);
            $res = $st->execute($sql['vals']);
            if(!$res) return false;

            if($is_list) {
                return $st->fetchAll(PDO::FETCH_ASSOC);
            } else {
                return $st->fetch(PDO::FETCH_ASSOC);
            }
        } catch(PDOException $e) {
            return false;
        }
    }

    /**
     * 累计统计数据
     * @param string $table
     * @param string $sum_fields 累计字段，比如array('field'=>'alias_field', ...)
     * @param array $where where条件，比如：array('sql'=>'name1=? and name2=?', 'vals'=>array('name1', 'name2'))
     * @return array
     */
    public function sum($table, $fields, $sum_fields, $where) {
        $this->initDb($table);

        try {
            $wheresql = '';
            if(!empty($where)) {
                $wheresql = "WHERE {$where['sql']}";
                $vals = $where['vals'];
            }

            $sumgroup = $sumsql = "`".implode('`, `', $fields)."`";
            foreach ($sum_fields as $field => $alias_field) {
                $sumsql .= ", sum(`{$field}`) as $alias_field";
            }

            $sql = "SELECT {$sumsql} FROM `{$this->table}` {$wheresql} GROUP BY {$sumgroup}";
            $this->logSql($table, 'count', $sql, $vals);

            $st = self::$link->prepare($sql);
            $res = $st->execute($vals);
            if(!$res) return false;

            return $st->fetchAll(PDO::FETCH_ASSOC);
        } catch(PDOException $e) {
            return false;
        }
    }


    /**
     * 解析数据库配置信息
     * 获得数据库的相关连接信息
     * @param sting $dbflag 数据库标识
     * @param boolean $master 是否为主库
     */
    private function parseDbCnf($dbflag,$master=false) {
        $configs = parse_ini_file(_Storage_CNF_PATH, true);
        $config = $configs[strtolower($dbflag)];

        if($master)	{
            $host_port = $config['master'];
        } else {
            $host_port = $config['slave'];
        }
        $hps = explode(',', $host_port);
        $random = rand(0, count($hps)-1);
        $hp = $hps[$random];

        list($host, $port) = explode(':', $hp);

        $cnf = array();
        $cnf['host'] = trim($host);
        $cnf['port'] = trim($port);
        $cnf['user'] = $master==false ? trim($config['user_r']) : trim($config['user']);
        $cnf['pwd'] = $master==false ? trim($config['passwd_r']) : trim($config['passwd']);
        $cnf['db'] = trim($config['db']);
        return $cnf;
    }

    /**
     * CUrl封装的get方式请求API的方法
     * @param string $url URL
     * @param int $timeout 超时时间
     */
    public function getCUrl($url, $timeout=3) {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);

        //分析是否开启SSL加密
        $ssl = substr($url, 0, 8) == 'https://' ? true : false;
        if ($ssl) {
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 1); // 从证书中检查SSL加密算法是否存在
        }

        $res = curl_exec($ch);
        if(curl_error($ch)=='') {
            curl_close($ch);
            return $res;
        }
        curl_close($ch);
        return false;
    }

    /**
     * CUrl封装的get方式请求API的方法
     * @param string $url
     * @param array $data post数据
     * @param int $timeout 超时时间
     */
    public function postCUrl($url, $data, $timeout=3) {
        $ch = curl_init();

        $urlinfo = parse_url($url);
        $domain = $urlinfo['host'];
        $headers = array("Host: $domain");
        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

        //分析是否开启SSL加密
        $ssl = substr($url, 0, 8) == 'https://' ? true : false;
        if ($ssl) {
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 1); // 从证书中检查SSL加密算法是否存在
        }

        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);
        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);

        $res = curl_exec($ch);
        if(curl_error($ch)=='') {
            curl_close($ch);
            return $res;
        }
        curl_close($ch);
        return false;
    }

}