class.ilADTDBBridge.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2009 ILIAS open source, Extended GPL, see docs/LICENSE */

abstract class ilADTDBBridge
{
    protected $adt; // [ilADT]
    protected $table; // [string]
    protected $id; // [string]
    protected $primary = []; // [array]
    
    public function __construct(ilADT $a_adt)
    {
        $this->setADT($a_adt);
    }
    
    //
    // properties
    //
    
    abstract protected function isValidADT(ilADT $a_adt);
    
    protected function setADT(ilADT $a_adt)
    {
        if (!$this->isValidADT($a_adt)) {
            throw new Exception('ADTDBBridge Type mismatch.');
        }
        
        $this->adt = $a_adt;
    }
    
    public function getADT()
    {
        return $this->adt;
    }
    
    public function setTable($a_table)
    {
        $this->table = (string) $a_table;
    }
    
    public function getTable()
    {
        return $this->table;
    }
    
    public function setElementId($a_value)
    {
        $this->id = (string) $a_value;
    }
    
    public function getElementId()
    {
        return $this->id;
    }
    
    public function setPrimary(array $a_value)
    {
        $this->primary = $a_value;
    }
    
    public function getPrimary()
    {
        return $this->primary;
    }
    
    public function buildPrimaryWhere()
    {
        global $DIC;

        $ilDB = $DIC['ilDB'];
                
        $sql = array();
        
        foreach ($this->primary as $field => $def) {
            $sql[] = $field . "=" . $ilDB->quote($def[1], $def[0]);
        }
        
        return implode(" AND ", $sql);
    }
    
    
    //
    // CRUD
    //
    
    abstract public function readRecord(array $a_row);
    
    abstract public function prepareInsert(array &$a_fields);
    
    public function afterInsert()
    {
    }
    
    public function prepareUpdate(array &$a_fields)
    {
        $this->prepareInsert($a_fields);
    }
    
    public function afterUpdate()
    {
    }

    public function afterDelete()
    {
    }

    public function supportsDefaultValueColumn() : bool
    {
        return true;
    }
}