UNLVHighlightMySQLDataStore.php

<?php
#
# UNLVHighlight: a dmBridge module for highlighting objects
#
# Copyright © 2011 Board of Regents of the Nevada System of Higher
# Education, on behalf of the University of Nevada, Las Vegas
#

class UNLVHighlightMySQLDataStore extends DMMySQLDataStore
implements UNLVHighlightDataStore {

   private static $instance;

   public static function getHighlightedObjectSQL() {
      return "SELECT alias, ptr, datetime FROM highlighted_object
         WHERE datetime <= NOW()
         ORDER BY datetime DESC
         LIMIT 1";
   }

   public static function getHighlightedObjectsSQL() {
      return "SELECT alias, ptr, datetime FROM highlighted_object
         ORDER BY datetime";
   }

   public static function getSetupSQL() {
      return array(
         "CREATE TABLE IF NOT EXISTS highlighted_object (
            id int(10) unsigned NOT NULL auto_increment,
            alias varchar(30) NOT NULL,
            ptr int(10) unsigned NOT NULL,
            datetime datetime NOT NULL,
            PRIMARY KEY (id)
         );"
      );
   }

   public static function getUpgradeSQL() {
      return array(
         // currently empty because there is no previous version from which
         // to upgrade.
      );
   }

   public static function getInstance() {
      if (!self::$instance instanceof self) {
         self::$instance = new self;
      }
      return self::$instance;
   }

   public function addHighlightedObject(DMObject $obj, DMDateTime $datetime) {
      $sql = UNLVHighlightGenericDataStore::addHighlightedObjectSQL();
      $params = array(
         ':alias' => $obj->getCollection()->getAlias(),
         ':ptr' => $obj->getPtr(),
         ':datetime' => $datetime->asMySQLDateTime()
      );
      $this->write($sql, $params);
   }

   function deleteHighlightedObjectsOnDate(DMDateTime $date) {
      $sql = UNLVHighlightGenericDataStore::getDeleteObjectsSQL();
      $params = array(
         ':datetime' => $date->asMySQLDateTime()
      );
      $this->write($sql, $params);
   }

   public function getHighlightedObject() {
      $sql = self::getHighlightedObjectSQL();
      $result = $this->read($sql, array());

      if (count($result)) {
         $collection = DMCollectionFactory::getCollection(
               $result[0]['alias']);
         $obj = DMObjectFactory::getObject($collection, $result[0]['ptr']);
         $h_obj = new UNLVHighlightedObject(new DMDateTime($result[0]['datetime']));
         $obj->addAssociatedModel($h_obj);
         return $obj;
      }
      return null;
   }

   public function getHighlightedObjects() {
      $sql = self::getHighlightedObjectsSQL();
      $result = $this->read($sql, array());

      $objects = array();
      foreach ($result as $row) {
         try {
            $collection = DMCollectionFactory::getCollection($row['alias']);
            $obj = DMObjectFactory::getObject($collection, $row['ptr']);

            $h_obj = new UNLVHighlightedObject(new DMDateTime($row['datetime']));
            $obj->addAssociatedModel($h_obj);

            $objects[] = $obj;
         } catch (DMUnavailableModelException $e) {
            // nothing we can do; skip
         }
      }
      return $objects;
   }

}