Source for file OnpubArticles.php

Documentation is available at OnpubArticles.php

  1. <?php
  2.  
  3. /**
  4.  * Manage articles 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 OnpubArticles table}.
  8.  *
  9.  * @author {@link mailto:corey@onpub.com Corey H.M. Taylor}
  10.  * @copyright Onpub (TM). Copyright 2012, Onpub.com.
  11.  *  {@link http://onpub.com/}
  12.  * @license http://www.gnu.org/copyleft/gpl.html GNU General Public License
  13.  *  Version 2
  14.  * @package OnpubAPI
  15.  */
  16. class OnpubArticles
  17. {
  18.   private $pdo;
  19.   /**
  20.    * Controls whether or not the methods in this class use transactions when
  21.    * they access the database.
  22.    *
  23.    * By default, this is set to TRUE and database transactions will be used
  24.    * where necessary. Set this to FALSE if you want to manage transactions
  25.    * yourself.
  26.    * @var bool 
  27.    */
  28.   public $enableTransactions;
  29.  
  30.   /**
  31.    * Connect to an Onpub database.
  32.    *
  33.    * All the methods in this class which query the database use the database
  34.    * connection provided by the PDO object required by this constructor.
  35.    * Currently, Onpub only supports MySQL as a database for storing content.
  36.    * Therefore, when constructing the PDO object, only the
  37.    * {@link PHP_MANUAL#ref.pdo-mysql PDO_MYSQL} driver is supported
  38.    * as a PDO {@link PHP_MANUAL#ref.pdo-mysql.connection data source}.
  39.    *
  40.    * All the methods in this class require the
  41.    * {@link http://onpub.com/pdfs/onpub_schema.pdf Onpub schema}
  42.    * to be installed in the PDO-connected database. The {@link OnpubDatabase}
  43.    * class contains methods to manage the Onpub schema. The Onpub
  44.    * schema can also be installed by clicking the "Install the schema" link
  45.    * once logged in to the Onpub web interface. The schema generally only has
  46.    * to be installed once per database.
  47.    *
  48.    * @param PDO $pdo A {@link PHP_MANUAL#function.pdo-construct PHP Data Object}.
  49.    * @param bool $enableTransactions If TRUE (the default), the methods in
  50.    *  this class that use database transactions will do so. If FALSE, methods
  51.    *  that by default use transactions, will not. Only pass FALSE to this
  52.    *  argument if you are managing transactions yourself.
  53.    *
  54.    */
  55.   function __construct(PDO $pdo, $enableTransactions = TRUE)
  56.   {
  57.     $this->pdo = $pdo;
  58.     $this->enableTransactions = $enableTransactions;
  59.     $this->pdo->setAttribute(PDO::ATTR_EMULATE_PREPARES, TRUE);
  60.   }
  61.  
  62.   /**
  63.    * Get the total number of articles in the database.
  64.    *
  65.    * @param int $sectionID Get the total number of articles in a section
  66.    *                        identified by its ID.
  67.    * @return int 
  68.    */
  69.   public function count($sectionID = NULL)
  70.   {
  71.     $query = $this->countQuery($sectionID);
  72.     $result = $this->pdo->query($query);
  73.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  74.  
  75.     if (!($row = $result->fetch(PDO::FETCH_ASSOC))) {
  76.       return 0;
  77.     }
  78.  
  79.     $result->closeCursor();
  80.     return $row["count"];
  81.   }
  82.  
  83.   private function countQuery($sectionID = NULL)
  84.   {
  85.     if ($sectionID) {
  86.       return "SELECT COUNT(articles.ID) AS count FROM OnpubArticles AS articles LEFT JOIN OnpubSAMaps as samaps ON articles.ID = samaps.articleID WHERE sectionID = $sectionID";
  87.     }
  88.     else {
  89.       return "SELECT COUNT(articles.ID) AS count FROM OnpubArticles AS articles";
  90.     }
  91.   }
  92.  
  93.   /**
  94.    * Delete an article from the database.
  95.    *
  96.    * @param int $ID ID of the article to delete.
  97.    * @return int 1 if the article was deleted, 0 if the article does not exist in the database.
  98.    */
  99.   public function delete($ID)
  100.   {
  101.     $oaamaps = new OnpubAAMaps($this->pdo, FALSE);
  102.     $osamaps = new OnpubSAMaps($this->pdo, FALSE);
  103.  
  104.     if ($this->enableTransactions) {
  105.       $status = $this->pdo->beginTransaction();
  106.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  107.     }
  108.  
  109.     try {
  110.       $oaamaps->delete($ID, NULL);
  111.     }
  112.     catch (PDOException $e) {
  113.       if ($this->enableTransactions)
  114.         $this->pdo->rollBack();
  115.  
  116.       throw $e;
  117.     }
  118.  
  119.     try {
  120.       $osamaps->delete(NULL, $ID);
  121.     }
  122.     catch (PDOException $e) {
  123.       if ($this->enableTransactions)
  124.         $this->pdo->rollBack();
  125.  
  126.       throw $e;
  127.     }
  128.  
  129.     $stmt = $this->pdo->prepare("DELETE FROM OnpubArticles WHERE ID = :ID");
  130.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, $this->enableTransactions);
  131.  
  132.     $stmt->bindParam(':ID', $ID);
  133.  
  134.     $result = $stmt->execute();
  135.     OnpubDatabase::verifyExecute($this->pdo, $result, $this->enableTransactions, $stmt->errorInfo());
  136.  
  137.     if ($this->enableTransactions) {
  138.       $status = $this->pdo->commit();
  139.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  140.     }
  141.  
  142.     return $stmt->rowCount();
  143.   }
  144.  
  145.   /**
  146.    * Search for articles in the database.
  147.    *
  148.    * @param string $keywords Keyword(s) to search for.
  149.    * @return array All the articles which were found as an array of {@link OnpubArticle} objects.
  150.    */
  151.   public function search($keywords, OnpubQueryOptions $queryOptions = NULL)
  152.   {
  153.     if ($queryOptions === NULL)
  154.       $queryOptions = new OnpubQueryOptions();
  155.  
  156.     $query = $this->searchQuery($keywords, $queryOptions);
  157.     $result = $this->pdo->query($query);
  158.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  159.  
  160.     $rows = $result->fetchAll(PDO::FETCH_ASSOC);
  161.  
  162.     $articles = array();
  163.     $authors = array();
  164.     $lastAID = 0;
  165.     $lastArticle = NULL;
  166.     $content = "";
  167.  
  168.     if ($rows) {
  169.       foreach ($rows as $row) {
  170.         $currAID = $row["ID"];
  171.         $currIID = $row["imageID"];
  172.         $currAIID = $row["authorImageID"];
  173.  
  174.         if ($lastAID != $currAID) {
  175.           $authors = array();
  176.         }
  177.  
  178.         $author = new OnpubAuthor();
  179.  
  180.         $author->ID = $row["authorID"];
  181.         $author->imageID = $currAIID;
  182.         $author->givenNames = $row["givenNames"];
  183.         $author->familyName = $row["familyName"];
  184.         $author->displayAs = $row["displayAs"];
  185.         $author->setCreated(new DateTime($row["authorCreated"]));
  186.         $author->setModified(new DateTime($row["authorModified"]));
  187.  
  188.         $authors[] = $author;
  189.  
  190.         if ($currAIID) {
  191.           $s = sizeof($authors);
  192.           $author = $authors[($s - 1)];
  193.  
  194.           $image = new OnpubImage();
  195.  
  196.           $image->ID = $currAIID;
  197.           $image->websiteID = $row["authorImageWebsiteID"];
  198.           $image->fileName = $row["authorImageFileName"];
  199.           $image->description = $row["authorImageDescription"];
  200.           $image->setCreated(new DateTime($row["authorImageCreated"]));
  201.           $image->setModified(new DateTime($row["authorImageModified"]));
  202.  
  203.           $author->image = $image;
  204.         }
  205.  
  206.         if ($queryOptions->includeContent) {
  207.           $content = $row["content"];
  208.         }
  209.         else {
  210.           $content = "";
  211.         }
  212.  
  213.         $currArticle = new OnpubArticle();
  214.  
  215.         $currArticle->ID = $currAID;
  216.         $currArticle->imageID = $currIID;
  217.         $currArticle->title = $row["title"];
  218.         $currArticle->content = $content;
  219.         $currArticle->url = $row["url"];
  220.         $currArticle->setCreated(new DateTime($row["created"]));
  221.         $currArticle->setModified(new DateTime($row["modified"]));
  222.  
  223.         if ($currIID) {
  224.           $image = new OnpubImage();
  225.  
  226.           $image->ID = $currIID;
  227.           $image->websiteID = $row["websiteID"];
  228.           $image->fileName = $row["fileName"];
  229.           $image->description = $row["description"];
  230.           $image->url = $row["articleImageURL"];
  231.           $image->setCreated(new DateTime($row["imageCreated"]));
  232.           $image->setModified(new DateTime($row["imageModified"]));
  233.  
  234.           $currArticle->image = $image;
  235.         }
  236.  
  237.         if ($lastArticle != NULL) {
  238.           if ($lastArticle->ID == $currArticle->ID) {
  239.             $lastArticle->authors = $authors;
  240.           }
  241.           else {
  242.             $articles[] = $currArticle;
  243.             $currArticle->authors = $authors;
  244.           }
  245.         }
  246.         else {
  247.           $articles[] = $currArticle;
  248.           $currArticle->authors = $authors;
  249.         }
  250.  
  251.         $lastAID = $currAID;
  252.  
  253.         if ($lastArticle != NULL) {
  254.           if ($lastArticle->ID != $currArticle->ID) {
  255.             $lastArticle = $currArticle;
  256.           }
  257.         }
  258.         else {
  259.           $lastArticle = $currArticle;
  260.         }
  261.       }
  262.     }
  263.  
  264.     $result->closeCursor();
  265.     return $articles;
  266.   }
  267.  
  268.   private function searchQuery($keywords, OnpubQueryOptions $queryOptions = NULL)
  269.   {
  270.     if ($queryOptions === NULL)
  271.       $queryOptions = new OnpubQueryOptions();
  272.  
  273.     $keywords = OnpubDatabase::utf8Decode(trim($keywords));
  274.     $where = "";
  275.  
  276.     if ($keywords) {
  277.       if ($queryOptions->fullTextSearch) {
  278.         $where = "WHERE articles.title LIKE '%$keywords%' OR authors.displayAS LIKE '%$keywords%' OR articles.created LIKE '%$keywords%' OR articles.modified LIKE '%$keywords%' OR articles.ID LIKE '%$keywords%' OR articles.content LIKE '%$keywords%' OR articles.url LIKE '%$keywords%'";
  279.       }
  280.       else {
  281.         $where = "WHERE articles.title LIKE '%$keywords%' OR authors.displayAS LIKE '%$keywords%' OR articles.created LIKE '%$keywords%' OR articles.modified LIKE '%$keywords%' OR articles.ID LIKE '%$keywords%' OR articles.url LIKE '%$keywords%'";
  282.       }
  283.     }
  284.  
  285.     if ($queryOptions->orderBy) {
  286.       $orderBy = $queryOptions->orderBy;
  287.     }
  288.     else {
  289.       $orderBy = "";
  290.     }
  291.  
  292.     if ($queryOptions->order) {
  293.       $order = $queryOptions->order;
  294.     }
  295.     else {
  296.       $order = "";
  297.     }
  298.  
  299.     if ($queryOptions->includeContent) {
  300.       $articleColumns = "articles.ID, articles.imageID, title, content, articles.url, articles.created, articles.modified";
  301.     }
  302.     else {
  303.       $articleColumns = "articles.ID, articles.imageID, title, articles.url,  articles.created, articles.modified";
  304.     }
  305.  
  306.     if ($queryOptions->dateLimit) {
  307.       $dateLimit = $queryOptions->dateLimit->format('Y-m-d H:i:s');
  308.  
  309.       if ($keywords) {
  310.         $where .= " AND articles.created <= '$dateLimit'";
  311.       }
  312.       else {
  313.         $where = "WHERE articles.created <= '$dateLimit'";
  314.       }
  315.     }
  316.  
  317.     if ($orderBy) {
  318.       if ($order) {
  319.         return
  320.           "SELECT $articleColumns, articleimages.websiteID, articleimages.fileName, articleimages.description, articleimages.url AS articleImageURL, articleimages.created AS imageCreated, articleimages.modified AS imageModified, authors.ID AS authorID, authors.imageID AS authorImageID, givenNames, familyName, 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 OnpubArticles AS articles 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 articles.$orderBy $order";
  321.       }
  322.       else {
  323.         return "SELECT $articleColumns, articleimages.websiteID, articleimages.fileName, articleimages.description, articleimages.url AS articleImageURL, articleimages.created AS imageCreated, articleimages.modified AS imageModified, authors.ID AS authorID, authors.imageID AS authorImageID, givenNames, familyName, 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 OnpubArticles AS articles 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 articles.$orderBy";
  324.       }
  325.     }
  326.     else {
  327.       return "SELECT $articleColumns, articleimages.websiteID, articleimages.fileName, articleimages.description, articleimages.url AS articleImageURL, articleimages.created AS imageCreated, articleimages.modified AS imageModified, authors.ID AS authorID, authors.imageID AS authorImageID, givenNames, familyName, 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 OnpubArticles AS articles 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";
  328.     }
  329.   }
  330.  
  331.   /**
  332.    * Get a single article from the database.
  333.    *
  334.    * @param int $ID ID of the article to get.
  335.    * @param OnpubQueryOptions $queryOptions Optional database query options.
  336.    * @return OnpubArticle An {@link OnpubArticle} object. NULL if the article does not exist in the database.
  337.    */
  338.   public function get($ID, OnpubQueryOptions $queryOptions = NULL)
  339.   {
  340.     if ($queryOptions === NULL)
  341.       $queryOptions = new OnpubQueryOptions();
  342.  
  343.     $query = $this->getQuery($ID, $queryOptions);
  344.     $result = $this->pdo->query($query);
  345.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  346.     $rows = $result->fetchAll(PDO::FETCH_ASSOC);
  347.  
  348.     if (!$rows) {
  349.       return NULL;
  350.     }
  351.  
  352.     $row = $rows[0];
  353.  
  354.     if ($queryOptions->includeContent) {
  355.       $content = $row["content"];
  356.     }
  357.     else {
  358.       $content = "";
  359.     }
  360.  
  361.     $article = new OnpubArticle();
  362.  
  363.     $article->ID = $row["ID"];
  364.     $article->imageID = $row["imageID"];
  365.     $article->title = $row["title"];
  366.     $article->content = $content;
  367.     $article->url = $row["url"];
  368.     $article->setCreated(new DateTime($row["created"]));
  369.     $article->setModified(new DateTime($row["modified"]));
  370.  
  371.     if (!$queryOptions->includeAuthors) {
  372.       return $article;
  373.     }
  374.  
  375.     if ($row["imageID"]) {
  376.       $image = new OnpubImage();
  377.  
  378.       $image->ID = $row["imageID"];
  379.       $image->websiteID = $row["websiteID"];
  380.       $image->fileName = $row["fileName"];
  381.       $image->description = $row["description"];
  382.       $image->setCreated(new DateTime($row["imageCreated"]));
  383.       $image->setModified(new DateTime($row["imageModified"]));
  384.  
  385.       $article->image = $image;
  386.     }
  387.  
  388.     $authorsassoc = array();
  389.  
  390.     foreach ($rows as $row) {
  391.       $authorID = $row["authorID"];
  392.  
  393.       if ($authorID) {
  394.         $author = new OnpubAuthor();
  395.  
  396.         $author->ID = $authorID;
  397.         $author->imageID = $row["authorImageID"];
  398.         $author->givenNames = $row["givenNames"];
  399.         $author->familyName = $row["familyName"];
  400.         $author->displayAs = $row["displayAs"];
  401.         $author->setCreated(new DateTime($row["authorCreated"]));
  402.         $author->setModified(new DateTime($row["authorModified"]));
  403.  
  404.         if (isset($authorsassoc["$authorID"])) {
  405.           $author = $authorsassoc["$authorID"];
  406.         }
  407.         else {
  408.           $authorsassoc["$authorID"] = $author;
  409.         }
  410.  
  411.         if ($row["authorImageID"]) {
  412.           $image = new OnpubImage();
  413.  
  414.           $image->ID = $row["authorImageID"];
  415.           $image->websiteID = $row["authorImageWebsiteID"];
  416.           $image->fileName = $row["authorImageFileName"];
  417.           $image->description = $row["authorImageDescription"];
  418.           $image->setCreated(new DateTime($row["authorImageCreated"]));
  419.           $image->setModified(new DateTime($row["authorImageModified"]));
  420.  
  421.           $author->image = $image;
  422.         }
  423.  
  424.         $authors = $article->authors;
  425.         $exists = FALSE;
  426.  
  427.         foreach ($authors as $a) {
  428.           if ($a->ID == $author->ID) {
  429.             $exists = TRUE;
  430.           }
  431.         }
  432.  
  433.         if ($exists == FALSE) {
  434.           $authors[] = $author;
  435.           $article->authors = $authors;
  436.         }
  437.       }
  438.     }
  439.  
  440.     $result->closeCursor();
  441.     return $article;
  442.   }
  443.  
  444.   private function getQuery($ID, OnpubQueryOptions $queryOptions = NULL)
  445.   {
  446.     if ($queryOptions === NULL)
  447.       $queryOptions = new OnpubQueryOptions();
  448.  
  449.     if ($queryOptions->orderBy) {
  450.       $orderBy = $queryOptions->orderBy;
  451.       $orderBy = "articles.$orderBy";
  452.     }
  453.     else {
  454.       $orderBy = "aamaps.ID";
  455.     }
  456.  
  457.     if ($queryOptions->order) {
  458.       $order = $queryOptions->order;
  459.     }
  460.     else {
  461.       $order = "";
  462.     }
  463.  
  464.     $where = "WHERE articles.ID = $ID";
  465.  
  466.     if ($queryOptions->dateLimit) {
  467.       $dateLimit = $queryOptions->dateLimit->format('Y-m-d H:i:s');
  468.       $where .= " AND articles.created <= '$dateLimit'";
  469.     }
  470.  
  471.     if ($queryOptions->includeContent) {
  472.       $articleColumns = "articles.ID, articles.imageID, title, content, " .
  473.                         "articles.url, articles.created, articles.modified";
  474.     }
  475.     else {
  476.       $articleColumns = "articles.ID, articles.imageID, title, articles.url, " .
  477.                         "articles.created, articles.modified";
  478.     }
  479.  
  480.     if ($queryOptions->includeAuthors) {
  481.       return "SELECT $articleColumns, articleimages.websiteID, " .
  482.              "articleimages.fileName, articleimages.description, " .
  483.              "articleimages.url AS articleImageURL, articleimages.created AS " .
  484.              "imageCreated, articleimages.modified AS imageModified, " .
  485.              "authors.ID AS authorID, authors.imageID AS authorImageID, " .
  486.              "givenNames, familyName, displayAs, authors.created AS " .
  487.              "authorCreated, authors.modified AS authorModified, " .
  488.              "authorimages.websiteID AS authorImageWebsiteID, " .
  489.              "authorimages.fileName AS authorImageFileName, " .
  490.              "authorimages.description AS authorImageDescription, " .
  491.              "authorimages.url AS authorImageURL, authorimages.created AS " .
  492.              "authorImageCreated, authorimages.modified AS authorImageModified " .
  493.              "FROM OnpubArticles AS articles LEFT JOIN OnpubImages AS " .
  494.              "articleimages ON articles.imageID = articleimages.ID " .
  495.              "LEFT JOIN OnpubAAMaps AS aamaps ON articles.ID = aamaps.articleID " .
  496.              "LEFT JOIN OnpubAuthors AS authors ON aamaps.authorID = authors.ID " .
  497.              "LEFT JOIN OnpubImages AS authorimages ON " .
  498.              "authors.imageID = authorimages.ID $where ORDER BY $orderBy $order";
  499.     }
  500.     else {
  501.       return "SELECT $articleColumns FROM OnpubArticles as articles WHERE ID = $ID";
  502.     }
  503.   }
  504.  
  505.   /**
  506.    * Get the ID of an article in the database.
  507.    *
  508.    * Looks for an article in the database with the same title and content.
  509.    * If there's a match, the ID of the article is returned.
  510.    *
  511.    * @param OnpubArticle $article Article whose ID you want to get.
  512.    * @return int The ID of the article. NULL if the article does not exist in the database.
  513.    */
  514.   public function getID(OnpubArticle $article)
  515.   {
  516.     $stmt = $this->pdo->prepare("SELECT ID FROM OnpubArticles WHERE title = :title AND content = :content");
  517.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, FALSE);
  518.  
  519.     $title = OnpubDatabase::utf8Decode(trim($article->title));
  520.     $content = OnpubDatabase::utf8Decode(trim($article->content));
  521.  
  522.     $stmt->bindParam(':title', $title);
  523.     $stmt->bindParam(':content', $content);
  524.     $result = $stmt->execute();
  525.     OnpubDatabase::verifyExecute($this->pdo, $result, FALSE, $stmt->errorInfo());
  526.  
  527.     if (($row = $stmt->fetch(PDO::FETCH_ASSOC))) {
  528.       return $row["ID"];
  529.     }
  530.  
  531.     return NULL;
  532.   }
  533.  
  534.   /**
  535.    * Insert new article(s) into the database.
  536.    *
  537.    * @param mixed $articles A single {@link OnpubArticle} object or an array of {@link OnpubArticle} objects (to insert multiple articles at a time).
  538.    * @return mixed The ID(s) of the new article(s). An int will be returned if a single article was inserted. An array of ints will be returned if multiple articles were inserted.
  539.    * @throws PDOException if there's a database error.
  540.    */
  541.   public function insert($articles)
  542.   {
  543.     $oimages = new OnpubImages($this->pdo, FALSE);
  544.     $oauthors = new OnpubAuthors($this->pdo, FALSE);
  545.     $oaamaps = new OnpubAAMaps($this->pdo, FALSE);
  546.     $osamaps = new OnpubSAMaps($this->pdo, FALSE);
  547.     $IDs = array();
  548.     $isArray = TRUE;
  549.  
  550.     if (!is_array($articles)) {
  551.       $articles = array ($articles);
  552.       $isArray = FALSE;
  553.     }
  554.  
  555.     if ($this->enableTransactions) {
  556.       $status = $this->pdo->beginTransaction();
  557.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  558.     }
  559.  
  560.     $stmt = $this->pdo->prepare("INSERT INTO OnpubArticles (ID, imageID, title, content, url, created, modified) VALUES (:ID, :imageID, :title, :content, :url, :created, :modified)");
  561.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, $this->enableTransactions);
  562.  
  563.     foreach ($articles as $article) {
  564.       if ($article->image) {
  565.         try {
  566.           $imageID = $oimages->insert($article->image);
  567.           $article->imageID = $imageID;
  568.         }
  569.         catch (PDOException $e) {
  570.           if ($this->enableTransactions)
  571.             $this->pdo->rollBack();
  572.  
  573.           throw $e;
  574.         }
  575.       }
  576.  
  577.       try {
  578.         $ID = $this->getID($article);
  579.       }
  580.       catch (PDOException $e) {
  581.         if ($this->enableTransactions)
  582.           $this->pdo->rollBack();
  583.  
  584.         throw $e;
  585.       }
  586.  
  587.       if ($ID) {
  588.         $IDs[] = $ID;
  589.         $article->ID = $ID;
  590.       }
  591.       else {
  592.         $ID = $article->ID;
  593.         $imageID = $article->imageID;
  594.         $title = OnpubDatabase::utf8Decode(trim($article->title));
  595.         $content = OnpubDatabase::utf8Decode(trim($article->content));
  596.         $url = OnpubDatabase::utf8Decode(trim($article->url));
  597.         $created = $article->getCreated()->format('Y-m-d H:i:s');
  598.         $modified = $article->getModified()->format('Y-m-d H:i:s');
  599.  
  600.         $stmt->bindParam(':ID', $ID);
  601.         $stmt->bindParam(':imageID', $imageID);
  602.         $stmt->bindParam(':title', $title);
  603.         $stmt->bindParam(':content', $content);
  604.         $stmt->bindParam(':url', $url);
  605.         $stmt->bindParam(':created', $created);
  606.         $stmt->bindParam(':modified', $modified);
  607.         $result = $stmt->execute();
  608.         OnpubDatabase::verifyExecute($this->pdo, $result, $this->enableTransactions, $stmt->errorInfo());
  609.  
  610.         $IDs[] = $this->pdo->lastInsertId();
  611.         $article->ID = $this->pdo->lastInsertId();
  612.       }
  613.  
  614.       $authors = $article->authors;
  615.  
  616.       try {
  617.         $oauthors->insert($authors);
  618.       }
  619.       catch (PDOException $e) {
  620.         if ($this->enableTransactions)
  621.           $this->pdo->rollBack();
  622.  
  623.         throw $e;
  624.       }
  625.  
  626.       $aamaps = array();
  627.  
  628.       foreach ($authors as $author) {
  629.         $aamap = new OnpubAAMap();
  630.  
  631.         $aamap->articleID = $article->ID;
  632.         $aamap->authorID = $author->ID;
  633.         $aamap->setCreated($article->getCreated());
  634.         $aamap->setModified($article->getModified());
  635.  
  636.         $aamaps[] = $aamap;
  637.       }
  638.  
  639.       try {
  640.         $oaamaps->insert($aamaps);
  641.       }
  642.       catch (PDOException $e) {
  643.         if ($this->enableTransactions)
  644.           $this->pdo->rollBack();
  645.  
  646.         throw $e;
  647.       }
  648.  
  649.       $sectionIDs = $article->sectionIDs;
  650.       $samaps = array();
  651.  
  652.       foreach ($sectionIDs as $sectionID) {
  653.         $samap = new OnpubSAMap();
  654.  
  655.         $samap->sectionID = $sectionID;
  656.         $samap->articleID = $article->ID;
  657.         $samap->setCreated($article->getCreated());
  658.         $samap->setModified($article->getModified());
  659.  
  660.         $samaps[] = $samap;
  661.       }
  662.  
  663.       try {
  664.         $osamaps->insert($samaps);
  665.       }
  666.       catch (PDOException $e) {
  667.         if ($this->enableTransactions)
  668.           $this->pdo->rollBack();
  669.  
  670.         throw $e;
  671.       }
  672.     }
  673.  
  674.     if ($this->enableTransactions) {
  675.       $status = $this->pdo->commit();
  676.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  677.     }
  678.  
  679.     if ($isArray) {
  680.       return $IDs;
  681.     }
  682.     else {
  683.       return end($IDs);
  684.     }
  685.   }
  686.  
  687.   /**
  688.    * Get multiple articles from the database.
  689.    *
  690.    * @param OnpubQueryOptions $queryOptions Database query options.
  691.    * @return array An array of {@link OnpubArticle} objects.
  692.    */
  693.   public function select(OnpubQueryOptions $queryOptions = NULL, $sectionID = NULL, $websiteID = NULL)
  694.   {
  695.     if ($queryOptions === NULL)
  696.       $queryOptions = new OnpubQueryOptions();
  697.  
  698.     $query = $this->selectQuery($queryOptions, $sectionID, $websiteID);
  699.     $result = $this->pdo->query($query);
  700.     OnpubDatabase::verifyQuery($this->pdo, $result, FALSE);
  701.     $rows = $result->fetchAll(PDO::FETCH_ASSOC);
  702.  
  703.     $articles = array();
  704.  
  705.     if ($rows) {
  706.       $lastID = null;
  707.       $article = new OnpubArticle();
  708.  
  709.       foreach ($rows as $row) {
  710.         if ($lastID != $row["ID"]) {
  711.           $article = new OnpubArticle();
  712.         }
  713.  
  714.         if ($queryOptions->includeContent) {
  715.           $content = $row["content"];
  716.         }
  717.         else {
  718.           $content = "";
  719.         }
  720.  
  721.         $article->ID = $row["ID"];
  722.         $article->imageID = $row["imageID"];
  723.         $article->title = $row["title"];
  724.         $article->content = $content;
  725.         $article->url = $row["url"];
  726.         $article->setCreated(new DateTime($row["created"]));
  727.         $article->setModified(new DateTime($row["modified"]));
  728.  
  729.         if ($row["imageID"]) {
  730.           $image = new OnpubImage();
  731.     
  732.           $image->ID = $row["imageID"];
  733.           $image->websiteID = $row["imageWebsiteID"];
  734.           $image->fileName = $row["imageFileName"];
  735.           $image->description = $row["imageDescription"];
  736.           $image->setCreated(new DateTime($row["imageCreated"]));
  737.           $image->setModified(new DateTime($row["imageModified"]));
  738.     
  739.           $article->image = $image;
  740.         }
  741.  
  742.         if ($sectionID || $websiteID) {
  743.           $article->sectionIDs[] = $row["sectionID"];
  744.         }
  745.  
  746.         if ($lastID != $row["ID"]) {
  747.           $articles[] = $article;
  748.         }
  749.  
  750.         $lastID = $article->ID;
  751.       }
  752.     }
  753.  
  754.     $result->closeCursor();
  755.     return $articles;
  756.   }
  757.  
  758.   private function selectQuery(OnpubQueryOptions $queryOptions = NULL, $sectionID = NULL, $websiteID = NULL)
  759.   {
  760.     if ($queryOptions === NULL)
  761.       $queryOptions = new OnpubQueryOptions();
  762.  
  763.     $articleColumns = "articles.ID, articles.imageID, articles.title, " .
  764.                       "articles.url, articles.created, articles.modified, " .
  765.                       "articleimages.websiteID AS imageWebsiteID, articleimages.fileName AS imageFileName, " .
  766.                       "articleimages.description AS imageDescription, articleimages.url AS " .
  767.                       "articleImageURL, articleimages.created AS imageCreated, " .
  768.                       "articleimages.modified AS imageModified";
  769.     $where = "";
  770.     $orderBy = "";
  771.     $limit = "";
  772.  
  773.     if ($queryOptions->includeContent) {
  774.       $articleColumns = "articles.ID, articles.imageID, articles.title, " .
  775.                         "articles.content, articles.url, articles.created, " .
  776.                         "articles.modified, articleimages.websiteID AS " .
  777.                         "imageWebsiteID, articleimages.fileName AS " .
  778.                         "imageFileName, articleimages.description AS " .
  779.                         "imageDescription, articleimages.url AS " .
  780.                         "articleImageURL, articleimages.created AS " .
  781.                         "imageCreated, articleimages.modified AS imageModified";
  782.     }
  783.  
  784.     if ($sectionID || $websiteID) {
  785.       $articleColumns .= ", samaps.sectionID AS sectionID";
  786.     }
  787.  
  788.     if ($queryOptions->dateLimit) {
  789.       $where = "WHERE articles.created <= " . $this->pdo->quote($queryOptions->dateLimit->format('Y-m-d H:i:s'));
  790.  
  791.       if ($sectionID && !$websiteID) {
  792.         $where .= " AND samaps.sectionID = $sectionID";
  793.       }
  794.  
  795.       if ($websiteID && !$sectionID) {
  796.         $where .= " AND wsmaps.websiteID = $websiteID";
  797.       }
  798.     }
  799.     else {
  800.       if ($sectionID && !$websiteID) {
  801.         $where = "WHERE samaps.sectionID = $sectionID";
  802.       }
  803.  
  804.       if ($websiteID && !$sectionID) {
  805.         $where = "WHERE wsmaps.websiteID = $websiteID";
  806.       }
  807.     }
  808.  
  809.     if ($queryOptions->orderBy) {
  810.       $orderBy = "ORDER BY articles." . $queryOptions->orderBy;
  811.  
  812.       if ($queryOptions->order) {
  813.         $orderBy .= " " . $queryOptions->order;
  814.       }
  815.     }
  816.     else {
  817.       if ($sectionID && !$websiteID) {
  818.         $orderBy = "ORDER BY samaps.ID ASC";
  819.       }
  820.     }
  821.  
  822.     if ($queryOptions->getPage() && $queryOptions->rowLimit && $queryOptions->rowLimit > 0) {
  823.       $limit = "LIMIT " . (($queryOptions->getPage() - 1) * $queryOptions->rowLimit) .
  824.                "," . $queryOptions->rowLimit;
  825.     }
  826.     elseif ($queryOptions->rowLimit && $queryOptions->rowLimit > 0) {
  827.       $limit = "LIMIT 0," . $queryOptions->rowLimit;
  828.     }
  829.  
  830.     if ($sectionID && !$websiteID) {
  831.       return "SELECT $articleColumns FROM OnpubArticles AS articles LEFT JOIN " .
  832.              "OnpubImages AS articleimages ON articles.imageID = articleimages.ID LEFT JOIN " .
  833.              "OnpubSAMaps AS samaps ON articles.ID = samaps.articleID " .
  834.              "$where $orderBy $limit";
  835.     }
  836.     elseif ($websiteID && !$sectionID) {
  837.       return "SELECT $articleColumns FROM OnpubArticles AS articles LEFT JOIN " .
  838.              "OnpubImages AS articleimages ON articles.imageID = articleimages.ID LEFT JOIN " .
  839.              "OnpubSAMaps AS samaps ON articles.ID = samaps.articleID " .
  840.              "LEFT JOIN OnpubWSMaps AS wsmaps ON samaps.sectionID = " .
  841.              "wsmaps.sectionID $where $orderBy $limit";
  842.     }
  843.     else {
  844.       return "SELECT $articleColumns FROM OnpubArticles AS articles LEFT JOIN " .
  845.              "OnpubImages AS articleimages ON articles.imageID = articleimages.ID " .
  846.              "$where $orderBy $limit";
  847.     }
  848.   }
  849.  
  850.   /**
  851.    * Update an article already in the database.
  852.    *
  853.    * If you set the article's sectionIDs to NULL, it will be unmapped from
  854.    * any sections it was previously mapped to.
  855.    *
  856.    * @param OnpubArticle $article The article to be updated.
  857.    * @param bool $overwriteAAMaps False by default. If set to TRUE, the
  858.    *  article-author maps for this article will be deleted and recreated, if
  859.    *  applicable.
  860.    * @return int 1 if the article was updated. 0 if the article does not exist in the database.
  861.    */
  862.   public function update(OnpubArticle $article, $overwriteAAMaps = FALSE)
  863.   {
  864.     $oaamaps = new OnpubAAMaps($this->pdo, FALSE);
  865.     $oauthors = new OnpubAuthors($this->pdo, FALSE);
  866.     $osamaps = new OnpubSAMaps($this->pdo, FALSE);
  867.     $oimages = new OnpubImages($this->pdo, FALSE);
  868.     $now = new DateTime();
  869.  
  870.     if ($this->enableTransactions) {
  871.       $status = $this->pdo->beginTransaction();
  872.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  873.     }
  874.  
  875.     $stmt = $this->pdo->prepare("UPDATE OnpubArticles SET imageID = :imageID, title = :title, content = :content, url = :url, created = :created, modified = :modified WHERE ID = :ID");
  876.     OnpubDatabase::verifyPrepare($this->pdo, $stmt, $this->enableTransactions);
  877.  
  878.     if ($article->image) {
  879.       try {
  880.         $imageID = $oimages->insert($article->image);
  881.         $article->imageID = $imageID;
  882.       }
  883.       catch (PDOException $e) {
  884.         if ($this->enableTransactions)
  885.           $this->pdo->rollBack();
  886.  
  887.         throw $e;
  888.       }
  889.     }
  890.  
  891.     $ID = $article->ID;
  892.     $imageID = $article->imageID;
  893.     $title = OnpubDatabase::utf8Decode(trim($article->title));
  894.     $content = OnpubDatabase::utf8Decode(trim($article->content));
  895.     $url = OnpubDatabase::utf8Decode(trim($article->url));
  896.     $created = $article->getCreated()->format('Y-m-d H:i:s');
  897.     $modified = $now->format('Y-m-d H:i:s');
  898.  
  899.     $stmt->bindParam(':ID', $ID);
  900.     $stmt->bindParam(':imageID', $imageID);
  901.     $stmt->bindParam(':title', $title);
  902.     $stmt->bindParam(':content', $content);
  903.     $stmt->bindParam(':url', $url);
  904.     $stmt->bindParam(':created', $created);
  905.     $stmt->bindParam(':modified', $modified);
  906.     $result = $stmt->execute();
  907.     OnpubDatabase::verifyExecute($this->pdo, $result, $this->enableTransactions, $stmt->errorInfo());
  908.  
  909.     if ($overwriteAAMaps) {
  910.       try {
  911.         $oaamaps->delete($article->ID, NULL);
  912.       }
  913.       catch (PDOException $e) {
  914.         if ($this->enableTransactions)
  915.           $this->pdo->rollBack();
  916.  
  917.         throw $e;
  918.       }
  919.     }
  920.  
  921.     $authors = $article->authors;
  922.  
  923.     foreach ($authors as $author) {
  924.       if ($author->ID) {
  925.         try {
  926.           $oauthors->update($author);
  927.         }
  928.         catch (PDOException $e) {
  929.           if ($this->enableTransactions)
  930.             $this->pdo->rollBack();
  931.  
  932.           throw $e;
  933.         }
  934.       }
  935.       else {
  936.         try {
  937.           $oauthors->insert($author);
  938.         }
  939.         catch (PDOException $e) {
  940.           if ($this->enableTransactions)
  941.             $this->pdo->rollBack();
  942.  
  943.           throw $e;
  944.         }
  945.       }
  946.  
  947.       try {
  948.         $aamap = new OnpubAAMap();
  949.         $aamap->articleID = $article->ID;
  950.         $aamap->authorID = $author->ID;
  951.         $oaamaps->insert($aamap);
  952.       }
  953.       catch (PDOException $e) {
  954.         if ($this->enableTransactions)
  955.           $this->pdo->rollBack();
  956.  
  957.         throw $e;
  958.       }
  959.     }
  960.  
  961.     $sectionIDs = $article->sectionIDs;
  962.  
  963.     if ($sectionIDs === NULL) {
  964.       try {
  965.         $samaps = $osamaps->delete(NULL, $article->ID);
  966.       }
  967.       catch (PDOException $e) {
  968.         if ($this->enableTransactions)
  969.           $this->pdo->rollBack();
  970.  
  971.         throw $e;
  972.       }
  973.     }
  974.     elseif (sizeof($sectionIDs)) {
  975.       $queryOptions = new OnpubQueryOptions();
  976.       $queryOptions->orderBy = "ID";
  977.       $queryOptions->order = "ASC";
  978.  
  979.       try {
  980.         $samaps = $osamaps->select($queryOptions, NULL, $article->ID);
  981.       }
  982.       catch (PDOException $e) {
  983.         if ($this->enableTransactions)
  984.           $this->pdo->rollBack();
  985.  
  986.         throw $e;
  987.       }
  988.  
  989.       // Unmap sections not included in $sectionIDs.
  990.       foreach ($samaps as $samap) {
  991.         if (!in_array($samap->sectionID, $sectionIDs)) {
  992.           try {
  993.             $osamaps->delete($samap->sectionID, $article->ID);
  994.           }
  995.           catch (PDOException $e) {
  996.             if ($this->enableTransactions)
  997.               $this->pdo->rollBack();
  998.  
  999.             throw $e;
  1000.           }
  1001.         }
  1002.       }
  1003.  
  1004.       foreach ($sectionIDs as $sectionID) {
  1005.         $samap = new OnpubSAMap();
  1006.  
  1007.         $samap->sectionID = $sectionID;
  1008.         $samap->articleID = $article->ID;
  1009.         $samap->setCreated($article->getCreated());
  1010.         $samap->setModified($article->getModified());
  1011.  
  1012.         try {
  1013.           $samapID = $osamaps->getID($samap);
  1014.         }
  1015.         catch (PDOException $e) {
  1016.           if ($this->enableTransactions)
  1017.             $this->pdo->rollBack();
  1018.  
  1019.           throw $e;
  1020.         }
  1021.  
  1022.         if ($samapID) {
  1023.           $samap->ID = $samapID;
  1024.  
  1025.           try {
  1026.             $osamaps->update($samap);
  1027.           }
  1028.           catch (PDOException $e) {
  1029.             if ($this->enableTransactions)
  1030.               $this->pdo->rollBack();
  1031.  
  1032.             throw $e;
  1033.           }
  1034.         }
  1035.         else {
  1036.           try {
  1037.             $osamaps->insert($samap);
  1038.           }
  1039.           catch (PDOException $e) {
  1040.             if ($this->enableTransactions)
  1041.               $this->pdo->rollBack();
  1042.  
  1043.             throw $e;
  1044.           }
  1045.         }
  1046.       }
  1047.     }
  1048.  
  1049.     if ($this->enableTransactions) {
  1050.       $status = $this->pdo->commit();
  1051.       OnpubDatabase::verifyTransaction($this->pdo, $status);
  1052.     }
  1053.  
  1054.     return $stmt->rowCount();
  1055.   }
  1056. }
  1057. ?>

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