classes/comment/CommentDAO.inc.php

Go to the documentation of this file.

<?php

//$Id$

import('comment.Comment');

define ('PAPER_COMMENT_RECURSE_ALL', -1);

class CommentDAO extends DAO {
   function &getRootCommentsByPaperId($paperId, $childLevels = 0) {
      $comments = array();

      $result =& $this->retrieve('SELECT * FROM comments WHERE paper_id = ? AND parent_comment_id IS NULL ORDER BY date_posted', $paperId);

      while (!$result->EOF) {
         $comments[] =& $this->_returnCommentFromRow($result->GetRowAssoc(false), $childLevels);
         $result->moveNext();
      }

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

      return $comments;
   }

   function &getCommentsByParentId($parentId, $childLevels = 0) {
      $comments = array();

      $result =& $this->retrieve('SELECT * FROM comments WHERE parent_comment_id = ? ORDER BY date_posted', $parentId);

      while (!$result->EOF) {
         $comments[] =& $this->_returnCommentFromRow($result->GetRowAssoc(false), $childLevels);
         $result->moveNext();
      }

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

      return $comments;
   }

   function &getCommentsByUserId($userId) {
      $comments = array();

      $result =& $this->retrieve('SELECT * FROM comments WHERE user_id = ?', $userId);

      while (!$result->EOF) {
         $comments[] =& $this->_returnCommentFromRow($result->GetRowAssoc(false));
         $result->moveNext();
      }

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

      return $comments;
   }

   function &getComment($commentId, $paperId, $childLevels = 0) {
      $result =& $this->retrieve(
         'SELECT * FROM comments WHERE comment_id = ? and paper_id = ?', array($commentId, $paperId)
      );

      $comment = null;
      if ($result->RecordCount() != 0) {
         $comment =& $this->_returnCommentFromRow($result->GetRowAssoc(false), $childLevels);
      }

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

      return $comment;
   }  

   function &_returnCommentFromRow($row, $childLevels = 0) {
      $userDao =& DAORegistry::getDAO('UserDAO');

      $comment = new Comment();
      $comment->setId($row['comment_id']);
      $comment->setPaperId($row['paper_id']);
      $comment->setUser($userDao->getUser($row['user_id']), true);
      $comment->setPosterIP($row['poster_ip']);
      $comment->setPosterName($row['poster_name']);
      $comment->setPosterEmail($row['poster_email']);
      $comment->setTitle($row['title']);
      $comment->setBody($row['body']);
      $comment->setDatePosted($this->datetimeFromDB($row['date_posted']));
      $comment->setDateModified($this->datetimeFromDB($row['date_modified']));
      $comment->setParentCommentId($row['parent_comment_id']);
      $comment->setChildCommentCount($row['num_children']);

      if (!HookRegistry::call('CommentDAO::_returnCommentFromRow', array(&$comment, &$row, &$childLevels))) {
         if ($childLevels>0) $comment->setChildren($this->getCommentsByParentId($row['comment_id'], $childLevels-1));
         else if ($childLevels==SUBMISSION_COMMENT_RECURSE_ALL) $comment->setChildren($this->getCommentsByParentId($row['comment_id'], SUBMISSION_COMMENT_RECURSE_ALL));
      }

      return $comment;
   }

   function insertComment(&$comment) {
      $comment->setDatePosted(Core::getCurrentDate());
      $comment->setDateModified($comment->getDatePosted());
      $user = $comment->getUser();
      $this->update(
         sprintf('INSERT INTO comments
            (paper_id, num_children, parent_comment_id, user_id, poster_ip, date_posted, date_modified, title, body, poster_name, poster_email)
            VALUES
            (?, ?, ?, ?, ?, %s, %s, ?, ?, ?, ?)',
            $this->datetimeToDB($comment->getDatePosted()), $this->datetimeToDB($comment->getDateModified())),
         array(
            $comment->getPaperId(),
            $comment->getChildCommentCount(),
            $comment->getParentCommentId(),
            (isset($user)?$user->getId():null),
            $comment->getPosterIP(),
            String::substr($comment->getTitle(), 0, 255),
            $comment->getBody(),
            String::substr($comment->getPosterName(), 0, 90),
            String::substr($comment->getPosterEmail(), 0, 90)
         )
      );

      $comment->setId($this->getInsertCommentId());

      if ($comment->getParentCommentId()) $this->incrementChildCount($comment->getParentCommentId());

      return $comment->getId();
   }

   function getInsertCommentId() {
      return $this->getInsertId('comments', 'comment_id');
   }  

   function incrementChildCount($commentId) {
      $this->update('UPDATE comments SET num_children=num_children+1 WHERE comment_id = ?', $commentId);
   }

   function decrementChildCount($commentId) {
      $this->update('UPDATE comments SET num_children=num_children-1 WHERE comment_id = ?', $commentId);
   }

   function deleteComment(&$comment, $isRecursing = false) {
      $result = $this->update('DELETE FROM comments WHERE comment_id = ?', $comment->getId());
      if (!$isRecursing) $this->decrementChildCount($comment->getParentCommentId());
      foreach ($comment->getChildren() as $child) {
         $this->deleteComment($child, true);
      }
   }

   function deleteCommentsByPaper($paperId) {
      return $this->update('DELETE FROM comments WHERE paper_id = ?', $paperId);
   }

   function updateComment(&$comment) {
      $comment->setDateModified(Core::getCurrentDate());
      $user = $comment->getUser();
      $this->update(
         sprintf('UPDATE paper_comments
            SET
               paper_id = ?,
               num_children = ?,
               parent_comment_id = ?,
               user_id = ?,
               poster_ip = ?,
               date_posted = %s,
               date_modified = %s,
               title = ?,
               body = ?,
               poster_name = ?,
               poster_email = ?
            WHERE comment_id = ?',
            $this->datetimeToDB($comment->getDatePosted()), $this->datetimeToDB($comment->getDateModified())),
         array(
            $comment->getPaperId(),
            $comment->getChildCommentCount(),
            $comment->getParentCommentId(),
            (isset($user)?$user->getId():null),
            $comment->getPosterIP(),
            String::substr($comment->getTitle(), 0, 255),
            $comment->getBody(),
            String::substr($comment->getPosterName(), 0, 90),
            String::substr($comment->getPosterEmail(), 0, 90),
            $comment->getId()
         )
      );
   }
}

?>

---