classes/press/CategoryDAO.inc.php

<?php

import ('classes.press.Category');

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

   function &getById($categoryId, $pressId = null, $parentId = null) {
      $params = array((int) $categoryId);
      if ($pressId) $params[] = (int) $pressId;
      if ($parentId) $params[] = (int) $parentId;

      $result =& $this->retrieve(
         'SELECT  *
         FROM  categories
         WHERE category_id = ?
         ' . ($pressId?' AND press_id = ?':'') . '
         ' . ($parentId?' AND parent_id = ?':''),
         $params
      );

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

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

      return $returner;
   }

   function &getByPath($path, $pressId) {
      $returner = null;
      $result =& $this->retrieve(
         'SELECT * FROM categories WHERE path = ? AND press_id = ?',
         array((string) $path, (int) $pressId)
      );

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

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

      return $returner;
   }

   function &getByTitle($categoryTitle, $pressId, $locale = null) {
      $params = array('title', $categoryTitle, (int) $pressId);
      if ($locale) $params[] = $locale;

      $result =& $this->retrieve(
         'SELECT  a.*
         FROM  categories a,
            category_settings l
         WHERE l.category_id = a.category_id AND
            l.setting_name = ? AND
            l.setting_value = ?
            AND a.press_id = ?
            ' . ($locale?' AND locale = ?':''),
         $params
      );

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

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

      return $returner;
   }

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

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

      return $returner;
   }

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

   function _fromRow(&$row) {
      $category = $this->newDataObject();

      $category->setId($row['category_id']);
      $category->setPressId($row['press_id']);
      $category->setParentId($row['parent_id']);
      $category->setPath($row['path']);
      $category->setImage(unserialize($row['image']));

      $this->getDataObjectSettings('category_settings', 'category_id', $row['category_id'], $category);

      HookRegistry::call('CategoryDAO::_fromRow', array(&$category, &$row));

      return $category;
   }

   function getLocaleFieldNames() {
      return array('title', 'description');
   }

   function updateLocaleFields(&$category) {
      $this->updateDataObjectSettings(
         'category_settings', $category,
         array(
            'category_id' => $category->getId()
         )
      );
   }

   function insertObject(&$category) {
      $this->update(
         'INSERT INTO categories
            (press_id, parent_id, path, image)
            VALUES
            (?, ?, ?, ?)',
         array(
            (int) $category->getPressId(),
            (int) $category->getParentId(),
            $category->getPath(),
            serialize($category->getImage() ? $category->getImage() : array()),
         )
      );

      $category->setId($this->getInsertCategoryId());
      $this->updateLocaleFields($category);
      return $category->getId();
   }

   function updateObject($category) {
      $returner = $this->update(
         'UPDATE  categories
         SET   press_id = ?,
            parent_id = ?,
            path = ?,
            image = ?
         WHERE category_id = ?',
         array(
            (int) $category->getPressId(),
            (int) $category->getParentId(),
            $category->getPath(),
            serialize($category->getImage() ? $category->getImage() : array()),
            (int) $category->getId()
         )
      );
      $this->updateLocaleFields($category);
      return $returner;
   }

   function deleteObject(&$category) {
      return $this->deleteById(
         $category->getId(),
         $category->getPressId()
      );
   }

   function deleteById($categoryId, $pressId = null) {
      $params = array((int) $categoryId);
      if ($pressId) $params[] = (int) $pressId;

      $this->update(
         'DELETE FROM categories
         WHERE category_id = ?
            ' . ($pressId?' AND press_id = ?':''),
         $params
      );

      // If the category was deleted (this validates press_id,
      // if specified), delete any associated settings as well.
      if ($this->getAffectedRows()) {
         $this->update(
            'DELETE FROM category_settings WHERE category_id = ?',
            array((int) $categoryId)
         );

         // remove any monograph assignments for this category.
         $this->update(
            'DELETE FROM monograph_categories WHERE category_id = ?',
            array((int) $categoryId)
         );
      }
   }

   function deleteByPressId($pressId) {
      $categories =& $this->getByPressId($pressId);
      while ($category =& $categories->next()) {
         $this->deleteObject($category, $pressId);
         unset($category);
      }
   }

   function &getByPressId($pressId, $rangeInfo = null) {
      // The strange ORDER BY clause is to return subcategories
      // immediately after their parent category's entry.
      $result =& $this->retrieveRange(
         'SELECT  *
         FROM  categories
         WHERE press_id = ?
         ORDER BY CASE WHEN parent_id = 0 THEN category_id * 2 ELSE (parent_id * 2) + 1 END ASC',
         array((int) $pressId)
      );

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

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

      $returner = $result->fields[0];

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

   function &getByParentId($parentId, $pressId = null, $rangeInfo = null) {
      $params = array((int) $parentId);
      if ($pressId) $params[] = (int) $pressId;

      $result =& $this->retrieveRange(
         'SELECT  *
         FROM  categories
         WHERE parent_id = ?
         ' . ($pressId?' AND press_id = ?':''),
         $params
      );

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

   function getInsertCategoryId() {
      return $this->getInsertId('categories', 'category_id');
   }
}

?>