diff --git a/data/dBase.php b/data/dBase.php
new file mode 100644
index 0000000..367bae5
--- /dev/null
+++ b/data/dBase.php
@@ -0,0 +1,918 @@
+<?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;
+    }
+
+}
+