csv_data.php

См. документацию.

<?php
 
class CCSVData
{
    var $sFileName;           // full file name
    var $sContent;         // file contents
    var $iFileLength;       // file length
    var $iCurPos = 0;       // current file position Fetch
    var $cFieldsType = "R";     // fields type: R - with delimiter, F - fixed width
    var $cDelimiter = ";";       // field delimiter
    var $arWidthMap = array();  // array of delimiters positions in fixed width case
    var $bFirstHeader = false; // 1 row - columns titles
 
    var $__file = null;
    var $__buffer = "";
    var $__buffer_pos = 0;
    var $__buffer_size = 0;
    var $__hasBOM = false;
 
    public function __construct($fields_type = "R", $first_header = false)
    {
        $this->SetFieldsType($fields_type);
        $this->SetFirstHeader($first_header);
    }
 
    public function LoadFile($filename)
    {
        $this->sFileName = $filename;
        $file = fopen($this->sFileName, "rb");
        if (is_resource($file))
        {
            $this->__file = $file;
            $this->iFileLength = filesize($this->sFileName);
            $this->CheckUTF8BOM();
            $this->SetPos();
            return true;
        }
        return false;
    }
 
    public function CloseFile()
    {
        if($this->__file)
        {
            fclose($this->__file);
            $this->__file = null;
        }
    }
 
    public function CheckUTF8BOM()
    {
        if (!$this->__file)
        {
            return;
        }
 
        //check UTF-8 Byte-Order Mark
        fseek($this->__file, 0);
        $sBOM = fread($this->__file, 3);
        if($sBOM == "\xEF\xBB\xBF")
        {
            $this->__hasBOM = true;
        }
    }
 
    public function SetFieldsType($fields_type = "R")
    {
        $this->cFieldsType = ($fields_type == "F"? "F" : "R");
    }
 
    public function SetDelimiter($delimiter = ";")
    {
        $this->cDelimiter = (mb_strlen($delimiter) > 1? mb_substr($delimiter, 0, 1) : $delimiter);
    }
 
    public function SetFirstHeader($first_header = false)
    {
        $this->bFirstHeader = $first_header;
    }
 
    public function GetFirstHeader()
    {
        return $this->bFirstHeader;
    }
 
    public function SetWidthMap($arMap)
    {
        $this->arWidthMap = array();
        for ($i = 0, $n = count($arMap); $i < $n; $i++)
        {
            $this->arWidthMap[$i] = intval($arMap[$i]);
        }
    }
 
    public function FetchDelimiter()
    {
        if (!$this->__file)
        {
            return false;
        }
 
        $bInString = false;
        $str = "";
        $res_r = array();
        while ($this->iCurPos < $this->iFileLength)
        {
            $ch = $this->__buffer[$this->__buffer_pos];
            if ($ch == "\r" || $ch == "\n")
            {
                if (!$bInString)
                {
                    while ($this->iCurPos < $this->iFileLength)
                    {
                        $this->IncCurPos();
                        $ch = $this->__buffer[$this->__buffer_pos];
                        if ($ch != "\r" && $ch != "\n")
                        {
                            break;
                        }
                    }
                    if ($this->bFirstHeader)
                    {
                        $this->bFirstHeader = false;
                        $res_r = array();
                        $str = "";
                        continue;
                    }
                    else
                    {
                        $res_r[] = $str;
                        return $res_r;
                    }
                }
            }
            elseif ($ch == "\"")
            {
                if (!$bInString)
                {
                    $bInString = true;
                    $this->IncCurPos();
                    continue;
                }
                else
                {
                    $this->IncCurPos();
                    if($this->__buffer[$this->__buffer_pos]!="\"")
                    {
                        $bInString = false;
                        continue;
                    }
                }
            }
            elseif ($ch == $this->cDelimiter)
            {
                if (!$bInString)
                {
                    $res_r[] = $str;
                    $str = "";
                    $this->IncCurPos();
                    continue;
                }
            }
 
            //inline "call"
            $this->iCurPos++;
            $this->__buffer_pos++;
            if($this->__buffer_pos >= $this->__buffer_size)
            {
                if(feof($this->__file))
                {
                    $this->__buffer = "";
                }
                else
                {
                    $this->__buffer = fread($this->__file, 1024*1024);
                }
                $this->__buffer_size = strlen($this->__buffer);
                $this->__buffer_pos = 0;
            }
 
            $str .= $ch;
        }
 
        if ($str <> '')
        {
            $res_r[] = $str;
        }
 
        if(empty($res_r))
        {
            return false;
        }
        else
        {
            return $res_r;
        }
    }
 
    public function FetchWidth()
    {
        if (!$this->__file)
        {
            return false;
        }
 
        $str = "";
        $ind = 1;
        $jnd = 0;
        $res_r = array();
 
        while ($this->iCurPos < $this->iFileLength)
        {
            $ch = $this->__buffer[$this->__buffer_pos];
            if ($ch == "\r" || $ch == "\n")
            {
                while ($this->iCurPos < $this->iFileLength)
                {
                    $this->IncCurPos();
                    $ch = $this->__buffer[$this->__buffer_pos];
                    if ($ch != "\r" && $ch != "\n")
                    {
                        break;
                    }
                }
                if ($this->bFirstHeader)
                {
                    $this->bFirstHeader = false;
                    $res_r = array();
                    $ind = 1;
                    $str = "";
                    continue;
                }
                else
                {
                    $res_r[] = $str;
                    return $res_r;
                }
            }
            elseif ($ind == $this->arWidthMap[$jnd])
            {
                $res_r[] = $str.$ch;
                $str = "";
                $this->IncCurPos();
                $ind++;
                $jnd++;
                continue;
            }
 
            //inline "call"
            $this->iCurPos++;
            $this->__buffer_pos++;
            if($this->__buffer_pos >= $this->__buffer_size)
            {
                if(feof($this->__file))
                {
                    $this->__buffer = "";
                }
                else
                {
                    $this->__buffer = fread($this->__file, 1024*1024);
                }
                $this->__buffer_size = strlen($this->__buffer);
                $this->__buffer_pos = 0;
            }
 
            $ind++;
            $str .= $ch;
        }
 
        if ($str <> '')
        {
            $res_r[] = $str;
        }
 
        if(empty($res_r))
        {
            return false;
        }
        else
        {
            return $res_r;
        }
    }
 
    public function Fetch()
    {
        if ($this->cFieldsType == "R")
        {
            if ($this->cDelimiter == '')
            {
                return false;
            }
            return $this->FetchDelimiter();
        }
        else
        {
            if (empty($this->arWidthMap))
            {
                return false;
            }
            return $this->FetchWidth();
        }
    }
 
    public function IncCurPos()
    {
        if (!$this->__file)
        {
            return;
        }
 
        $this->iCurPos++;
        $this->__buffer_pos++;
        if($this->__buffer_pos >= $this->__buffer_size)
        {
            if(feof($this->__file))
            {
                $this->__buffer = "";
            }
            else
            {
                $this->__buffer = fread($this->__file, 1024*1024);
            }
            $this->__buffer_size = strlen($this->__buffer);
            $this->__buffer_pos = 0;
        }
    }
 
    public function MoveFirst()
    {
        $this->SetPos();
    }
 
    public function GetPos()
    {
        return $this->iCurPos;
    }
 
    public function SetPos($iCurPos = 0)
    {
        if (!$this->__file)
        {
            return;
        }
 
        $iCurPos = intval($iCurPos);
        if ($iCurPos <= $this->iFileLength)
        {
            $this->iCurPos = $iCurPos;
        }
        else
        {
            $this->iCurPos = $this->iFileLength;
        }
 
        $pos = $this->iCurPos;
        if($this->__hasBOM)
        {
            $pos += 3;
        }
        fseek($this->__file, $pos);
 
        if(feof($this->__file))
        {
            $this->__buffer = "";
        }
        else
        {
            $this->__buffer = fread($this->__file, 1024*1024);
        }
        $this->__buffer_size = strlen($this->__buffer);
        $this->__buffer_pos = 0;
    }
 
    public function SaveFile($filename, $arFields)
    {
        $this->sFileName = $filename;
 
        if ($this->cFieldsType == 'R' && $this->cDelimiter <> '')
        {
            $this->sContent = '';
            for ($i = 0, $n = count($arFields); $i < $n; $i++)
            {
                if ($i>0)
                {
                    $this->sContent .= $this->cDelimiter;
                }
                $pos1 = mb_strpos($arFields[$i], $this->cDelimiter);
                $pos2 = mb_strpos($arFields[$i], "\"");
                $pos3 = mb_strpos($arFields[$i], "\n");
                $pos4 = mb_strpos($arFields[$i], "\r");
                if ($pos1 !== false || $pos2 !== false || $pos3 !== false || $pos4 !== false)
                {
                    $this->sContent .= "\"";
                    $this->sContent .= str_replace("\"", "\"\"", $arFields[$i]);
                    $this->sContent .= "\"";
                }
                else
                {
                    $this->sContent .= $arFields[$i];
                }
            }
            if ($this->sContent <> '')
            {
                $this->sContent .= "\n";
                $file_id = fopen($this->sFileName, "ab");
                fwrite($file_id, $this->sContent);
                fclose($file_id);
            }
        }
    }
}