QueryDAO.inc.php

<?php
 
import('lib.pkp.classes.query.Query');
 
class QueryDAO extends DAO {
 
   function getById($queryId, $assocType = null, $assocId = null) {
      $params = array((int) $queryId);
      if ($assocType) {
         $params[] = (int) $assocType;
         $params[] = (int) $assocId;
      }
      $result = $this->retrieve(
         'SELECT *
         FROM  queries
         WHERE query_id = ?'
            . ($assocType?' AND assoc_type = ? AND assoc_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function getByAssoc($assocType, $assocId, $stageId = null, $userId = null) {
      $params = array();
      $params[] = (int) ASSOC_TYPE_QUERY;
      if ($userId) $params[] = (int) $userId;
      $params[] = (int) $assocType;
      $params[] = (int) $assocId;
      if ($stageId) $params[] = (int) $stageId;
      if ($userId) $params[] = (int) $userId;
 
      return new DAOResultFactory(
         $this->retrieve(
            'SELECT  DISTINCT q.*
            FROM  queries q
            LEFT JOIN notes n ON n.assoc_type = ? AND n.assoc_id = q.query_id
            ' . ($userId?'INNER JOIN query_participants qp ON (q.query_id = qp.query_id AND qp.user_id = ?)':'') . '
            WHERE q.assoc_type = ? AND q.assoc_id = ?
            ' . ($stageId?' AND q.stage_id = ?':'') .
            ($userId?'
            AND (n.user_id = ? OR n.title IS NOT NULL
            OR n.contents IS NOT NULL)':'') . '
            ORDER BY q.seq',
            $params
         ),
         $this, '_fromRow'
      );
   }
 
   function _fromRow($row) {
      $query = $this->newDataObject();
      $query->setId($row['query_id']);
      $query->setAssocType($row['assoc_type']);
      $query->setAssocId($row['assoc_id']);
      $query->setStageId($row['stage_id']);
      $query->setIsClosed($row['closed']);
      $query->setSequence($row['seq']);
 
      HookRegistry::call('QueryDAO::_fromRow', array(&$query, &$row));
      return $query;
   }
 
   function newDataObject() {
      return new Query();
   }
 
   function insertObject($query) {
      $this->update(
         'INSERT INTO queries (assoc_type, assoc_id, stage_id, closed, seq)
         VALUES (?, ?, ?, ?, ?)',
         array(
            (int) $query->getAssocType(),
            (int) $query->getAssocId(),
            (int) $query->getStageId(),
            (int) $query->getIsClosed(),
            (float) $query->getSequence(),
         )
      );
      $query->setId($this->getInsertId());
      return $query->getId();
   }
 
   function insertParticipant($queryId, $userId) {
      $this->update(
         'INSERT INTO query_participants
         (query_id, user_id)
         VALUES
         (?, ?)',
         array(
            (int) $queryId,
            (int) $userId,
         )
      );
   }
 
   function removeParticipant($queryId, $userId) {
      $this->update(
         'DELETE FROM query_participants WHERE query_id = ? AND user_id = ?',
         array((int) $queryId, (int) $userId)
      );
   }
 
   function removeAllParticipants($queryId) {
      $this->update(
         'DELETE FROM query_participants WHERE query_id = ?',
         (int) $queryId
      );
   }
 
   function getParticipantIds($queryId, $userId = null) {
      $params = array((int) $queryId);
      if ($userId) $params[] = (int) $userId;
      $result = $this->retrieve(
         'SELECT  user_id
         FROM  query_participants
         WHERE query_id = ?' .
         ($userId?' AND user_id = ?':''),
         $params
      );
      $userIds = array();
      while (!$result->EOF) {
         $row = $result->getRowAssoc(false);
         $userIds[] = (int) $row['user_id'];
         $result->MoveNext();
      }
      $result->Close();
      return $userIds;
   }
 
   function updateObject($query) {
      $this->update(
         'UPDATE  queries
         SET   assoc_type = ?,
            assoc_id = ?,
            stage_id = ?,
            closed = ?,
            seq = ?
         WHERE query_id = ?',
         array(
            (int) $query->getAssocType(),
            (int) $query->getAssocId(),
            (int) $query->getStageId(),
            (int) $query->getIsClosed(),
            (float) $query->getSequence(),
            (int) $query->getId()
         )
      );
   }
 
   function deleteObject($query) {
      $this->deleteById($query->getId());
   }
 
   function deleteById($queryId, $assocType = null, $assocId = null) {
      $params = array((int) $queryId);
      if ($assocType) {
         $params[] = (int) $assocType;
         $params[] = (int) $assocId;
      }
      $this->update(
         'DELETE FROM queries WHERE query_id = ?' .
         ($assocType?' AND assoc_type = ? AND assoc_id = ?':''),
         $params
      );
      if ($this->getAffectedRows()) {
         $this->update('DELETE FROM query_participants WHERE query_id = ?', (int) $queryId);
 
         // Remove associated notes
         $noteDao = DAORegistry::getDAO('NoteDAO'); /* @var $noteDao NoteDAO */
         $noteDao->deleteByAssoc(ASSOC_TYPE_QUERY, $queryId);
 
         // Remove associated notifications
         $notificationDao = DAORegistry::getDAO('NotificationDAO'); /* @var $notificationDao NotificationDAO */
         $notifications = $notificationDao->getByAssoc(ASSOC_TYPE_QUERY, $queryId);
         while ($notification = $notifications->next()) {
            $notificationDao->deleteObject($notification);
         }
 
      }
   }
 
   function resequence($assocType, $assocId) {
      $result = $this->retrieve(
         'SELECT query_id FROM queries WHERE assoc_type = ? AND assoc_id = ? ORDER BY seq',
         array((int) $assocType, (int) $assocId)
      );
 
      for ($i=1; !$result->EOF; $i++) {
         list($queryId) = $result->fields;
         $this->update(
            'UPDATE queries SET seq = ? WHERE query_id = ?',
            array(
               $i,
               $queryId
            )
         );
 
         $result->MoveNext();
      }
      $result->Close();
   }
 
   function getInsertId() {
      return $this->_getInsertId('queries', 'query_id');
   }
 
   function deleteByAssoc($assocType, $assocId) {
      $queries = $this->getByAssoc($assocType, $assocId);
      while ($query = $queries->next()) {
         $this->deleteObject($query);
      }
   }
}