PHP文件处理类

/**
 * 文件读写类
 * 读取时,支持跳过N个/行字符然后再读取M个/行字符
 * 支持每次读取时使用回调函数
 * 
 * 示例:
 * $file = new File('a.txt', 'r');
 * 
 * $data = $file->limit(0, 10)->getLine(function($line){
 *         return  $line . ' <br/>';
 * });
 * print_r($data);
 * $file->close();
 * 
 */

class File {
    
    protected $fp = null;
    protected $file = null;
    protected $limit = [0, 0];

    public function __construct($file, $mode = 'r'){
        
        $this->file = $file;
        $this->fp = fopen($file, $mode);
        
    }
    
    public function limit($start, $line = 0){
        
        if(func_num_args() == 1){
            $line = $start; $start = 0;
        }
        $this->limit = [$start, $line];
        return $this;
    }
    
    /**
     * 增加对文件函数的直接调用
     * @param string $method
     * @param mixed $args
     * @return mixed
     */
    public function __call($method, $args){
    
        array_unshift($args, $this->fp);
        return call_user_func_array($method, $args);
    }
    

    
    /**
     * 读取文件按行
     * @param function $func
     * @param $read 读取方式
     * @param $args 参数列表
     * @return mixed
     */
    public function readLine($func = null, $read = null, $args = []){
    
        $data = array();
        $opt = array('char'=>'fgetc', 'line'=>'fgets', 'csv'=>'fgetcsv');
        $read = (isset($opt[$read]))? $opt[$read] : 'fgets';
        array_unshift($args, $this->fp);
        
        //跳过字符数或行数
        if($this->limit[0] !== 0){
            for($i = 0; $i < $this->limit[0]; $i++){
                if(call_user_func_array($read, $args) === false){
                    return $data;
                }
            }
        }
        
        if($this->limit[1] > 0){
            //读取有效行数
            for($i = 0; $i < $this->limit[1]; $i++){
            
                if(($buffer = call_user_func_array($read, $args)) === false){
                    return $data;
                }
                if(is_callable($func)){
                    $buffer = $func($buffer);
                    if($buffer !== null) $data[] = $buffer;
                }else{
                    $data[] = $buffer;
                }
            }    
            
        }else{
            //读取所有行数
            while(($buffer = call_user_func_array($read, $args)) !== false){
                if(is_callable($func)){
                    $buffer = $func($buffer);
                    if($buffer !== null) $data[] = $buffer;
                }
            }
        }
        $this->setHome();
        return $data;

    }
    
    /**
     * 读取文件按字符
     * @param function $func
     * @return mixed
     */
    public function getChar($func = null){
        return implode('', $this->readLine($func, 'char'));
        
    }
    
    /**
     * 读取文件按行
     * @param int $length
     * @param function $func
     * @return mixed
     */
    public function getLine($func = null, $length = 1024){
        
        if(is_numeric($func)){
            $length = $func; $func = null;
        }
        return $this->readLine($func, 'line', [$length]);
    }
    
    /**
     * 读按行取csv文件
     * @param unknown $func
     * @param number $length
     * @param string $delimiter
     */
    public function getCsv($length = 0, $delimiter = ','){
        return $this->readLine($func, 'csv', [$length, $delimiter]);
    }
    
    /**
     * 读取文件按字节
     * @param number $length
     * @return string
     */
    public function read($length = 0){
        
        if(empty($length)) $length = filesize($this->file);
        return fread($this->fp, $length);
    }

    /**
     * 写入文件
     * @param unknown $string
     * @param unknown $length
     * @return number
     */
    public function write($string, $length = null){
        return fwrite($this->fp, $string, $length);
    }
    
    /**
     * 写入csv文件
     * @param unknown $data
     * @param string $delimiter
     * @return boolean
     */
    public function putCsv($data, $delimiter = ','){
        
        foreach($data as $row) {
            fputcsv($fp, $row);
        }
    }
    
    /**
     * 获取文件资源指针
     * @return resource
     */
    public function getfp(){
        return $this->fp;
    }
    
    /**
     * 获取当前头文件指针位置
     * @return number
     */
    public function getSeek(){
        return ftell($this->fp);
    }
    
    /**
     * 文件指针定位到开头
     * @return boolean
     */
    public function setHome(){
        return rewind($this->fp);
    }
    
    /**
     * 文件指针定位到结尾
     * @return number
     */
    public function setEnd(){
        return fseek($this->fp, 0, SEEK_END);
    }
    
    /**
     * 设置文件指针位置
     * @param unknown $offset
     * @param string $whence
     * @return number
     */
    public function setSeek($offset, $whence = SEEK_SET){
        return fseek($this->fp, $offset, $whence);
    }
    
    /**
     * 关闭文件指针
     * @return boolean
     */
    public function close(){
        return fclose($this->fp);
    }
    
    public static function getSql($file, $isarray = false){
        
        $content = preg_replace(['/[
|
]+s?(((--s+|#).*)|/*(.|
)**/)/', '/[
|
]+/'], '', file_get_contents($file));
        if($isarray) $content = array_filter(explode(';', $content));
        return $content;
    }

}