classes/search/MonographSearchDAO.inc.php

<?php

import('classes.search.MonographSearch');

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

   function insertKeyword($keyword) {
      static $monographSearchKeywordIds = array();
      if (isset($monographSearchKeywordIds[$keyword])) return $monographSearchKeywordIds[$keyword];
      $result =& $this->retrieve(
         'SELECT keyword_id FROM monograph_search_keyword_list WHERE keyword_text = ?',
         $keyword
      );
      if($result->RecordCount() == 0) {
         $result->Close();
         unset($result);
         if ($this->update(
            'INSERT INTO monograph_search_keyword_list (keyword_text) VALUES (?)',
            $keyword,
            true,
            false
         )) {
            $keywordId = $this->getInsertId('monograph_search_keyword_list', 'keyword_id');
         } else {
            $keywordId = null; // Bug #2324
         }
      } else {
         $keywordId = $result->fields[0];
         $result->Close();
         unset($result);
      }

      $monographSearchKeywordIds[$keyword] = $keywordId;

      return $keywordId;
   }

   function &getPhraseResults(&$press, $phrase, $publishedFrom = null, $publishedTo = null, $type = null, $limit = 500, $cacheHours = 24) {
      import('lib.pkp.classes.db.DBRowIterator');
      if (empty($phrase)) {
         $results = false;
         $returner = new DBRowIterator($results);
         return $returner;
      }

      $sqlFrom = '';
      $sqlWhere = '';

      for ($i = 0, $count = count($phrase); $i < $count; $i++) {
         if (!empty($sqlFrom)) {
            $sqlFrom .= ', ';
            $sqlWhere .= ' AND ';
         }
         $sqlFrom .= 'monograph_search_object_keywords o'.$i.' NATURAL JOIN monograph_search_keyword_list k'.$i;
         if (strstr($phrase[$i], '%') === false) $sqlWhere .= 'k'.$i.'.keyword_text = ?';
         else $sqlWhere .= 'k'.$i.'.keyword_text LIKE ?';
         if ($i > 0) $sqlWhere .= ' AND o0.object_id = o'.$i.'.object_id AND o0.pos+'.$i.' = o'.$i.'.pos';

         $params[] = $phrase[$i];
      }

      if (!empty($type)) {
         $sqlWhere .= ' AND (o.type & ?) != 0';
         $params[] = $type;
      }

      if (!empty($press)) {
         $sqlWhere .= ' AND m.press_id = ?';
         $params[] = $press->getId();
      }

      $result =& $this->retrieveCached(
         'SELECT
            o.monograph_id,
            COUNT(*) AS count
         FROM
            monographs m,
            published_monographs pm,
            monograph_search_objects o NATURAL JOIN ' . $sqlFrom . '
         WHERE
            m.monograph_id = pm.monograph_id AND o.monograph_id = m.monograph_id AND ' . $sqlWhere . '
         GROUP BY o.monograph_id
         ORDER BY count DESC
         LIMIT ' . $limit,
         $params,
         3600 * $cacheHours // Cache for 24 hours
      );

      $returner = new DBRowIterator($result);
      return $returner;
   }

   function deleteMonographKeywords($monographId, $type = null, $assocId = null) {
      $sql = 'SELECT object_id FROM monograph_search_objects WHERE monograph_id = ?';
      $params = array($monographId);

      if (isset($type)) {
         $sql .= ' AND type = ?';
         $params[] = $type;
      }

      if (isset($assocId)) {
         $sql .= ' AND assoc_id = ?';
         $params[] = $assocId;
      }

      $result =& $this->retrieve($sql, $params);
      while (!$result->EOF) {
         $objectId = $result->fields[0];
         $this->update('DELETE FROM monograph_search_object_keywords WHERE object_id = ?', $objectId);
         $this->update('DELETE FROM monograph_search_objects WHERE object_id = ?', $objectId);
         $result->MoveNext();
      }
      $result->Close();
      unset($result);
   }

   function insertObject($monographId, $type, $assocId, $keepExisting = false) {
      $result =& $this->retrieve(
         'SELECT object_id FROM monograph_search_objects WHERE monograph_id = ? AND type = ? AND assoc_id = ?',
         array($monographId, $type, $assocId)
      );
      if ($result->RecordCount() == 0) {
         $this->update(
            'INSERT INTO monograph_search_objects (monograph_id, type, assoc_id) VALUES (?, ?, ?)',
            array($monographId, $type, (int) $assocId)
         );
         $objectId = $this->getInsertId('monograph_search_objects', 'object_id');

      } else {
         $objectId = $result->fields[0];
         $this->update(
            'DELETE FROM monograph_search_object_keywords WHERE object_id = ?',
            $objectId
         );
      }
      $result->Close();
      unset($result);

      return $objectId;
   }

   function insertObjectKeyword($objectId, $keyword, $position) {
      $keywordId = $this->insertKeyword($keyword);
      if ($keywordId === null) return null; // Bug #2324
      $this->update(
         'INSERT INTO monograph_search_object_keywords (object_id, keyword_id, pos) VALUES (?, ?, ?)',
         array($objectId, $keywordId, $position)
      );
      return $keywordId;
   }
}

?>