data_source_csv.inc

<?php
require_once SQ_CORE_PACKAGE_PATH.'/../include/asset.inc';
require_once SQ_CORE_PACKAGE_PATH.'/data_source/data_source/data_source.inc';


class Data_Source_Csv extends Data_Source
{


    function __construct($assetid=0)
    {
        parent::__construct($assetid);

    }//end constructor
    
    
    public function _getAllowedLinks()
    {
        // any link is allowed
        $allowed_link['asset']['card'] = 'M';
        $allowed_link['asset']['exclusive'] = FALSE;

        $links[SQ_LINK_TYPE_1] = $allowed_link;
        $links[SQ_LINK_TYPE_2] = $allowed_link;
        $links[SQ_LINK_TYPE_3] = $allowed_link;
        $links[SQ_LINK_NOTICE] = $allowed_link;

        return $links;

    }//end _getAllowedLinks()
    

    function getResultSet()
    {
        $GLOBALS['SQ_SYSTEM']->pm->startTimer($this);
        $result = Array();
        $result = parent::getResultSet($this->name);
        if (empty($result)) {
                if (empty($result)) $result = $this->getItems();
                if (!empty($result)) {
                    parent::setResultSet($result, $this->name);
                }
        }
        $GLOBALS['SQ_SYSTEM']->pm->stopTimer($this);
        return $result;

    }//end getResultSet()


    function getItems()
    {
        // lets get the content
        $content = $this->attr('cached_content');
        $use_header_row = $this->attr('header_row');

        if (empty($content)) return Array();

        // Initialise to handle blank content
        $fields = Array();
        $new_content = Array();

        // Use header row?
        if ($use_header_row) {
            foreach ($content[0] as $header) {
                $fields[] = strtolower(str_replace(' ', '_', trim($header)));
            }

        } else {
            for ($c = 0; $c < count($content[0]) ; $c++) {
                $fields[$c] = 'field_'.$c;
            }
        }

        $rc = 0;
        foreach ($content as $record) {

            if ($rc == 0 && $use_header_row) {
                $rc++;
                continue;
            }

            for ($f = 0; $f < count($fields); $f++) {
                $record_id = ($use_header_row ? $rc - 1 : $rc);
                $new_content[$record_id][trim($fields[$f])] = trim($record[$f]);
            }

            $rc++;

        }//end foreach

        return $new_content;

    }//end getItems()


}//end class

?>