classes/press/LibraryFileDAO.inc.php

<?php

import('classes.press.LibraryFile');

class LibraryFileDAO extends DAO {
   function LibraryFileDAO() {
      parent::DAO();
   }

   function &getById($fileId) {
      $result =& $this->retrieve(
         'SELECT file_id, press_id, file_name, original_file_name, file_type, file_size, type, date_uploaded, monograph_id FROM library_files WHERE file_id = ?',
         array((int) $fileId)
      );

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

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

      return $returner;
   }

   function &getByPressId($pressId, $type = null) {
      $params = array((int) $pressId);
      if (isset($type)) $params[] = (int) $type;

      $result =& $this->retrieve(
         'SELECT  *
         FROM  library_files
         WHERE press_id = ? AND monograph_id = 0 ' . (isset($type)?' AND type = ?' : ''),
         $params
      );
      $returner = new DAOResultFactory($result, $this, '_fromRow', array('id'));
      return $returner;
   }

   function &getByMonographId($monographId, $type = null, $pressId = null) {
      $params = array((int) $monographId);
      if (isset($type)) $params[] = (int) $type;
      if (isset($pressId)) $params[] = (int) $pressId;

      $result =& $this->retrieve(
            'SELECT  *
            FROM  library_files
            WHERE monograph_id = ? ' . (isset($pressId)?' AND press_id = ?' : '') . (isset($type)?' AND type = ?' : ''),
            $params
      );
      $returner = new DAOResultFactory($result, $this, '_fromRow', array('id'));
      return $returner;
   }

   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->setPressId($row['press_id']);
      $libraryFile->setFileName($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->setMonographId($row['monograph_id']);

      $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->getPressId(),
         $libraryFile->getFileName(),
         $libraryFile->getOriginalFileName(),
         $libraryFile->getFileType(),
         (int) $libraryFile->getFileSize(),
         (int) $libraryFile->getType(),
         (int) $libraryFile->getMonographId(),
      );

      if ($libraryFile->getId()) $params[] = (int) $libraryFile->getId();

      $this->update(
         sprintf('INSERT INTO library_files
            (press_id, file_name, original_file_name, file_type, file_size, type, monograph_id, 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->getInsertLibraryFileId());

      $this->updateLocaleFields($libraryFile);
      return $libraryFile->getId();
   }

   function updateObject(&$libraryFile) {
      $this->update(
         sprintf('UPDATE   library_files
            SET   press_id = ?,
               file_name = ?,
               original_file_name = ?,
               file_type = ?,
               file_size = ?,
               type = ?,
               monograph_id = ?,
               date_uploaded = %s
            WHERE file_id = ?',
            $this->datetimeToDB($libraryFile->getDateUploaded())
         ), array(
            (int) $libraryFile->getPressId(),
            $libraryFile->getFileName(),
            $libraryFile->getOriginalFileName(),
            $libraryFile->getFileType(),
            (int) $libraryFile->getFileSize(),
            (int) $libraryFile->getType(),
            (int) $libraryFile->getMonographId(),
            (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($pressId, $fileName) {
      $result = $this->retrieve(
         'SELECT COUNT(*) FROM library_files WHERE press_id = ? AND file_name = ?',
         array((int) $pressId, $fileName)
      );

      $returner = (isset($result->fields[0]) && $result->fields[0] > 0) ? true : false;
      $result->Close();
      unset($result);

      return $returner;
   }

   function getInsertLibraryFileId() {
      return $this->getInsertId('library_files', 'file_id');
   }
}

?>