TemporaryFileDAO.inc.php

<?php
 
import('lib.pkp.classes.file.TemporaryFile');
 
class TemporaryFileDAO extends DAO {
 
   function getTemporaryFile($fileId, $userId) {
      $result = $this->retrieveLimit(
         'SELECT t.* FROM temporary_files t WHERE t.file_id = ? and t.user_id = ?',
         array((int) $fileId, (int) $userId),
         1
      );
 
      $returner = null;
      if (isset($result) && $result->RecordCount() != 0) {
         $returner = $this->_returnTemporaryFileFromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function newDataObject() {
      return new TemporaryFile();
   }
 
   function _returnTemporaryFileFromRow($row) {
      $temporaryFile = $this->newDataObject();
      $temporaryFile->setId($row['file_id']);
      $temporaryFile->setServerFileName($row['file_name']);
      $temporaryFile->setFileType($row['file_type']);
      $temporaryFile->setFileSize($row['file_size']);
      $temporaryFile->setUserId($row['user_id']);
      $temporaryFile->setOriginalFileName($row['original_file_name']);
      $temporaryFile->setDateUploaded($this->datetimeFromDB($row['date_uploaded']));
 
      HookRegistry::call('TemporaryFileDAO::_returnTemporaryFileFromRow', array(&$temporaryFile, &$row));
 
      return $temporaryFile;
   }
 
   function insertObject($temporaryFile) {
      $this->update(
         sprintf('INSERT INTO temporary_files
            (user_id, file_name, file_type, file_size, original_file_name, date_uploaded)
            VALUES
            (?, ?, ?, ?, ?, %s)',
            $this->datetimeToDB($temporaryFile->getDateUploaded())),
         array(
            (int) $temporaryFile->getUserId(),
            $temporaryFile->getServerFileName(),
            $temporaryFile->getFileType(),
            (int) $temporaryFile->getFileSize(),
            $temporaryFile->getOriginalFileName()
         )
      );
 
      $temporaryFile->setId($this->getInsertId());
      return $temporaryFile->getId();
   }
 
   function updateObject($temporaryFile) {
      $this->update(
         sprintf('UPDATE temporary_files
            SET
               file_name = ?,
               file_type = ?,
               file_size = ?,
               user_id = ?,
               original_file_name = ?,
               date_uploaded = %s
            WHERE file_id = ?',
            $this->datetimeToDB($temporaryFile->getDateUploaded())),
         array(
            $temporaryFile->getServerFileName(),
            $temporaryFile->getFileType(),
            (int) $temporaryFile->getFileSize(),
            (int) $temporaryFile->getUserId(),
            $temporaryFile->getOriginalFileName(),
            (int) $temporaryFile->getId()
         )
      );
 
      return $temporaryFile->getId();
   }
 
   function deleteTemporaryFileById($fileId, $userId) {
      return $this->update(
         'DELETE FROM temporary_files WHERE file_id = ? AND user_id = ?',
         array((int) $fileId, (int) $userId)
      );
   }
 
   function deleteByUserId($userId) {
      return $this->update(
         'DELETE FROM temporary_files WHERE user_id = ?',
         (int) $userId
      );
   }
 
   function &getExpiredFiles() {
      // Files older than one day can be cleaned up.
      $expiryThresholdTimestamp = time() - (60 * 60 * 24);
 
      $temporaryFiles = array();
 
      $result = $this->retrieve(
         'SELECT * FROM temporary_files WHERE date_uploaded < ' . $this->datetimeToDB($expiryThresholdTimestamp)
      );
 
      while (!$result->EOF) {
         $temporaryFiles[] = $this->_returnTemporaryFileFromRow($result->GetRowAssoc(false));
         $result->MoveNext();
      }
 
      $result->Close();
      return $temporaryFiles;
   }
 
   function getInsertId() {
      return $this->_getInsertId('temporary_files', 'file_id');
   }
}