Source for file OnpubWebsites.php

Documentation is available at OnpubWebsites.php

  1. <?php
  2.  
  3. /**
  4.  * Manage websites in an Onpub database.
  5.  *
  6.  * @author {@link mailto:corey@onpub.com Corey H.M. Taylor}
  7.  * @copyright Onpub (TM). Copyright 2012, Onpub.com.
  8.  *  {@link http://onpub.com/}
  9.  * @license http://www.gnu.org/copyleft/gpl.html GNU General Public License
  10.  *  Version 2
  11.  * @package OnpubAPI
  12.  */
  13. class OnpubWebsites
  14. {
  15.   private $pdo;
  16.   /**
  17.    * @var bool 
  18.    */
  19.   public $enableTransactions;
  20.  
  21.   /**
  22.    * Connect to an Onpub database.
  23.    *
  24.    * All the methods in this class which query the database use the database
  25.    * connection provided by the PDO object required by this constructor.
  26.    * Currently, Onpub only supports MySQL as a database for storing content.
  27.    * Therefore, when constructing the PDO object, only the
  28.    * {@link PHP_MANUAL#ref.pdo-mysql PDO_MYSQL} driver is supported
  29.    * as a PDO {@link PHP_MANUAL#ref.pdo-mysql.connection data source}.
  30.    *
  31.    * All the methods in this class require the
  32.    * {@link http://onpub.com/pdfs/onpub_schema.pdf Onpub schema}
  33.    * to be installed in the PDO-connected database. The {@link OnpubDatabase}
  34.    * class contains methods to manage the Onpub schema. The Onpub
  35.    * schema can also be installed by clicking the "Install the schema" link
  36.    * once logged in to the Onpub web interface. The schema generally only has
  37.    * to be installed once per database.
  38.    *
  39.    * @param PDO $pdo A {@link PHP_MANUAL#function.pdo-construct PHP Data Object}.
  40.    * @param bool $enableTransactions 
  41.    */
  42.   function __construct(PDO $pdo, $enableTransactions = TRUE)
  43.   {
  44.     $this->pdo = $pdo;
  45.     $this->enableTransactions = $enableTransactions;
  46.     $this->pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, TRUE);
  47.   }
  48.  
  49.   /**
  50.    * @return int 
  51.    */
  52.   public function count()
  53.   {
  54.     $query = $this->countQuery();
  55.     $result = $this->pdo->query($query);
  56.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  57.  
  58.     if (!($row = $result->fetch(PDO::FETCH_ASSOC))) {
  59.       return 0;
  60.     }
  61.  
  62.     $result->closeCursor();
  63.     return $row["count"];
  64.   }
  65.  
  66.   private function countQuery()
  67.   {
  68.     return "SELECT COUNT(ID) AS count FROM OnpubWebsites";
  69.   }
  70.  
  71.   /**
  72.    * @param int $ID ID of the website to delete.
  73.    * @return int 1 if the website was deleted, 0 if the website does not exist in the database.
  74.    */
  75.   public function delete($ID)
  76.   {
  77.     $stmt = $this->pdo->prepare("DELETE FROM OnpubWebsites WHERE ID = :ID");
  78.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, FALSE);
  79.  
  80.     $stmt->bindParam(':ID', $ID);
  81.     $result = $stmt->execute();
  82.     OnpubDatabase::verifyExecute($this->pdo, $result, FALSE, $stmt->errorInfo());
  83.  
  84.     return $stmt->rowCount();
  85.   }
  86.  
  87.   /**
  88.    * @param string $keywords Keyword(s) to search for.
  89.    * @return array All the websites which were found as an array of {@link OnpubWebsite} objects.
  90.    */
  91.   public function search($keywords, OnpubQueryOptions $queryOptions = NULL)
  92.   {
  93.     if ($queryOptions === NULL)
  94.       $queryOptions = new OnpubQueryOptions();
  95.  
  96.     $query = $this->searchQuery($keywords, $queryOptions);
  97.     $result = $this->pdo->query($query);
  98.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  99.  
  100.     $rows = $result->fetchAll(PDO::FETCH_ASSOC);
  101.  
  102.     $websites = array();
  103.  
  104.     if ($rows) {
  105.       foreach ($rows as $row) {
  106.         $website = new OnpubWebsite();
  107.  
  108.         $website->ID = $row["ID"];
  109.         $website->imageID = $row["imageID"];
  110.         $website->name = $row["name"];
  111.         $website->url = $row["url"];
  112.         $website->imagesURL = $row["imagesURL"];
  113.         $website->imagesDirectory = $row["imagesDirectory"];
  114.         $website->setCreated(new DateTime($row["created"]));
  115.         $website->setModified(new DateTime($row["modified"]));
  116.  
  117.         $websites[] = $website;
  118.       }
  119.     }
  120.  
  121.     $result->closeCursor();
  122.     return $websites;
  123.   }
  124.  
  125.   private function searchQuery($keywords, OnpubQueryOptions $queryOptions = NULL)
  126.   {
  127.     if ($queryOptions === NULL)
  128.       $queryOptions = new OnpubQueryOptions();
  129.  
  130.     $keywords = $this->pdo->quote(OnpubDatabase::utf8Decode(trim($keywords)));
  131.  
  132.     if ($queryOptions->orderBy) {
  133.       $orderBy = $queryOptions->orderBy;
  134.     }
  135.     else {
  136.       $orderBy = "";
  137.     }
  138.  
  139.     if ($queryOptions->order) {
  140.       $order = $queryOptions->order;
  141.     }
  142.     else {
  143.       $order = "";
  144.     }
  145.  
  146.     if ($orderBy) {
  147.       if ($order) {
  148.         return "SELECT ID, imageID, name, url, imagesURL, imagesDirectory, created, modified FROM OnpubWebsites WHERE ID RLIKE $keywords OR name RLIKE $keywords OR modified RLIKE $keywords ORDER BY $orderBy $order";
  149.       }
  150.       else {
  151.         return "SELECT ID, imageID, name, url, imagesURL, imagesDirectory, created, modified FROM OnpubWebsites WHERE ID RLIKE $keywords OR name RLIKE $keywords OR modified RLIKE $keywords ORDER BY $orderBy";
  152.       }
  153.     }
  154.     else {
  155.       return "SELECT ID, imageID, name, url, imagesURL, imagesDirectory, created, modified FROM OnpubWebsites WHERE ID RLIKE $keywords OR name RLIKE $keywords OR modified RLIKE $keywords";
  156.     }
  157.   }
  158.  
  159.   /**
  160.    * @param OnpubQueryOptions $queryOptions Database query options.
  161.    * @return array An array of {@link OnpubWebsite} objects.
  162.    */
  163.   public function select(OnpubQueryOptions $queryOptions = NULL)
  164.   {
  165.     if ($queryOptions === NULL)
  166.       $queryOptions = new OnpubQueryOptions();
  167.  
  168.     $query = $this->selectQuery($queryOptions);
  169.     $result = $this->pdo->query($query);
  170.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  171.     $rows = $result->fetchAll(PDO::FETCH_ASSOC);
  172.  
  173.     $websites = array();
  174.  
  175.     if ($rows) {
  176.       foreach ($rows as $row) {
  177.         $website = new OnpubWebsite();
  178.  
  179.         $website->ID = $row["ID"];
  180.         $website->imageID = $row["imageID"];
  181.         $website->name = $row["name"];
  182.         $website->url = $row["url"];
  183.         $website->imagesURL = $row["imagesURL"];
  184.         $website->imagesDirectory = $row["imagesDirectory"];
  185.         $website->setCreated(new DateTime($row["created"]));
  186.         $website->setModified(new DateTime($row["modified"]));
  187.  
  188.         $websites[] = $website;
  189.       }
  190.     }
  191.  
  192.     $result->closeCursor();
  193.     return $websites;
  194.   }
  195.  
  196.   private function selectQuery(OnpubQueryOptions $queryOptions = NULL)
  197.   {
  198.     if ($queryOptions === NULL)
  199.       $queryOptions = new OnpubQueryOptions();
  200.  
  201.     $where = "";
  202.     $orderBy = "";
  203.     $limit = "";
  204.  
  205.     if ($queryOptions->dateLimit) {
  206.       $where = "WHERE created <= "
  207.         . $this->pdo->quote($queryOptions->dateLimit->format('Y-m-d H:i:s'));
  208.     }
  209.  
  210.     if ($queryOptions->orderBy) {
  211.       $orderBy = "ORDER BY " . $queryOptions->orderBy;
  212.  
  213.       if ($queryOptions->order) {
  214.         $orderBy .= " " . $queryOptions->order;
  215.       }
  216.     }
  217.  
  218.     if ($queryOptions->getPage() && $queryOptions->rowLimit && $queryOptions->rowLimit > 0) {
  219.       $limit = "LIMIT "
  220.         . (($queryOptions->getPage() - 1) * $queryOptions->rowLimit) . ","
  221.         . $queryOptions->rowLimit;
  222.     }
  223.     elseif ($queryOptions->rowLimit && $queryOptions->rowLimit > 0) {
  224.       $limit = "LIMIT 0," . $queryOptions->rowLimit;
  225.     }
  226.  
  227.     return "SELECT ID, imageID, ID, name, url, imagesURL, imagesDirectory, created, modified FROM OnpubWebsites $where $orderBy $limit";
  228.   }
  229.  
  230.   /**
  231.    * @param int $ID ID of the website to get.
  232.    * @return OnpubWebsite An {@link OnpubWebsite} object. NULL if the website does not exist in the database.
  233.    */
  234.   public function get($ID, OnpubQueryOptions $queryOptions = NULL, $flatArticleList = FALSE)
  235.   {    
  236.     if ($queryOptions === NULL)
  237.       $queryOptions = new OnpubQueryOptions();
  238.  
  239.     $query = $this->getQuery($ID, $queryOptions);
  240.     $result = $this->pdo->query($query);
  241.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  242.  
  243.     if (!($rows = $result->fetchAll(PDO::FETCH_ASSOC))) {
  244.       return NULL;
  245.     }
  246.  
  247.     $row = $rows[0];
  248.  
  249.     $website = new OnpubWebsite();
  250.  
  251.     $website->ID = $row["ID"];
  252.     $website->imageID = $row["imageID"];
  253.     $website->name = $row["name"];
  254.     $website->url = $row["url"];
  255.     $website->imagesURL = $row["imagesURL"];
  256.     $website->imagesDirectory = $row["imagesDirectory"];
  257.     $website->setCreated(new DateTime($row["created"]));
  258.     $website->setModified(new DateTime($row["modified"]));
  259.  
  260.     if ($row["imageID"]) {
  261.       $image = new OnpubImage();
  262.  
  263.       $image->ID = $row["imageID"];
  264.       $image->websiteID = $row["ID"];
  265.       $image->fileName = $row["fileName"];
  266.       $image->description = $row["description"];
  267.       $image->setCreated(new DateTime($row["imageCreated"]));
  268.       $image->setModified(new DateTime($row["imageModified"]));
  269.  
  270.       $website->image = $image;
  271.     }
  272.  
  273.     if (!$queryOptions->includeSections) {
  274.       return $website;
  275.     }
  276.  
  277.     $osections = new OnpubSections($this->pdo);
  278.     $sections = array();
  279.     $sectionsassoc = array();
  280.  
  281.     foreach ($rows as $row) {
  282.       $sectionID = $row["sectionID"];
  283.       $ID = $row["ID"];
  284.  
  285.       if ($sectionID) {
  286.         $section = new OnpubSection();
  287.  
  288.         $section->ID = $sectionID;
  289.         $section->imageID = $row["sectionImageID"];
  290.         $section->websiteID = $row["sectionWebsiteID"];
  291.         $section->parentID = $row["sectionParentID"];
  292.         $section->name = $row["sectionName"];
  293.         $section->url = $row["sectionURL"];
  294.         $section->setCreated(new DateTime($row["sectionCreated"]));
  295.         $section->setModified(new DateTime($row["sectionModified"]));
  296.  
  297.         if (isset($sectionsassoc["$sectionID"])) {
  298.           $section = $sectionsassoc["$sectionID"];
  299.         }
  300.         else {
  301.           $sectionsassoc["$sectionID"] = $section;
  302.         }
  303.  
  304.         if ($row["sectionImageID"]) {
  305.           $image = new OnpubImage();
  306.  
  307.           $image->ID = $row["sectionImageID"];
  308.           $image->websiteID = $row["sectionImageWebsiteID"];
  309.           $image->fileName = $row["sectionImageFileName"];
  310.           $image->description = $row["sectionImageDescription"];
  311.           $image->setCreated(new DateTime($row["sectionImageCreated"]));
  312.           $image->setModified(new DateTime($row["sectionImageModified"]));
  313.  
  314.           $section->image = $image;
  315.         }
  316.  
  317.         $sections = $website->sections;
  318.         $exists = FALSE;
  319.  
  320.         foreach ($sections as $s) {
  321.           if ($s->ID == $section->ID) {
  322.             $exists = TRUE;
  323.           }
  324.         }
  325.  
  326.         if ($exists == FALSE) {
  327.           $sections[] = $section;
  328.           $website->sections = $sections;
  329.         }
  330.       }
  331.     }
  332.  
  333.     // An array to track the subsections indexes in the sections array.
  334.     $subsections = array();
  335.  
  336.     // Loop through all sections and link subsections to their parents and
  337.     // vice-versa.
  338.     for ($i = 0; $i < sizeof($sections); $i++) {
  339.       $section = $sections[$i];
  340.       
  341.       if ($section->parentID) {
  342.         $parentID = $section->parentID;
  343.  
  344.         if (isset($sectionsassoc["$parentID"])) {
  345.           $parentSection = $sectionsassoc["$parentID"];
  346.           $parentSection->sections[] = $section;
  347.           $section->parent = $parentSection;
  348.         }
  349.  
  350.         $subsections[] = $i;
  351.       }
  352.     }
  353.  
  354.     // Unset subsections from the original sections array now that they are
  355.     // linked to their parent sections.
  356.     foreach ($subsections as $subsection) {
  357.       unset($sections[$subsection]);
  358.     }
  359.  
  360.     // Array now might not be offset from 0 for sections. Re-index from 0.
  361.     $website->sections = array_values($sections);
  362.  
  363.     if (!$queryOptions->includeArticles) {
  364.       return $website;
  365.     }
  366.  
  367.     $articlesassoc = array();
  368.  
  369.     reset ($rows);
  370.  
  371.     foreach ($rows as $row) {
  372.       $articleID = $row["articleID"];
  373.       $sectionID = $row["sectionID"];
  374.  
  375.       if ($articleID && $sectionID) {
  376.         if ($queryOptions->includeContent) {
  377.           $content = $row["content"];
  378.         }
  379.         else {
  380.           $content = "";
  381.         }
  382.  
  383.         $article = new OnpubArticle();
  384.  
  385.         $article->ID = $articleID;
  386.         $article->imageID = $row["articleImageID"];
  387.         $article->title = $row["title"];
  388.         $article->content = $content;
  389.         $article->url = $row["articleURL"];
  390.         $article->setCreated(new DateTime($row["articleCreated"]));
  391.         $article->setModified(new DateTime($row["articleModified"]));
  392.  
  393.         if (isset($articlesassoc["$articleID"])) {
  394.           $article = $articlesassoc["$articleID"];
  395.         }
  396.         else {
  397.           $article->sectionIDs[] = $sectionID;
  398.           $articlesassoc["$articleID"] = $article;
  399.         }
  400.  
  401.         if ($row["articleImageID"]) {
  402.           $image = new OnpubImage();
  403.  
  404.           $image->ID = $row["articleImageID"];
  405.           $image->websiteID = $row["articleImageWebsiteID"];
  406.           $image->fileName = $row["articleImageFileName"];
  407.           $image->description = $row["articleImageDescription"];
  408.           $image->url = $row["articleImageURL"];
  409.           $image->setCreated(new DateTime($row["articleImageCreated"]));
  410.           $image->setModified(new DateTime($row["articleImageModified"]));
  411.  
  412.           $article->image = $image;
  413.         }
  414.  
  415.         $section = $sectionsassoc["$sectionID"];
  416.         $articles = $section->articles;
  417.         $exists = FALSE;
  418.  
  419.         foreach ($articles as $a) {
  420.           if ($a->ID == $article->ID) {
  421.             $exists = TRUE;
  422.           }
  423.         }
  424.  
  425.         if ($exists == FALSE) {
  426.           $articles[] = $article;
  427.           $section->articles = $articles;
  428.         }
  429.       }
  430.     }
  431.  
  432.     if ($flatArticleList) {
  433.       $articles = array();
  434.  
  435.       foreach ($articlesassoc as $article) {
  436.         $articles[] = $article;
  437.       }
  438.  
  439.       $website->articles = $articles;
  440.     }
  441.  
  442.     $authorsassoc = array();
  443.  
  444.     reset ($rows);
  445.  
  446.     foreach ($rows as $row) {
  447.       $authorID = $row["authorID"];
  448.       $articleID = $row["articleID"];
  449.  
  450.       if ($authorID && $articleID) {
  451.         $author = new OnpubAuthor();
  452.  
  453.         $author->ID = $authorID;
  454.         $author->imageID = $row["authorImageID"];
  455.         $author->givenNames = $row["givenNames"];
  456.         $author->familyName = $row["familyName"];
  457.         $author->displayAs = $row["displayAs"];
  458.         $author->setCreated(new DateTime($row["authorCreated"]));
  459.         $author->setModified(new DateTime($row["authorModified"]));
  460.  
  461.         if (isset($authorsassoc["$authorID"])) {
  462.           $author = $authorsassoc["$authorID"];
  463.         }
  464.         else {
  465.           $authorsassoc["$authorID"] = $author;
  466.         }
  467.  
  468.         if ($row["authorImageID"]) {
  469.           $image = new OnpubImage();
  470.  
  471.           $image->ID = $row["authorImageID"];
  472.           $image->websiteID = $row["authorImageWebsiteID"];
  473.           $image->fileName = $row["authorImageFileName"];
  474.           $image->description = $row["authorImageDescription"];
  475.           $image->setCreated(new DateTime($row["authorImageCreated"]));
  476.           $image->setModified(new DateTime($row["authorImageModified"]));
  477.  
  478.           $author->image = $image;
  479.         }
  480.  
  481.         $article = $articlesassoc["$articleID"];
  482.         $authors = $article->authors;
  483.         $exists = FALSE;
  484.  
  485.         foreach ($authors as $a) {
  486.           if ($a->ID == $author->ID) {
  487.             $exists = TRUE;
  488.           }
  489.         }
  490.  
  491.         if ($exists == FALSE) {
  492.           $authors[] = $author;
  493.           $article->authors = $authors;
  494.         }
  495.       }
  496.     }
  497.  
  498.     $result->closeCursor();
  499.     return $website;
  500.   }
  501.  
  502.   private function getQuery($ID, OnpubQueryOptions $queryOptions = NULL)
  503.   {
  504.     if ($queryOptions === NULL)
  505.       $queryOptions = new OnpubQueryOptions();
  506.  
  507.     if ($queryOptions->includeArticles) {
  508.       if ($queryOptions->orderBy) {
  509.         $orderBy = $queryOptions->orderBy;
  510.  
  511.         if ($queryOptions->order) {
  512.           $order = $queryOptions->order;
  513.           $orderBy = "articles.$orderBy $order";
  514.         }
  515.         else {
  516.           $orderBy = "articles.$orderBy ASC";
  517.         }
  518.       }
  519.       else {
  520.         if ($queryOptions->order) {
  521.           $order = $queryOptions->order;
  522.           $orderBy = "wsmaps.ID ASC, samaps.ID $order";
  523.         }
  524.         else {
  525.           $orderBy = "wsmaps.ID ASC, samaps.ID ASC";
  526.         }
  527.       }
  528.     }
  529.     else {
  530.       if ($queryOptions->orderBy) {
  531.         $orderBy = $queryOptions->orderBy;
  532.  
  533.         if ($queryOptions->order) {
  534.           $order = $queryOptions->order;
  535.           $orderBy = "wsmaps.$orderBy $order";
  536.         }
  537.         else {
  538.           $orderBy = "wsmaps.$orderBy ASC";
  539.         }
  540.       }
  541.       else {
  542.         if ($queryOptions->order) {
  543.           $order = $queryOptions->order;
  544.           $orderBy = "wsmaps.ID $order";
  545.         }
  546.         else {
  547.           $orderBy = "wsmaps.ID ASC";
  548.         }
  549.       }
  550.     }
  551.  
  552.     $where = "WHERE websites.ID = $ID";
  553.  
  554.     if ($queryOptions->dateLimit && $queryOptions->includeArticles) {
  555.       $dateLimit = $queryOptions->dateLimit->format('Y-m-d H:i:s');
  556.       $where .= " AND articles.created <= '$dateLimit'";
  557.     }
  558.  
  559.     if ($queryOptions->dateAfter && !$queryOptions->dateLimit && $queryOptions->includeArticles) {
  560.       $dateAfter = $queryOptions->dateAfter->format('Y-m-d H:i:s');
  561.       $where .= " AND articles.created >= '$dateAfter'";
  562.     }
  563.  
  564.     if ($queryOptions->includeContent) {
  565.       $articleColumns = "articles.ID AS articleID, articles.imageID AS " .
  566.                         "articleImageID, title, content, articles.url AS " .
  567.                         "articleURL, articles.created AS articleCreated, " .
  568.                         "articles.modified AS articleModified";
  569.     }
  570.     else {
  571.       $articleColumns = "articles.ID AS articleID, articles.imageID AS " .
  572.                         "articleImageID, title, articles.url AS articleURL, " .
  573.                         "articles.created AS articleCreated, " .
  574.                         "articles.modified AS articleModified";
  575.     }
  576.  
  577.     if ($queryOptions->includeSections) {
  578.       if ($queryOptions->includeArticles) {
  579.         return
  580.           "SELECT websites.ID, websites.imageID, websites.name, " .
  581.           "websites.url, websites.imagesURL, websites.imagesDirectory, " .
  582.           "websites.created, websites.modified, websiteimages.fileName, " .
  583.           "websiteimages.description, websiteimages.url AS websiteImageURL, " .
  584.           "websiteimages.created AS imageCreated, websiteimages.modified AS " .
  585.           "imageModified, sections.ID AS sectionID, sections.imageID AS " .
  586.           "sectionImageID, sections.websiteID AS sectionWebsiteID, " .
  587.           "sections.parentID AS sectionParentID, sections.name AS " .
  588.           "sectionName, sections.url AS sectionURL, sections.created AS sectionCreated, " .
  589.           "sections.modified AS sectionModified, sectionimages.websiteID AS " .
  590.           "sectionImageWebsiteID, sectionimages.fileName AS " .
  591.           "sectionImageFileName, sectionimages.description AS " .
  592.           "sectionImageDescription, sectionimages.url AS sectionImageURL, " .
  593.           "sectionimages.created AS sectionImageCreated, " .
  594.           "sectionimages.modified AS sectionImageModified, $articleColumns, " .
  595.           "articleimages.websiteID AS articleImageWebsiteID, " .
  596.           "articleimages.fileName AS articleImageFileName, " .
  597.           "articleimages.description AS articleImageDescription, " .
  598.           "articleimages.url AS articleImageURL, articleimages.created AS " .
  599.           "articleImageCreated, articleimages.modified AS " .
  600.           "articleImageModified, authors.ID AS authorID, authors.imageID AS " .
  601.           "authorImageID, authors.givenNames, authors.familyName, " .
  602.           "authors.displayAs, authors.created AS authorCreated, " .
  603.           "authors.modified AS authorModified, authorimages.websiteID AS " .
  604.           "authorImageWebsiteID, authorimages.fileName AS " .
  605.           "authorImageFileName, authorimages.description AS " .
  606.           "authorImageDescription, authorimages.url AS authorImageURL, " .
  607.           "authorimages.created AS authorImageCreated, " .
  608.           "authorimages.modified AS authorImageModified FROM OnpubWebsites " .
  609.           "AS websites LEFT JOIN OnpubImages AS websiteimages ON " .
  610.           "websites.imageID = websiteimages.ID LEFT JOIN OnpubWSMaps AS " .
  611.           "wsmaps ON websites.ID = wsmaps.websiteID LEFT JOIN OnpubSections " .
  612.           "AS sections ON wsmaps.sectionID = sections.ID LEFT JOIN " .
  613.           "OnpubImages AS sectionimages ON sections.imageID = " .
  614.           "sectionimages.ID LEFT JOIN OnpubSAMaps AS samaps ON " .
  615.           "sections.ID = samaps.sectionID LEFT JOIN OnpubArticles AS " .
  616.           "articles ON samaps.articleID = articles.ID LEFT JOIN OnpubImages " .
  617.           "AS articleimages ON articles.imageID = articleimages.ID " .
  618.           "LEFT JOIN OnpubAAMaps AS aamaps ON articles.ID = " .
  619.           "aamaps.articleID LEFT JOIN OnpubAuthors AS authors ON " .
  620.           "aamaps.authorID = authors.ID LEFT JOIN OnpubImages AS " .
  621.           "authorimages ON authors.imageID = authorimages.ID $where " .
  622.           "ORDER BY $orderBy";
  623.       }
  624.       else {
  625.         return
  626.           "SELECT websites.ID, websites.imageID, websites.name, " .
  627.           "websites.url, websites.imagesURL, websites.imagesDirectory, " .
  628.           "websites.created, websites.modified, websiteimages.fileName, " .
  629.           "websiteimages.description, websiteimages.url AS websiteImageURL, " .
  630.           "websiteimages.created AS imageCreated, websiteimages.modified AS " .
  631.           "imageModified, sections.ID AS sectionID, sections.imageID AS " .
  632.           "sectionImageID, sections.websiteID AS sectionWebsiteID, " .
  633.           "sections.parentID AS sectionParentID, sections.name AS " .
  634.           "sectionName, sections.url AS sectionURL, sections.created AS sectionCreated, " .
  635.           "sections.modified AS sectionModified, sectionimages.websiteID " .
  636.           "AS sectionImageWebsiteID, sectionimages.fileName AS " .
  637.           "sectionImageFileName, sectionimages.description AS " .
  638.           "sectionImageDescription, sectionimages.url AS sectionImageURL, " .
  639.           "sectionimages.created AS sectionImageCreated, " .
  640.           "sectionimages.modified AS sectionImageModified FROM " .
  641.           "OnpubWebsites AS websites LEFT JOIN OnpubImages AS websiteimages " .
  642.           "ON websites.imageID = websiteimages.ID LEFT JOIN OnpubWSMaps AS " .
  643.           "wsmaps ON websites.ID = wsmaps.websiteID LEFT JOIN OnpubSections " .
  644.           "AS sections ON wsmaps.sectionID = sections.ID LEFT JOIN " .
  645.           "OnpubImages AS sectionimages ON sections.imageID = " .
  646.           "sectionimages.ID $where ORDER BY $orderBy";
  647.       }
  648.     }
  649.     else {
  650.       return "SELECT websites.ID, imageID, name, websites.url, imagesURL, " .
  651.              "imagesDirectory, websites.created, websites.modified, " .
  652.              "websiteimages.fileName, websiteimages.description, " .
  653.              "websiteimages.url AS websiteImageURL, websiteimages.created " .
  654.              "AS imageCreated, websiteimages.modified AS imageModified " .
  655.              "FROM OnpubWebsites AS websites LEFT JOIN OnpubImages AS " .
  656.              "websiteimages ON websites.imageID = websiteimages.ID " .
  657.              "WHERE websites.ID = $ID";
  658.     }
  659.   }
  660.  
  661.   /**
  662.    * @param OnpubWebsite $website Website whose ID you want to get.
  663.    * @return int The ID of the website. NULL if the website does not exist in the database.
  664.    */
  665.   public function getID(OnpubWebsite $website)
  666.   {
  667.     $stmt = $this->pdo->prepare("SELECT ID FROM OnpubWebsites WHERE name = :name");
  668.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, FALSE);
  669.  
  670.     $name = OnpubDatabase::utf8Decode(trim($website->name));
  671.  
  672.     $stmt->bindParam(':name', $name);
  673.     $result = $stmt->execute();
  674.     OnpubDatabase::verifyExecute($this->pdo, $result, FALSE, $stmt->errorInfo());
  675.  
  676.     if (($row = $stmt->fetch(PDO::FETCH_ASSOC))) {
  677.       return $row["ID"];
  678.     }
  679.  
  680.     return NULL;
  681.   }
  682.  
  683.   /**
  684.    * @param mixed $websites A single {@link OnpubWebsite} object or an array of {@link OnpubWebsite} objects (to insert multiple websites at a time).
  685.    * @return mixed The ID(s) of the new website(s). An int will be returned if a single website was inserted. An array of ints will be returned if multiple websites were inserted.
  686.    * @throws PDOException if there's a database error.
  687.    */
  688.   public function insert($websites)
  689.   {
  690.     $oimages = new OnpubImages($this->pdo, FALSE);
  691.     $IDs = array();
  692.     $isArray = TRUE;
  693.  
  694.     if (!is_array($websites)) {
  695.       $websites = array ($websites);
  696.       $isArray = FALSE;
  697.     }
  698.  
  699.     if ($this->enableTransactions) {
  700.       $status = $this->pdo->beginTransaction();
  701.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  702.     }
  703.  
  704.     $stmt = $this->pdo->prepare("INSERT INTO OnpubWebsites (ID, imageID, name, url, imagesURL, imagesDirectory, created, modified) VALUES (:ID, :imageID, :name, :url, :imagesURL, :imagesDirectory, :created, :modified)");
  705.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, $this->enableTransactions);
  706.  
  707.     foreach ($websites as $website) {
  708.       if ($website->image) {
  709.         try {
  710.           $imageID = $oimages->insert($website->image);
  711.           $website->imageID = $imageID;
  712.         }
  713.         catch (PDOException $e) {
  714.           if ($this->enableTransactions)
  715.             $this->pdo->rollBack();
  716.  
  717.           throw $e;
  718.         }
  719.       }
  720.  
  721.       try {
  722.         $ID = $this->getID($website);
  723.       }
  724.       catch (PDOException $e) {
  725.         if ($this->enableTransactions)
  726.           $this->pdo->rollBack();
  727.  
  728.         throw $e;
  729.       }
  730.  
  731.       if ($ID) {
  732.         $IDs[] = $ID;
  733.         $website->ID = $ID;
  734.       }
  735.       else {
  736.         $ID = $website->ID;
  737.         $imageID = $website->imageID;
  738.         $name = OnpubDatabase::utf8Decode(trim($website->name));
  739.         $url = OnpubDatabase::utf8Decode(trim($website->url));
  740.         $imagesURL = OnpubDatabase::utf8Decode(trim($website->imagesURL));
  741.         $imagesDirectory = OnpubDatabase::utf8Decode(trim($website->imagesDirectory));
  742.         $created = $website->getCreated()->format('Y-m-d H:i:s');
  743.         $modified = $website->getModified()->format('Y-m-d H:i:s');
  744.  
  745.         $stmt->bindParam(':ID', $ID);
  746.         $stmt->bindParam(':imageID', $imageID);
  747.         $stmt->bindParam(':name', $name);
  748.         $stmt->bindParam(':url', $url);
  749.         $stmt->bindParam(':imagesURL', $imagesURL);
  750.         $stmt->bindParam(':imagesDirectory', $imagesDirectory);
  751.         $stmt->bindParam(':created', $created);
  752.         $stmt->bindParam(':modified', $modified);
  753.         $result = $stmt->execute();
  754.         OnpubDatabase::verifyExecute($this->pdo, $result, $this->enableTransactions, $stmt->errorInfo());
  755.  
  756.         $IDs[] = $this->pdo->lastInsertId();
  757.         $website->ID = $this->pdo->lastInsertId();
  758.       }
  759.     }
  760.  
  761.     if ($this->enableTransactions) {
  762.       $status = $this->pdo->commit();
  763.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  764.     }
  765.  
  766.     if ($isArray) {
  767.       return $IDs;
  768.     }
  769.     else {
  770.       return end($IDs);
  771.     }
  772.   }
  773.  
  774.   /**
  775.    * @param OnpubWebsite $website The website to be updated.
  776.    * @return int 1 if the website was updated. 0 if the website does not exist in the database.
  777.    */
  778.   public function update(OnpubWebsite $website)
  779.   {
  780.     $owsmaps = new OnpubWSMaps($this->pdo, FALSE);
  781.     $now = new DateTime();
  782.  
  783.     if ($this->enableTransactions) {
  784.       $status = $this->pdo->beginTransaction();
  785.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  786.     }
  787.  
  788.     $stmt = $this->pdo->prepare("UPDATE OnpubWebsites SET imageID = :imageID, name = :name, url = :url, imagesURL = :imagesURL, imagesDirectory = :imagesDirectory, modified = :modified WHERE ID = :ID");
  789.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, $this->enableTransactions);
  790.  
  791.     $ID = $website->ID;
  792.     $imageID = $website->imageID;
  793.     $name = OnpubDatabase::utf8Decode(trim($website->name));
  794.     $url = OnpubDatabase::utf8Decode(trim($website->url));
  795.     $imagesURL = OnpubDatabase::utf8Decode(trim($website->imagesURL));
  796.     $imagesDirectory = OnpubDatabase::utf8Decode(trim($website->imagesDirectory));
  797.     $modified = $now->format('Y-m-d H:i:s');
  798.  
  799.     $stmt->bindParam(':ID', $ID);
  800.     $stmt->bindParam(':imageID', $imageID);
  801.     $stmt->bindParam(':name', $name);
  802.     $stmt->bindParam(':url', $url);
  803.     $stmt->bindParam(':imagesURL', $imagesURL);
  804.     $stmt->bindParam(':imagesDirectory', $imagesDirectory);
  805.     $stmt->bindParam(':modified', $modified);
  806.     $result = $stmt->execute();
  807.     OnpubDatabase::verifyExecute($this->pdo, $result, $this->enableTransactions, $stmt->errorInfo());
  808.  
  809.     try {
  810.       $owsmaps->delete($website->ID, NULL);
  811.     }
  812.     catch (PDOException $e) {
  813.       if ($this->enableTransactions)
  814.         $this->pdo->rollBack();
  815.  
  816.       throw $e;
  817.     }
  818.  
  819.     $sections = $website->sections;
  820.     $wsmaps = array();
  821.  
  822.     foreach ($sections as $section) {
  823.       $wsmap = new OnpubWSMap();
  824.  
  825.       $wsmap->websiteID = $section->websiteID;
  826.       $wsmap->sectionID = $section->ID;
  827.  
  828.       $wsmaps[] = $wsmap;
  829.     }
  830.  
  831.     try {
  832.       $owsmaps->insert($wsmaps);
  833.     }
  834.     catch (PDOException $e) {
  835.       if ($this->enableTransactions)
  836.         $this->pdo->rollBack();
  837.  
  838.       throw $e;
  839.     }
  840.  
  841.     if ($this->enableTransactions) {
  842.       $status = $this->pdo->commit();
  843.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  844.     }
  845.  
  846.     return $stmt->rowCount();
  847.   }
  848. }
  849. ?>

Documentation generated on Fri, 08 Feb 2013 04:02:26 -0500 by phpDocumentor 1.4.4