SubmissionSearchDAO.inc.php

<?php
 
class SubmissionSearchDAO extends DAO {
 
   function insertKeyword($keyword) {
      static $submissionSearchKeywordIds = array();
      if (isset($submissionSearchKeywordIds[$keyword])) return $submissionSearchKeywordIds[$keyword];
      $result = $this->retrieve(
         'SELECT keyword_id FROM submission_search_keyword_list WHERE keyword_text = ?',
         $keyword
      );
      if($result->RecordCount() == 0) {
         $result->Close();
         if ($this->update(
            'INSERT INTO submission_search_keyword_list (keyword_text) VALUES (?)',
            $keyword,
            true,
            false
         )) {
            $keywordId = $this->_getInsertId('submission_search_keyword_list', 'keyword_id');
         } else {
            $keywordId = null; // Bug #2324
         }
      } else {
         $keywordId = $result->fields[0];
         $result->Close();
      }
 
      $submissionSearchKeywordIds[$keyword] = $keywordId;
 
      return $keywordId;
   }
 
   function deleteSubmissionKeywords($submissionId, $type = null, $assocId = null) {
      $sql = 'SELECT object_id FROM submission_search_objects WHERE submission_id = ?';
      $params = array((int) $submissionId);
 
      if (isset($type)) {
         $sql .= ' AND type = ?';
         $params[] = (int) $type;
      }
 
      if (isset($assocId)) {
         $sql .= ' AND assoc_id = ?';
         $params[] = (int) $assocId;
      }
 
      $result = $this->retrieve($sql, $params);
      while (!$result->EOF) {
         $objectId = $result->fields[0];
         $this->update('DELETE FROM submission_search_object_keywords WHERE object_id = ?', $objectId);
         $this->update('DELETE FROM submission_search_objects WHERE object_id = ?', $objectId);
         $result->MoveNext();
      }
      $result->Close();
   }
 
   function insertObject($submissionId, $type, $assocId, $keepExisting = false) {
      $result = $this->retrieve(
         'SELECT object_id FROM submission_search_objects WHERE submission_id = ? AND type = ? AND assoc_id = ?',
         array((int) $submissionId, (int) $type, (int) $assocId)
      );
      if ($result->RecordCount() == 0) {
         $this->update(
            'INSERT INTO submission_search_objects (submission_id, type, assoc_id) VALUES (?, ?, ?)',
            array((int) $submissionId, (int) $type, (int) $assocId)
         );
         $objectId = $this->_getInsertId('submission_search_objects', 'object_id');
 
      } else {
         $objectId = $result->fields[0];
         $this->update(
            'DELETE FROM submission_search_object_keywords WHERE object_id = ?',
            (int) $objectId
         );
      }
      $result->Close();
      return $objectId;
   }
 
   function insertObjectKeyword($objectId, $keyword, $position) {
      $keywordId = $this->insertKeyword($keyword);
      if ($keywordId === null) return null; // Bug #2324
      $this->update(
         'INSERT INTO submission_search_object_keywords (object_id, keyword_id, pos) VALUES (?, ?, ?)',
         array((int) $objectId, (int) $keywordId, (int) $position)
      );
      return $keywordId;
   }
 
   function clearIndex() {
      $this->update('DELETE FROM submission_search_object_keywords');
      $this->update('DELETE FROM submission_search_objects');
      $this->update('DELETE FROM submission_search_keyword_list');
      $this->setCacheDir(Config::getVar('files', 'files_dir') . '/_db');
      $dataSource = $this->getDataSource();
      $dataSource->CacheFlush();
   }
}