mysql工具类

wocaosinima

<?php   
/**  
+----------------------------------------------------------  
 * Mysql操作类  
+----------------------------------------------------------  
 * 文件名称  Db.class.php  
+----------------------------------------------------------  
 * 文件描述  mysql操作类  
+----------------------------------------------------------  
 */  
class Db{   
    //数据库连接标识   
    protected $link = null;   
    //当前操作的表   
    public $table = '';   
    //查询参数   
    protected $options = array();   
    //当前执行的SQL语句   
    protected $sql = '';   
    //用什么编码传递数据   
    protected $dbCharset = 'utf8';   
  
    //缓存路径   
    protected $cachePath = './cache/';   
    //缓存扩展名   
    protected $cacheFileExt = "php";   
    //缓存文件名   
    protected $cacheFileName;   
    //是否缓存   
    protected $cache = false;   
    //缓存更新时间秒数   
    protected $cacheLimitTime = 60;   
  
    //数据返回类型, 1代表数组, 2代表对象   
    protected $returnType = 1;   
  
  /*  
   * 根据当前动态文件生成缓存文件名  
   */  
    function setCacheFileName($fileName) {   
        $cacheFileName = $this->cachePath . strtoupper(md5($fileName)).".".$this->cacheFileExt;   
        $this->cacheFileName=$cacheFileName;   
    }   
  /*  
   * 根据当前动态文件生成缓存文件名  
   */  
    function getCacheFileName() {   
        return  $this->cacheFileName;   
    }   
    /**  
     * 连接数据库  
     *  
     * @access      public  
     * @param       array    $db  数据库配置  
     * @return      resource 数据库连接标识  
     */  
    public function connect($db){   
        //根据配置使用不同函数连接数据库   
        $db['host'] = isset($db['port']) ? $db['host'].':'.$db['port']: $db['host'];   
        $db['char'] = isset($db['char']) ? $db['char']: $this->dbCharset;   
        $func = $db['pconnect'] ? 'mysql_pconnect' : 'mysql_connect';   
        $this->link = $func($db['host'], $db['user'], $db['pwd']);   
        mysql_select_db($db['database'], $this->link);   
        mysql_query("SET NAMES '{$db['char']}'");   
        $this->cachePath = isset($db['cachepath']) ? $db['cachepath']: $this->cachePath;   
        return $this->link;   
    }   
    /**  
     * 查询符合条件的一条记录  
     *  
     * @access      public  
     * @param       string    $where  查询条件  
     * @param       string    $field  查询字段  
     * @param       string    $table  表  
     * @return      mixed             符合条件的记录  
     */  
    public function find($where = NULL, $field = '*', $table = ''){   
        return $this->findAll($where = NULL, $field = '*', $table = '', FALSE);   
    }   
    /**  
     * 查询符合条件的所有记录  
     *  
     * @access      public  
     * @param       string    $where  查询条件  
     * @param       string    $field  查询字段  
     * @param       string    $table  表  
     * @return      mixed             符合条件的记录  
     */  
    public function findAll($where = NULL, $field = '*', $table = '', $all = TRUE){   
        $this->options['where'] = is_null($where) ? @$this->options['where']: $where;   
        $this->options['field'] = isset($this->options['field']) ? $this->options['field']: $field;   
        $this->options['table'] = $table == '' ? $this->table: $table;   
        $sql = "SELECT {$this->options['field']} FROM `{$this->options['table']}` ";   
        $sql .= isset($this->options['join']) ? ' LEFT JOIN '.$this->options['join']: '';   
        $sql .= isset($this->options['where']) ? ' WHERE '.$this->options['where']: '';   
        $sql .= isset($this->options['group']) ? ' GROUP BY '.$this->options['group']: '';   
        $sql .= isset($this->options['having']) ? ' HAVING '.$this->options['having']: '';   
        $sql .= isset($this->options['order']) ? ' ORDER BY '.$this->options['order']: '';   
        $sql .= isset($this->options['limit']) ? ' LIMIT '.$this->options['limit']: '';   
        $this->sql = $sql;   
        $row = NULL;   
        //如果开启了缓存, 那么重缓存中获取数据   
        if ($this->cache === TRUE){   
            $this->setCacheFileName($this->sql);   
            $row = $this->readCache();   
        }   
        //如果读取失败, 或则没有开启缓存   
        if (is_null($row)){   
            $result = $this->query();   
            $row = $all === TRUE ? $this->fetchAll($result): $this->fetch($result);   
            //如果开启了缓存, 那么就写入   
            if ($this->cache === TRUE){   
                $this->writeCache($row);   
            }   
            $this->options = array();   
        }   
        return $row;   
    }   
    /**  
     * 读取结果集中的所有记录到数组中  
     *  
     * @access public  
     * @param  resource  $result  结果集  
     * @return array  
     */  
    public function fetchAll($result = NULL){   
        $rows = array();   
        while ($row = $this->fetch($result)){   
            $rows[] = $row;   
        }   
        return $rows;   
    }   
    /**  
     * 读取结果集中的一行记录到数组中  
     *  
     * @access public  
     * @param  resource  $result  结果集  
     * @param  int       $type    返回类型, 1为数组, 2为对象  
     * @return mixed              根据返回类型返回  
     */  
    public function fetch($result = NULL, $type = NULL){   
        $result = is_null($result) ? $this->result: $result;   
        $type = is_null($type) ? $this->returnType: $type;   
        $func = $type === 1 ? 'mysql_fetch_assoc' : 'mysql_fetch_object';   
        return $func($result);   
    }   
    /**  
     * 执行SQL命令  
     *  
     * @access      public  
     * @param       string    $sql    SQL命令  
     * @param       resource  $link   数据库连接标识  
     * @return      mixed             数据库结果集  
     */  
    public function query($sql = '', $link = NULL){   
        $sql = emptyempty($sql) ? $this->sql: $sql;   
        $link = is_null($link) ? $this->link: $link;   
        $this->result = mysql_query($sql, $link);   
        if (is_resource($this->result)){   
            return $this->result;   
        }   
        //如果执行SQL出现错误, 那么抛出异常   
        exit('<strong>Mysql error:</strong>'.$this->getError());   
    }   
    /**  
     * 执行SQL命令  
     *  
     * @access      public  
     * @param       string    $sql    SQL命令  
     * @param       resource  $link   数据库连接标识  
     * @return      bool              是否执行成功  
     */  
    public function execute($sql = '', $link = NULL){   
        $sql = emptyempty($sql) ? $this->sql: $sql;   
        $link = is_null($link) ? $this->link: $link;   
        if (mysql_query($sql, $link)){   
            return TRUE;   
        }   
        return FALSE;   
    }   
    /**  
     * 插入记录  
     *  
     * @access public  
     * @param  array  $data  插入的记录, 格式:array('字段名'=>'值', '字段名'=>'值');  
     * @param  string $table 表名  
     * @return bool          当前记录id  
     */  
    public function add($data, $table = NULL){   
        $table = is_null($table) ? $this->table: $table;   
        $sql = "INSERT INTO `{$table}`";   
        $fields = $values = array();   
        $field = $value = '';   
        //遍历记录, 格式化字段名称与值   
        foreach($data as $key => $val){   
            $fields[] = "`{$table}`.`{$key}`";   
            $values[] = is_numeric($val) ? $val : "'{$val}'";   
        }   
        $field = join(',', $fields);   
        $value = join(',', $values);   
        unset($fields, $values);   
        $sql .= "({$field}) VALUES({$value})";   
        $this->sql = $sql;   
        $this->execute();   
        return $this->insertId();   
    }   
    /**  
     * 删除记录  
     *  
     * @access public  
     * @param  string  $where  条件  
     * @param  string  $table  表名  
     * @return bool            影响行数  
     */  
    public function delete($where = NULL, $table = NULL){   
        $table = is_null($table) ? $this->table: $table;   
        $where = is_null($where) ? @$this->options['where']: $where;   
        $sql = "DELETE FROM `{$table}` WHERE {$where}";   
        $this->sql = $sql;   
        $this->execute();   
        return $this->affectedRows();   
    }   
    /**  
     * 更新记录  
     *  
     * @access public  
     * @param  array   $data   更新的数据 格式:array('字段名' => 值);  
     * @param  string  $where  更新条件  
     * @param  string  $table  表名  
     * @return bool            影响多少条信息  
     */  
    public function update($data, $where = NULL, $table = NULL){   
        $table = is_null($table) ? $this->table: $table;   
        $where = is_null($where) ? @$this->options['where']: $where;   
        $sql = "UPDATE `{$table}` SET ";   
        $values = array();   
        foreach($data as $key => $val){   
            $val = is_numeric($val) ? $val : "'{$val}'";   
            $values[] = "`{$table}`.`{$key}` = {$val}";   
        }   
        $value = join(',', $values);   
        $this->sql = $sql.$value." WHERE {$where}";   
        $this->execute();   
        return $this->affectedRows();   
    }   
    /**  
     * 读取缓存  
     *  
     * @access      public  
     * @return      mixed   如果读取成功返回缓存内容, 否则返回NULL  
     */  
    protected function readCache(){   
        $file = $this->getCacheFileName();   
        if (file_exists($file)){   
            //缓存过期   
            if ((filemtime($file) + $this->cacheLimitTime) < time()){   
                @unlink($file);   
                return NULL;   
            }   
            if (1 === $this->returnType){   
                $row = include $file;   
            }   
            else{   
                $data = file_get_contents($file);   
                $row = unserialize($data);   
            }   
            return $row;   
        }   
        return NULL;   
    }   
    /**  
     * 写入缓存  
     *  
     * @access      public  
     * @param       mixed   $data   缓存内容  
     * @return      bool            是否写入成功  
     */  
    public function writeCache($data){   
        $file = $this->getCacheFileName();   
        if ($this->makeDir(dirname($file))){   
            if (1 === $this->returnType){   
                $data = '<?php return '.var_export($data, TRUE).';?>';   
            }else{   
                $data = serialize($data);   
            }   
        }   
        return file_put_contents($file, $data);   
    }   
    /*  
     * 清除缓存文件  
     * string $fileName 指定文件名(含函数)或者all（全部）  
     * 返回：清除成功返回true，反之返回false  
     */  
    function clearCache( $fileName = "all" ) {   
        if( $fileName != "all" ) {   
            if( file_exists( $fileName ) ) {   
                return @unlink( $fileName );   
            }else return false;   
        }   
        if ( is_dir( $this->cachePath ) ) {   
            if ( $dir = @opendir( $this->cachePath ) ) {   
                while ( $file = @readdir( $dir ) ) {   
                    $check = is_dir( $file );   
                    if ( !$check )   
                    @unlink( $this->cachePath . $file );   
                }   
                @closedir( $dir );   
                return true;   
            }else{   
                return false;   
            }   
        }else{   
          return false;   
        }   
    }   
      /*  
       * 连续建目录  
       * string $dir 目录字符串  
       * int $mode   权限数字  
       * 返回：顺利创建或者全部已建返回true，其它方式返回false  
       */  
    function makeDir( $dir, $mode = "0777" ) {   
        if( ! $dir ) return 0;   
        $dir = str_replace( "\\", "/", $dir );   
           
        $mdir = "";   
        foreach( explode( "/", $dir ) as $val ) {   
            $mdir .= $val."/";   
            if( $val == ".." || $val == "." || trim( $val ) == "" ) continue;   
             
            if( ! file_exists( $mdir ) ) {   
                if(!@mkdir( $mdir, $mode )){   
                    return false;   
                }   
            }   
        }   
        return true;   
    }   
    //自动加载函数, 实现特殊操作   
    public function __call($func, $args)   
    {   
         if(in_array($func, array('field', 'join', 'where'</