classes/file/TemporaryFileDAO.inc.php

<?php

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


import('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($fileId, $userId),
         1
      );

      $returner = null;
      if (isset($result) && $result->RecordCount() != 0) {
         $returner = &$this->_returnTemporaryFileFromRow($result->GetRowAssoc(false));
      }

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

      return $returner;
   }

   function &_returnTemporaryFileFromRow(&$row) {
      $temporaryFile = &new TemporaryFile();
      $temporaryFile->setFileId($row['file_id']);
      $temporaryFile->setFileName($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 insertTemporaryFile(&$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(
            $temporaryFile->getUserId(),
            $temporaryFile->getFileName(),
            $temporaryFile->getFileType(),
            $temporaryFile->getFileSize(),
            $temporaryFile->getOriginalFileName()
         )
      );

      $temporaryFile->setFileId($this->getInsertTemporaryFileId());
      return $temporaryFile->getFileId();
   }

   function updateTemporaryFile(&$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->getFileName(),
            $temporaryFile->getFileType(),
            $temporaryFile->getFileSize(),
            $temporaryFile->getUserId(),
            $temporaryFile->getOriginalFileName(),
            $temporaryFile->getFileId()
         )
      );

      return $temporaryFile->getFileId();

   }

   function deleteTemporaryFileById($fileId, $userId) {
      return $this->update(
         'DELETE FROM temporary_files WHERE file_id = ? AND user_id = ?', array($fileId, $userId)
      );
   }

   function deleteTemporaryFilesByUserId($userId) {
      return $this->update(
         'DELETE FROM temporary_files WHERE user_id = ?', $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();
      unset($result);

      return $temporaryFiles;
   }

   function getInsertTemporaryFileId() {
      return $this->getInsertId('temporary_files', 'file_id');
   }
}

?>

---