Source for file OnpubWSMaps.php

Documentation is available at OnpubWSMaps.php

  1. <?php
  2.  
  3. /**
  4.  * Manage website-section maps in an Onpub database.
  5.  *
  6.  * This class contains the methods to manage the data contained in an
  7.  * {@link http://onpub.com/pdfs/onpub_schema.pdf OnpubWSMaps table}. An
  8.  * OnpubWSMaps table maps website IDs to section IDs. This allows Onpub to do
  9.  * the following without any duplication of website/section data:
  10.  * - Add a single section to multiple websites.
  11.  * - Add multiple sections to a single website.
  12.  * - Specify the order of sections in a website.
  13.  *
  14.  * @author {@link mailto:corey@onpub.com Corey H.M. Taylor}
  15.  * @copyright Onpub (TM). Copyright 2012, Onpub.com.
  16.  *  {@link http://onpub.com/}
  17.  * @license http://www.gnu.org/copyleft/gpl.html GNU General Public License
  18.  *  Version 2
  19.  * @package OnpubAPI
  20.  */
  21. class OnpubWSMaps
  22. {
  23.   private $pdo;
  24.   /**
  25.    * @var bool 
  26.    */
  27.   public $enableTransactions;
  28.  
  29.   /**
  30.    * Connect to an Onpub database.
  31.    *
  32.    * All the methods in this class which query the database use the database
  33.    * connection provided by the PDO object required by this constructor.
  34.    * Currently, Onpub only supports MySQL as a database for storing content.
  35.    * Therefore, when constructing the PDO object, only the
  36.    * {@link PHP_MANUAL#ref.pdo-mysql PDO_MYSQL} driver is supported
  37.    * as a PDO {@link PHP_MANUAL#ref.pdo-mysql.connection data source}.
  38.    *
  39.    * All the methods in this class require the
  40.    * {@link http://onpub.com/pdfs/onpub_schema.pdf Onpub schema}
  41.    * to be installed in the PDO-connected database. The {@link OnpubDatabase}
  42.    * class contains methods to manage the Onpub schema. The Onpub
  43.    * schema can also be installed by clicking the "Install the schema" link
  44.    * once logged in to the Onpub web interface. The schema generally only has
  45.    * to be installed once per database.
  46.    *
  47.    * @param PDO $pdo A {@link PHP_MANUAL#function.pdo-construct PHP Data Object}.
  48.    * @param bool $enableTransactions 
  49.    */
  50.   function __construct(PDO $pdo, $enableTransactions = TRUE)
  51.   {
  52.     $this->pdo = $pdo;
  53.     $this->enableTransactions = $enableTransactions;
  54.     $this->pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, TRUE);
  55.   }
  56.  
  57.   /**
  58.    * @param int $websiteID Delete the map(s) with websiteID.
  59.    * @param int $sectionID Delete the map(s) with sectionID.
  60.    * @return int The number of maps deleted, 0 if no maps were deleted.
  61.    */
  62.   public function delete($websiteID, $sectionID)
  63.   {
  64.     if ($websiteID && $sectionID) {
  65.       $stmt = $this->pdo->prepare("DELETE FROM OnpubWSMaps WHERE websiteID = :websiteID AND sectionID = :sectionID");
  66.       OnpubDatabase::verifyPrepare($this->pdo, $stmt, FALSE);
  67.       $stmt->bindParam(':websiteID', $websiteID);
  68.       $stmt->bindParam(':sectionID', $sectionID);
  69.     }
  70.  
  71.     if ($websiteID && !$sectionID) {
  72.       $stmt = $this->pdo->prepare("DELETE FROM OnpubWSMaps WHERE websiteID = :websiteID");
  73.       OnpubDatabase::verifyPrepare($this->pdo, $stmt, FALSE);
  74.       $stmt->bindParam(':websiteID', $websiteID);
  75.     }
  76.  
  77.     if (!$websiteID && $sectionID) {
  78.       $stmt = $this->pdo->prepare("DELETE FROM OnpubWSMaps WHERE sectionID = :sectionID");
  79.       OnpubDatabase::verifyPrepare($this->pdo, $stmt, FALSE);
  80.       $stmt->bindParam(':sectionID', $sectionID);
  81.     }
  82.  
  83.     $result = $stmt->execute();
  84.     OnpubDatabase::verifyExecute($this->pdo, $result, FALSE, $stmt->errorInfo());
  85.  
  86.     return $stmt->rowCount();
  87.   }
  88.  
  89.   /**
  90.    * @param OnpubWSMap $wsmap Map whose ID you want to get.
  91.    * @return int The ID of the map. NULL if the map does not exist in the database.
  92.    */
  93.   public function getID(OnpubWSMap $wsmap)
  94.   {
  95.     $stmt = $this->pdo->prepare("SELECT ID FROM OnpubWSMaps WHERE websiteID = :websiteID AND sectionID = :sectionID");
  96.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, FALSE);
  97.  
  98.     $websiteID = $wsmap->websiteID;
  99.     $sectionID = $wsmap->sectionID;
  100.  
  101.     $stmt->bindParam(':websiteID', $websiteID);
  102.     $stmt->bindParam(':sectionID', $sectionID);
  103.     $result = $stmt->execute();
  104.     OnpubDatabase::verifyExecute($this->pdo, $result, FALSE, $stmt->errorInfo());
  105.  
  106.     if (($row = $stmt->fetch(PDO::FETCH_ASSOC))) {
  107.       return $row["ID"];
  108.     }
  109.  
  110.     return NULL;
  111.   }
  112.  
  113.   /**
  114.    * @param OnpubQueryOptions $queryOptions Database query options.
  115.    * @return array An array of {@link OnpubWSMap} objects.
  116.    */
  117.   public function select(OnpubQueryOptions $queryOptions = NULL, $websiteID = NULL)
  118.   {
  119.     if ($queryOptions === NULL)
  120.       $queryOptions = new OnpubQueryOptions();
  121.  
  122.     $query = $this->selectQuery($queryOptions, $websiteID);
  123.     $result = $this->pdo->query($query);
  124.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  125.     $rows = $result->fetchAll(PDO::FETCH_ASSOC);
  126.  
  127.     $wsmaps = array();
  128.  
  129.     if ($rows) {
  130.       foreach ($rows as $row) {
  131.         $wsmap = new OnpubWSMap();
  132.  
  133.         $wsmap->ID = $row["ID"];
  134.         $wsmap->websiteID = $row["websiteID"];
  135.         $wsmap->sectionID = $row["sectionID"];
  136.         $wsmap->setCreated(new DateTime($row["created"]));
  137.         $wsmap->setModified(new DateTime($row["modified"]));
  138.  
  139.         $wsmaps[] = $wsmap;
  140.       }
  141.     }
  142.  
  143.     $result->closeCursor();
  144.     return $wsmaps;
  145.   }
  146.  
  147.   private function selectQuery(OnpubQueryOptions $queryOptions = NULL, $websiteID)
  148.   {
  149.     if ($queryOptions === NULL)
  150.       $queryOptions = new OnpubQueryOptions();
  151.  
  152.     $where = "";
  153.     $orderBy = "";
  154.     $limit = "";
  155.  
  156.     if ($queryOptions->dateLimit) {
  157.       $where = "WHERE created <= "
  158.         . $this->pdo->quote($queryOptions->dateLimit->format('Y-m-d H:i:s'));
  159.  
  160.       if ($websiteID) {
  161.         $where .= " AND websiteID = $websiteID";
  162.       }
  163.     }
  164.     else {
  165.       if ($websiteID) {
  166.         $where = "WHERE websiteID = $websiteID";
  167.       }
  168.     }
  169.  
  170.     if ($queryOptions->orderBy) {
  171.       $orderBy = "ORDER BY " . $queryOptions->orderBy;
  172.  
  173.       if ($queryOptions->order) {
  174.         $orderBy .= " " . $queryOptions->order;
  175.       }
  176.     }
  177.  
  178.     if ($queryOptions->getPage() && $queryOptions->rowLimit && $queryOptions->rowLimit > 0) {
  179.       $limit = "LIMIT "
  180.         . (($queryOptions->getPage() - 1) * $queryOptions->rowLimit) . ","
  181.         . $queryOptions->rowLimit;
  182.     }
  183.     elseif ($queryOptions->rowLimit && $queryOptions->rowLimit > 0) {
  184.       $limit = "LIMIT 0," . $queryOptions->rowLimit;
  185.     }
  186.  
  187.     return "SELECT ID, websiteID, sectionID, created, modified FROM OnpubWSMaps $where $orderBy $limit";
  188.   }
  189.  
  190.   /**
  191.    * @param mixed $wsmaps A single {@link OnpubWSMap} object or an array of {@link OnpubWSMap} objects (to insert multiple maps at a time).
  192.    * @return mixed The ID(s) of the new map(s). An int will be returned if a single map was inserted. An array of ints will be returned if multiple maps were inserted.
  193.    * @throws PDOException if there's a database error.
  194.    */
  195.   public function insert($wsmaps)
  196.   {
  197.     $wsmapIDs = array();
  198.     $isArray = TRUE;
  199.  
  200.     if (!is_array($wsmaps)) {
  201.       $wsmaps = array ($wsmaps);
  202.       $isArray = FALSE;
  203.     }
  204.  
  205.     if ($this->enableTransactions) {
  206.       $status = $this->pdo->beginTransaction();
  207.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  208.     }
  209.  
  210.     $stmt = $this->pdo->prepare("INSERT INTO OnpubWSMaps (ID, websiteID, sectionID, created, modified) VALUES (:ID, :websiteID, :sectionID, :created, :modified)");
  211.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, $this->enableTransactions);
  212.  
  213.     foreach ($wsmaps as $wsmap) {
  214.       try {
  215.         $wsmapID = $this->getID($wsmap);
  216.       }
  217.       catch (PDOException $e) {
  218.         if ($this->enableTransactions)
  219.           $this->pdo->rollBack();
  220.  
  221.         throw $e;
  222.       }
  223.  
  224.       if ($wsmapID) {
  225.         $wsmapIDs[] = $wsmapID;
  226.         $wsmap->ID = $wsmapID;
  227.       }
  228.       else {
  229.         $ID = $wsmap->ID;
  230.         $websiteID = $wsmap->websiteID;
  231.         $sectionID = $wsmap->sectionID;
  232.         $created = $wsmap->getCreated()->format('Y-m-d H:i:s');
  233.         $modified = $wsmap->getModified()->format('Y-m-d H:i:s');
  234.  
  235.         $stmt->bindParam(':ID', $ID);
  236.         $stmt->bindParam(':websiteID', $websiteID);
  237.         $stmt->bindParam(':sectionID', $sectionID);
  238.         $stmt->bindParam(':created', $created);
  239.         $stmt->bindParam(':modified', $modified);
  240.         $result = $stmt->execute();
  241.         OnpubDatabase::verifyExecute($this->pdo, $result, $this->enableTransactions, $stmt->errorInfo());
  242.  
  243.         $wsmapIDs[] = $this->pdo->lastInsertId();
  244.         $wsmap->ID = $this->pdo->lastInsertId();
  245.       }
  246.     }
  247.  
  248.     if ($this->enableTransactions) {
  249.       $status = $this->pdo->commit();
  250.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  251.     }
  252.  
  253.     if ($isArray) {
  254.       return $wsmapIDs;
  255.     }
  256.     else {
  257.       return end($wsmapIDs);
  258.     }
  259.   }
  260. }
  261. ?>

Documentation generated on Sun, 20 May 2012 04:03:02 -0400 by phpDocumentor 1.4.4