Source for file OnpubSections.php

Documentation is available at OnpubSections.php

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

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