Ticket #5: RecordProxy.class.php

<?php
function checkArray($v){
if (! is_array($v)) return array($v);
return $v;
}

abstract class RecordProxy{
        protected $record;
    protected $dao_selector;
        function __construct($id, $dao){
    //id can be a pkey, an array of pkeys or a record
        if (is_a($id, 'jDaoRecordBase')) $this->record=$id;
        else {
            $f=jDao::get($dao);
            if ($id == null) $this->record=jDao::createRecord($dao);
            else $this->record=$f->get($id);            
        }
        $this->dao_selector=$dao;
        }
    function __get($nm){
                if (isset($this->record->$nm)) {
                        $r = $this->record->$nm;
                return $r;
                }
        }
        function __set($nm, $val){
                        $this->record->$nm=$val;
        }
    function __call(string $name, array $arguments){ return $this->record->$name($arguments);}
    function insert(){
        $f=jDao::get($this->dao_selector);
        $f->insert($this->record);
        $conn = jDb::getConnection();
        return $conn->lastInsertId();
     }
     function delete(){
         $f=jDao::get($this->dao_selector);
         $f->delete($this->record->getPk());
     }
}

class MapDao {
    private $pkey;
    private $map;
    private $map_dao;
    private $pkey_name;
    function __construct($pkey, $pkey_name, $map_dao){        
        $this->pkey=checkArray($pkey);
        $this->map_dao=$map_dao;
        $this->pkey_name=checkArray($pkey_name);    
    }
    private function fetchAll($order=array()){
            $fact = jDao::get($this->map_dao);
            $conditions = jDao::createConditions();
            for ($i = 0; $i < count($this->pkey) ; $i++)
                $conditions->addCondition($this->pkey_name[$i],'=',$this->pkey[$i]);   
            foreach ($order as $field =>$way) 
                $conditions->addItemOrder($field, $way);
            return $fact->findBy($conditions)->fetchAll();
    }
    function count(){return count($this->fetchAll());}
    
    function get($order = array()){return $this->fetchAll($order);}
    
    function select($field_names, $field_values, $order=array()){
        return $this->selectBase($field_names, $field_values, $order)->fetchAll();
    }
    function includes($field_names, $field_values){        
        return $this->selectBase($field_names, $field_values)->rowCount() >0;
    }
    function map($field_names, $field_values){
    //adds an entry in the map (overwriting pkeys with specified fields is possible)
    //1 check for unicity
    if (! $this->includes($field_names,$field_values))
    {        
        //2 create the record
        $record = jDao::createRecord($this->map_dao);
        $pk = array_combine($this->pkey_name, $this->pkey);
        $additional = array_combine(checkArray($field_names),checkArray($field_values));
        foreach (array_merge($pk, $additional) as $name=>$val) $record->$name=$val;
        //3 save it !
        $fact = jDao::get($this->map_dao);
        return $fact->insert($record);
    }
    return null;
    }
    function unMap($field_names, $field_values){        
        $properties= jDao::createRecord($this->map_dao)->getProperties(); //record properties
        $pk = array_combine($this->pkey_name, $this->pkey);
        $additional = array_combine(checkArray($field_names),checkArray($field_values));
                
        $a=array_merge($pk, $additional);
        $pk=array();
        $fact = jDao::get($this->map_dao);
        foreach ($properties as $field){
            if ($field['isPK']) $pk [$field['name']] = $a [$field['name']];
        }
        $fact->delete($pk);
    }
    function unMapAll(){
    //unMaps all elements
    $fact = jDao::get($this->map_dao);
    foreach ($this->fetchAll() as $r)
        $fact->delete($r->getPk());
    }
    private function selectBase($field_names, $field_values, $order=array()){
        $fact = jDao::get($this->map_dao);
                $conditions = jDao::createConditions();
                for ($i = 0; $i < count($this->pkey) ; $i++)
                      $conditions->addCondition($this->pkey_name[$i],'=',$this->pkey[$i]);
        if (count(checkArray($field_names)) ==0) $fields=array();
        else $fields= array_combine(checkArray($field_names), checkArray($field_values));
        foreach ($fields as $name=>$value)
            $conditions->addCondition(trim($name),'=',trim($value));
        foreach ($order as $field_id=>$way) $conditions->addItemOrder($field_id, $way);
        return $fact->findBy($conditions);
    }
    
}

?>