classes/press/NewReleaseDAO.inc.php

<?php

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

   function getMonographIdsByAssoc($assocType, $assocId) {
      $returner = array();
      $result =& $this->retrieve(
         'SELECT monograph_id FROM new_releases WHERE assoc_type = ? AND assoc_id = ?',
         array((int) $assocType, (int) $assocId)
      );

      while (!$result->EOF) {
         list($monographId) = $result->fields;
         $returner[$monographId] = true;
         $result->MoveNext();
      }

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

      return $returner;
   }

   function getMonographsByAssoc($assocType, $assocId) {
      $returner = array();
      $result =& $this->retrieve(
            'SELECT n.monograph_id FROM new_releases n, published_monographs pm
            WHERE n.monograph_id = pm.monograph_id AND assoc_type = ? AND assoc_id = ? ORDER BY pm.date_published DESC',
            array((int) $assocType, (int) $assocId)
      );

      $publishedMonographDao =& DAORegistry::getDAO('PublishedMonographDAO');
      while (!$result->EOF) {
         list($monographId) = $result->fields;
         $returner[] =& $publishedMonographDao->getById($monographId);
         $result->MoveNext();
      }

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

      return $returner;
   }

   function insertNewRelease($monographId, $assocType, $assocId) {
      $this->update(
         'INSERT INTO new_releases
            (monograph_id, assoc_type, assoc_id)
            VALUES
            (?, ?, ?)',
         array(
            (int) $monographId,
            (int) $assocType,
            (int) $assocId
         )
      );
   }

   function deleteByMonographId($monographId) {
      $this->update(
         'DELETE FROM new_releases WHERE monograph_id = ?',
         (int) $monographId
      );
   }

   function deleteByAssoc($assocType, $assocId) {
      $this->update(
         'DELETE FROM new_releases WHERE assoc_type = ? AND assoc_id = ?',
         array((int) $assocType, (int) $assocId)
      );
   }

   function deleteNewRelease($monographId, $assocType, $assocId) {
      $this->update(
         'DELETE FROM new_releases
         WHERE monograph_id = ? AND
            assoc_type = ? AND
            assoc_id = ?',
         array(
            (int) $monographId,
            (int) $assocType,
            (int) $assocId
         )
      );
   }
}

?>