LibraryFileDAO.inc.php

<?php
 
import('lib.pkp.classes.context.LibraryFile');
 
class LibraryFileDAO extends DAO {
 
   function getById($fileId, $contextId = null) {
 
      $params = array((int) $fileId);
      if ($contextId) $params[] = (int) $contextId;
 
      $result = $this->retrieve(
         'SELECT file_id, context_id, file_name, original_file_name, file_type, file_size, type, date_uploaded, submission_id, public_access FROM library_files WHERE file_id = ?'
         . ($contextId ? ' AND context_id = ?' : ''),
         $params
      );
 
      $returner = null;
      if (isset($result) && $result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function getByContextId($contextId, $type = null) {
      $params = array((int) $contextId);
      if (isset($type)) $params[] = (int) $type;
 
      $result = $this->retrieve(
         'SELECT  *
         FROM  library_files
         WHERE context_id = ? AND submission_id = 0 ' . (isset($type)?' AND type = ?' : ''),
         $params
      );
      return new DAOResultFactory($result, $this, '_fromRow', array('id'));
   }
 
   function getBySubmissionId($submissionId, $type = null, $contextId = null) {
      $params = array((int) $submissionId);
      if (isset($type)) $params[] = (int) $type;
      if (isset($contextId)) $params[] = (int) $contextId;
 
      $result = $this->retrieve(
         'SELECT  *
         FROM  library_files
         WHERE submission_id = ? ' . (isset($contextId)?' AND context_id = ?' : '') . (isset($type)?' AND type = ?' : ''),
         $params
      );
      return new DAOResultFactory($result, $this, '_fromRow', array('id'));
   }
 
   function newDataObject() {
      return new LibraryFile();
   }
 
 
   function getLocaleFieldNames() {
      return array('name');
   }
 
   function updateLocaleFields(&$libraryFile) {
      $this->updateDataObjectSettings(
         'library_file_settings',
         $libraryFile,
         array('file_id' => $libraryFile->getId())
      );
   }
 
   function _fromRow($row) {
      $libraryFile = $this->newDataObject();
 
      $libraryFile->setId($row['file_id']);
      $libraryFile->setContextId($row['context_id']);
      $libraryFile->setServerFileName($row['file_name']);
      $libraryFile->setOriginalFileName($row['original_file_name']);
      $libraryFile->setFileType($row['file_type']);
      $libraryFile->setFileSize($row['file_size']);
      $libraryFile->setType($row['type']);
      $libraryFile->setDateUploaded($this->datetimeFromDB($row['date_uploaded']));
      $libraryFile->setSubmissionId($row['submission_id']);
      $libraryFile->setPublicAccess($row['public_access']);
 
      $this->getDataObjectSettings('library_file_settings', 'file_id', $row['file_id'], $libraryFile);
 
      HookRegistry::call('LibraryFileDAO::_fromRow', array(&$libraryFile, &$row));
 
      return $libraryFile;
   }
 
   function insertObject($libraryFile) {
      $params = array(
         (int) $libraryFile->getContextId(),
         $libraryFile->getServerFileName(),
         $libraryFile->getOriginalFileName(),
         $libraryFile->getFileType(),
         (int) $libraryFile->getFileSize(),
         (int) $libraryFile->getType(),
         (int) $libraryFile->getSubmissionId(),
         (int) $libraryFile->getPublicAccess()
      );
 
      if ($libraryFile->getId()) $params[] = (int) $libraryFile->getId();
 
      $this->update(
         sprintf('INSERT INTO library_files
            (context_id, file_name, original_file_name, file_type, file_size, type, submission_id, public_access, date_uploaded, date_modified' . ($libraryFile->getId()?', file_id':'') . ')
            VALUES
            (?, ?, ?, ?, ?, ?, ?, ?, %s, %s' . ($libraryFile->getId()?', ?':'') . ')',
            $this->datetimeToDB($libraryFile->getDateUploaded()),
            $this->datetimeToDB($libraryFile->getDateModified())
         ),
         $params
      );
 
      if (!$libraryFile->getId()) $libraryFile->setId($this->getInsertId());
 
      $this->updateLocaleFields($libraryFile);
      return $libraryFile->getId();
   }
 
   function updateObject($libraryFile) {
      $this->update(
         sprintf('UPDATE   library_files
            SET   context_id = ?,
               file_name = ?,
               original_file_name = ?,
               file_type = ?,
               file_size = ?,
               type = ?,
               submission_id = ?,
               public_access = ?,
               date_uploaded = %s
            WHERE file_id = ?',
            $this->datetimeToDB($libraryFile->getDateUploaded())
         ), array(
            (int) $libraryFile->getContextId(),
            $libraryFile->getServerFileName(),
            $libraryFile->getOriginalFileName(),
            $libraryFile->getFileType(),
            (int) $libraryFile->getFileSize(),
            (int) $libraryFile->getType(),
            (int) $libraryFile->getSubmissionId(),
            (int) $libraryFile->getPublicAccess(),
            (int) $libraryFile->getId()
         )
      );
 
      $this->updateLocaleFields($libraryFile);
      return $libraryFile->getId();
   }
 
   function deleteById($fileId, $revision = null) {
      $this->update(
         'DELETE FROM library_files WHERE file_id = ?',
         (int) $fileId
      );
      $this->update(
         'DELETE FROM library_file_settings WHERE file_id = ?',
         (int) $fileId
      );
   }
 
   function filenameExists($contextId, $fileName) {
      $result = $this->retrieve(
         'SELECT COUNT(*) FROM library_files WHERE context_id = ? AND file_name = ?',
         array((int) $contextId, $fileName)
      );
 
      $returner = (isset($result->fields[0]) && $result->fields[0] > 0) ? true : false;
      $result->Close();
      return $returner;
   }
 
   function getInsertId() {
      return $this->_getInsertId('library_files', 'file_id');
   }
}