IssueFileDAO.inc.php

<?php
 
import('lib.pkp.classes.db.DAO');
import('classes.issue.IssueFile');
 
class IssueFileDAO extends DAO {
 
   var $_inlineableTypes = null;
 
 
   function getInlineableTypes() {
      return $this->_inlineableTypes;
   }
 
   function setInlineableTypes($inlineableTypes) {
      $this->_inlineableTypes = $inlineableTypes;
   }
 
   function getById($fileId, $issueId = null) {
      $params = array((int) $fileId);
      if ($issueId) $params[] = (int) $issueId;
      $result = $this->retrieve(
         'SELECT f.*
         FROM  issue_files f
         WHERE f.file_id = ?
            ' . ($issueId?' AND f.issue_id = ?':''),
            $params
         );
      $returner = null;
      if (isset($result) && $result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   function newDataObject() {
      return new IssueFile();
   }
 
   function _fromRow($row) {
      $issueFile = $this->newDataObject();
      $issueFile->setId($row['file_id']);
      $issueFile->setIssueId($row['issue_id']);
      $issueFile->setServerFileName($row['file_name']);
      $issueFile->setFileType($row['file_type']);
      $issueFile->setFileSize($row['file_size']);
      $issueFile->setContentType($row['content_type']);
      $issueFile->setOriginalFileName($row['original_file_name']);
      $issueFile->setDateUploaded($this->datetimeFromDB($row['date_uploaded']));
      $issueFile->setDateModified($this->datetimeFromDB($row['date_modified']));
      HookRegistry::call('IssueFileDAO::_returnIssueFileFromRow', array(&$issueFile, &$row));
      return $issueFile;
   }
 
   function insertObject($issueFile) {
      $this->update(
         sprintf(
            'INSERT INTO issue_files
               (issue_id,
               file_name,
               file_type,
               file_size,
               content_type,
               original_file_name,
               date_uploaded,
               date_modified)
            VALUES
               (?, ?, ?, ?, ?, ?, %s, %s)',
            $this->datetimeToDB($issueFile->getDateUploaded()),
            $this->datetimeToDB($issueFile->getDateModified())
         ),
         array(
            (int) $issueFile->getIssueId(),
            $issueFile->getServerFileName(),
            $issueFile->getFileType(),
            $issueFile->getFileSize(),
            $issueFile->getContentType(),
            $issueFile->getOriginalFileName()
         )
      );
 
      $issueFile->setId($this->getInsertId());
      return $issueFile->getId();
   }
 
   function updateObject($issueFile) {
      $this->update(
         sprintf('UPDATE issue_files
            SET
               issue_id = ?,
               file_name = ?,
               file_type = ?,
               file_size = ?,
               content_type = ?,
               original_file_name = ?,
               date_uploaded = %s,
               date_modified = %s
            WHERE file_id = ?',
            $this->datetimeToDB($issueFile->getDateUploaded()),
            $this->datetimeToDB($issueFile->getDateModified())
         ),
         array(
            (int) $issueFile->getIssueId(),
            $issueFile->getServerFileName(),
            $issueFile->getFileType(),
            $issueFile->getFileSize(),
            $issueFile->getContentType(),
            $issueFile->getOriginalFileName(),
            (int) $issueFile->getId()
         )
      );
 
      return $issueFile->getId();
 
   }
 
   function deleteObject($issueFile) {
      $this->deleteById($issueFile->getId());
   }
 
   function deleteById($fileId) {
      $this->update(
         'DELETE FROM issue_files WHERE file_id = ?', (int) $fileId
      );
   }
 
   function deleteByIssueId($issueId) {
      $this->update(
         'DELETE FROM issue_files WHERE issue_id = ?', (int) $issueId
      );
   }
 
   function getInsertId() {
      return $this->_getInsertId('issue_files', 'file_id');
   }
}