classes/press/PressDAO.inc.php

<?php
import('classes.press.Press');

class PressDAO extends DAO {
   function PressDAO() {
      parent::DAO();
   }

   function getById($pressId) {
      $result =& $this->retrieve('SELECT * FROM presses WHERE press_id = ?', (int) $pressId);

      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner =& $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }

   function getNames() {
      $presses = array();

      $pressIterator =& $this->getPresses();
      while ($press =& $pressIterator->next()) {
         $presses[$press->getId()] = $press->getLocalizedName();
         unset($press);
      }
      unset($pressIterator);

      return $presses;
   }

   function newDataObject() {
      return new Press();
   }

   function &_fromRow(&$row) {
      $press = $this->newDataObject();
      $press->setId($row['press_id']);
      $press->setPath($row['path']);
      $press->setSequence($row['seq']);
      $press->setEnabled($row['enabled']);
      $press->setPrimaryLocale($row['primary_locale']);

      HookRegistry::call('PressDAO::_fromRow', array(&$press, &$row));

      return $press;
   }

   function pressExistsByPath($path) {
      $result =& $this->retrieve(
         'SELECT COUNT(*) FROM presses WHERE path = ?', $path
      );
      $returner = isset($result->fields[0]) && $result->fields[0] == 1 ? true : false;

      $result->Close();
      unset($result);

      return $returner;
   }

   function &getPressByPath($path) {
      $returner =& $this->getByPath($path);
      return $returner;
   }

   function &getByPath($path) {
      $returner = null;
      $result =& $this->retrieve(
         'SELECT * FROM presses WHERE path = ?', (string) $path
      );

      if ($result->RecordCount() != 0) {
         $returner =& $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      unset($result);
      return $returner;
   }

   function &getPresses($rangeInfo = null) {
      $result =& $this->retrieveRange(
         'SELECT * FROM presses ORDER BY seq',
         false, $rangeInfo
      );

      $returner = new DAOResultFactory($result, $this, '_fromRow');
      return $returner;
   }

   function insertObject(&$press) {
      $this->update(
         'INSERT INTO presses
            (path, seq, enabled, primary_locale)
            VALUES
            (?, ?, ?, ?)',
         array(
            $press->getPath(),
            (int) $press->getSequence() == null ? 0 : $press->getSequence(),
            $press->getEnabled() ? 1 : 0,
            $press->getPrimaryLocale()
         )
      );

      $press->setId($this->getInsertPressId());
      return $press->getId();
   }

   function updateObject(&$press) {
      return $this->update(
         'UPDATE presses
            SET
               path = ?,
               seq = ?,
               enabled = ?,
               primary_locale = ?
            WHERE press_id = ?',
         array(
            $press->getPath(),
            (int) $press->getSequence(),
            $press->getEnabled() ? 1 : 0,
            $press->getPrimaryLocale(),
            (int) $press->getId()
         )
      );
   }

   function &getEnabledPresses() {
      $result =& $this->retrieve(
         'SELECT * FROM presses WHERE enabled=1 ORDER BY seq'
      );

      $resultFactory = new DAOResultFactory($result, $this, '_fromRow');
      return $resultFactory;
   }

   function getInsertPressId() {
      return $this->getInsertId('presses', 'press_id');
   }

   function deleteById($pressId) {
      $pressSettingsDao =& DAORegistry::getDAO('PressSettingsDAO');
      $pressSettingsDao->deleteSettingsByPress($pressId);

      $seriesDao =& DAORegistry::getDAO('SeriesDAO');
      $seriesDao->deleteByPressId($pressId);

      $emailTemplateDao =& DAORegistry::getDAO('EmailTemplateDAO');
      $emailTemplateDao->deleteEmailTemplatesByPress($pressId);

      $monographDao =& DAORegistry::getDAO('MonographDAO');
      $monographDao->deleteByPressId($pressId);

      $userGroupDao =& DAORegistry::getDAO('UserGroupDAO');
      $userGroupDao->deleteAssignmentsByContextId($pressId);
      $userGroupDao->deleteByContextId($pressId);

      $pluginSettingsDao =& DAORegistry::getDAO('PluginSettingsDAO');
      $pluginSettingsDao->deleteSettingsByPressId($pressId);

      $reviewFormDao =& DAORegistry::getDAO('ReviewFormDAO');
      $reviewFormDao->deleteByAssocId(ASSOC_TYPE_PRESS, $pressId);

      $genreDao =& DAORegistry::getDAO('GenreDAO');
      $genreDao->deleteByPressId($pressId);

      $featureDao =& DAORegistry::getDAO('FeatureDAO');
      $featureDao->deleteByAssoc(ASSOC_TYPE_PRESS, $pressId);

      $newReleaseDao =& DAORegistry::getDAO('NewReleaseDAO');
      $newReleaseDao->deleteByAssoc(ASSOC_TYPE_PRESS, $pressId);

      $this->update('DELETE FROM press_defaults WHERE press_id = ?', (int) $pressId);

      return $this->update(
         'DELETE FROM presses WHERE press_id = ?', (int) $pressId
      );
   }

   function resequencePresses() {
      $result =& $this->retrieve(
         'SELECT press_id FROM presses ORDER BY seq'
      );

      for ($i=1; !$result->EOF; $i++) {
         list($pressId) = $result->fields;
         $this->update(
            'UPDATE presses SET seq = ? WHERE press_id = ?',
            array(
               $i,
               $pressId
            )
         );

         $result->MoveNext();
      }

      $result->Close();
      unset($result);
   }
}

?>