classes/comment/CommentDAO.inc.php

<?php

// $Id: CommentDAO.inc.php,v 1.22 2008/07/01 01:16:09 asmecher Exp $


import('comment.Comment');

define ('ARTICLE_COMMENT_RECURSE_ALL', -1);

// Comment system configuration constants
define ('COMMENTS_DISABLED', 0); // All comments disabled
define ('COMMENTS_AUTHENTICATED', 1);  // Can be posted by authenticated users
define ('COMMENTS_ANONYMOUS', 2);   // Can be posted anonymously by authenticated users
define ('COMMENTS_UNAUTHENTICATED', 3);   // Can be posted anonymously by anyone

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

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

      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', (int) $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 = ?', (int) $userId);

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

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

      return $comments;
   }

   function attributedCommentsExistForUser($userId) {
      $result =& $this->retrieve('SELECT count(*) FROM comments WHERE user_id = ?', (int) $userId);
      $returner = $result->fields[0]?true:false;
      $result->Close();
      return $returner;
   }

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

      $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->setCommentId($row['comment_id']);
      $comment->setArticleId($row['article_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==ARTICLE_COMMENT_RECURSE_ALL) $comment->setChildren($this->getCommentsByParentId($row['comment_id'], ARTICLE_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
            (article_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->getArticleId(),
            $comment->getChildCommentCount(),
            $comment->getParentCommentId(),
            (isset($user)?$user->getUserId():null),
            $comment->getPosterIP(),
            $comment->getTitle(),
            $comment->getBody(),
            $comment->getPosterName(),
            $comment->getPosterEmail()
         )
      );

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

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

      return $comment->getCommentId();
   }

   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->getCommentId());
      if (!$isRecursing) $this->decrementChildCount($comment->getParentCommentId());
      foreach ($comment->getChildren() as $child) {
         $this->deleteComment($child, true);
      }
   }

   function deleteCommentsByArticle($articleId) {
      return $this->update('DELETE FROM comments WHERE article_id = ?', $articleId);
   }

   function updateComment(&$comment) {
      $comment->setDateModified(Core::getCurrentDate());
      $user = $comment->getUser();
      $this->update(
         sprintf('UPDATE article_comments
            SET
               article_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->getArticleId(),
            $comment->getChildCommentCount(),
            $comment->getParentCommentId(),
            (isset($user)?$user->getUserId():null),
            $comment->getPosterIP(),
            $comment->getTitle(),
            $comment->getBody(),
            $comment->getPosterName(),
            $comment->getPosterEmail(),
            $comment->getCommentId()
         )
      );
   }
}

?>

---