Abstract.php

<?php
abstract class Dsao_Db_Table_DataHandler_Row_Abstract
  extends Dsao_Db_Table_DataHandler_Abstract
{
  protected $_row = null;

  protected function _fetchMinimal($primaryKeyColumn = 'id')
  {
    $identifiers = $this->_getValidIdentifiers();

    // Select-Statement erstellen und nur primäre Spalte laden
    $select = $this->getTable()->select(true)
      ->reset(Zend_Db_Select::COLUMNS)->columns($primaryKeyColumn);

    // Where-Klausel aus Identifizierern bauen
    foreach ($identifiers as $identifier)
    {
      // Da die Identifizierer fest im Code verankert sind und keine vom
      // Benutzer übergebenene Werte, wird hier nicht gequotet
      $select->where($identifier.' = ?', $this->__get($identifier));
    }

    $row = $select->fetchRow();

    return ($row ? $row->toArray() : array());
  }

  public function delete()
  {
    parent::delete();

    // Falls Objekt noch nicht aus Datenbank geladen, erst laden und dann
    // löschen
    if (null === $this->isSynchronous())
    {
      $this->getSelect()->fetchRow()->delete();
    }
    // Ansonsten Zeile löschen
    else
    {
      $this->getRow(false)->delete();
    }

    return $this;
  }

  public function exists()
  {
    // Falls schon übergeordnete Funktion Vorhandensein eindeutig klären konnte
    if (null !== ($exists = parent::exists()))
    {
      return $exists;
    }

    $rowData = $this->_fetchMinimal();

    // Falls ID vorhanden und Objekt nicht schreib geschützt
    if (isset($rowData['id']) && !$this->isReadOnly())
    {
      $this->__set('id', $rowData['id']);
    }

    return (bool) $rowData;
  }

  public function getRow($throw = true)
  {
    // Falls Objekt nicht snychron oder noch nicht geladen wurde
    if ((!$this->isSynchronous() || null === $this->_row) && $throw)
    {
      throw new Dsao_Exception
        ('dsao_db_table_datahandler_row_abstract_row_asynchronous');
    }

    return $this->_row;
  }

  public function insert()
  {
    parent::insert($properties);

    // In Datenbank einfügen
    $this->getTable()->insert($this->_data->getArrayCopy());

    return $this;
  }

  public function refresh($override = false)
  {
    parent::refresh();

    // Falls Objekt mit Datenbank synchron oder Änderungen ignoriert werden
    // sollen, vorhandene Zeile aktualisieren
    if (true === $this->isSynchronous()
      || (false === $this->isSynchronous && $override))
    {
      $this->getRow(false)->refresh();
    }
    // Ansonsten Zeile laden
    else
    {
      $this->_fetchRow();

      $this->setData($this->_row->toArray());
    }

    return $this;
  }

  public function setRow(Zend_Db_Table_Row_Abstract $row)
  {
    // Falls Zeile zu einer anderen Tabelle gehört
    if ($row->getTable()->info(Zend_Db_Table_Abstract::NAME)
      != $this->getTable()->info(Zend_Db_Table_Abstract::NAME))
    {
      throw new Dsao_Exception
        ('dsao_db_table_datahandler_row_abstract_table_invalid');
    }

    // Zeile speichern
    $this->_row = $row;

    // Daten setzen
    $this->_data = $row->toArray();

    // Als synchron und gültig markieren
    $this->_synchronous = true;
    $this->_valid = true;

    return $this;
  }

  public function update(array $properties = array())
  {
    $this->getRow(false)->setFromArray($this->getData($properties))->save();
  }
}