Source for file postgresql.php

Documentation is available at postgresql.php

  1. <?php
  2. /**
  3.  * @package     Joomla.Administrator
  4.  * @subpackage  com_finder
  5.  *
  6.  * @copyright   Copyright (C) 2005 - 2013 Open Source Matters, Inc. All rights reserved.
  7.  * @license     GNU General Public License version 2 or later; see LICENSE
  8.  */
  9.  
  10. defined('_JEXEC') or die;
  11.  
  12. jimport('joomla.filesystem.file');
  13.  
  14. /**
  15.  * Indexer class supporting PostgreSQL for the Finder indexer package.
  16.  *
  17.  * @package     Joomla.Administrator
  18.  * @subpackage  com_finder
  19.  * @since       3.0
  20.  */
  21. class FinderIndexerDriverPostgresql extends FinderIndexer
  22. {
  23.     /**
  24.      * Method to index a content item.
  25.      *
  26.      * @param   FinderIndexerResult  $item    The content item to index.
  27.      * @param   string               $format  The format of the content. [optional]
  28.      *
  29.      * @return  integer  The ID of the record in the links table.
  30.      *
  31.      * @since   3.0
  32.      * @throws  Exception on database error.
  33.      */
  34.     public function index($item, $format = 'html')
  35.     {
  36.         // Mark beforeIndexing in the profiler.
  37.         static::$profiler ? static::$profiler->mark('beforeIndexing') : null;
  38.         $db = JFactory::getDbo();
  39.         $nd = $db->getNullDate();
  40.  
  41.         // Check if the item is in the database.
  42.         $query = $db->getQuery(true)
  43.             ->select($db->quoteName('link_id') . ', ' . $db->quoteName('md5sum'))
  44.             ->from($db->quoteName('#__finder_links'))
  45.             ->where($db->quoteName('url') . ' = ' . $db->quote($item->url));
  46.  
  47.         // Load the item  from the database.
  48.         $db->setQuery($query);
  49.         $link = $db->loadObject();
  50.  
  51.         // Get the indexer state.
  52.         $state = static::getState();
  53.  
  54.         // Get the signatures of the item.
  55.         $curSig = static::getSignature($item);
  56.         $oldSig = isset($link->md5sum) ? $link->md5sum : null;
  57.  
  58.         // Get the other item information.
  59.         $linkId = empty($link->link_id) ? null : $link->link_id;
  60.         $isNew = empty($link->link_id) ? true : false;
  61.  
  62.         // Check the signatures. If they match, the item is up to date.
  63.         if (!$isNew && $curSig == $oldSig)
  64.         {
  65.             return $linkId;
  66.         }
  67.  
  68.         /*
  69.          * If the link already exists, flush all the term maps for the item.
  70.          * Maps are stored in 16 tables so we need to iterate through and flush
  71.          * each table one at a time.
  72.          */
  73.         if (!$isNew)
  74.         {
  75.             for ($i = 0; $i <= 15; $i++)
  76.             {
  77.                 // Flush the maps for the link.
  78.                 $query->clear()
  79.                     ->delete($db->quoteName('#__finder_links_terms' . dechex($i)))
  80.                     ->where($db->quoteName('link_id') . ' = ' . (int) $linkId);
  81.                 $db->setQuery($query);
  82.                 $db->execute();
  83.             }
  84.  
  85.             // Remove the taxonomy maps.
  86.             FinderIndexerTaxonomy::removeMaps($linkId);
  87.         }
  88.  
  89.         // Mark afterUnmapping in the profiler.
  90.         static::$profiler ? static::$profiler->mark('afterUnmapping') : null;
  91.  
  92.         // Perform cleanup on the item data.
  93.         $item->publish_start_date = (int) $item->publish_start_date != 0 ? $item->publish_start_date : $nd;
  94.         $item->publish_end_date = (int) $item->publish_end_date != 0 ? $item->publish_end_date : $nd;
  95.         $item->start_date = (int) $item->start_date != 0 ? $item->start_date : $nd;
  96.         $item->end_date = (int) $item->end_date != 0 ? $item->end_date : $nd;
  97.  
  98.         // Prepare the item description.
  99.         $item->description = FinderIndexerHelper::parse($item->summary);
  100.  
  101.         /*
  102.          * Now, we need to enter the item into the links table. If the item
  103.          * already exists in the database, we need to use an UPDATE query.
  104.          * Otherwise, we need to use an INSERT to get the link id back.
  105.          */
  106.  
  107.         if ($isNew)
  108.         {
  109.             $columnsArray = array(
  110.                 $db->quoteName('url'), $db->quoteName('route'), $db->quoteName('title'), $db->quoteName('description'),
  111.                 $db->quoteName('indexdate'), $db->quoteName('published'), $db->quoteName('state'), $db->quoteName('access'),
  112.                 $db->quoteName('language'), $db->quoteName('type_id'), $db->quoteName('object'), $db->quoteName('publish_start_date'),
  113.                 $db->quoteName('publish_end_date'), $db->quoteName('start_date'), $db->quoteName('end_date'), $db->quoteName('list_price'),
  114.                 $db->quoteName('sale_price')
  115.             );
  116.  
  117.             // Insert the link.
  118.             $query->clear()
  119.                 ->insert($db->quoteName('#__finder_links'))
  120.                 ->columns($columnsArray)
  121.                 ->values(
  122.                 $db->quote($item->url) . ', '
  123.                 . $db->quote($item->route) . ', '
  124.                 . $db->quote($item->title) . ', '
  125.                 . $db->quote($item->description) . ', '
  126.                 . $query->currentTimestamp() . ', '
  127.                 . '1, '
  128.                 . (int) $item->state . ', '
  129.                 . (int) $item->access . ', '
  130.                 . $db->quote($item->language) . ', '
  131.                 . (int) $item->type_id . ', '
  132.                 . $db->quote(serialize($item)) . ', '
  133.                 . $db->quote($item->publish_start_date) . ', '
  134.                 . $db->quote($item->publish_end_date) . ', '
  135.                 . $db->quote($item->start_date) . ', '
  136.                 . $db->quote($item->end_date) . ', '
  137.                 . (double) ($item->list_price ? $item->list_price : 0) . ', '
  138.                 . (double) ($item->sale_price ? $item->sale_price : 0)
  139.             );
  140.             $db->setQuery($query);
  141.             $db->execute();
  142.  
  143.             // Get the link id.
  144.             $linkId = (int) $db->insertid();
  145.         }
  146.         else
  147.         {
  148.             // Update the link.
  149.             $query->clear()
  150.                 ->update($db->quoteName('#__finder_links'))
  151.                 ->set($db->quoteName('route') . ' = ' . $db->quote($item->route))
  152.                 ->set($db->quoteName('title') . ' = ' . $db->quote($item->title))
  153.                 ->set($db->quoteName('description') . ' = ' . $db->quote($item->description))
  154.                 ->set($db->quoteName('indexdate') . ' = ' . $query->currentTimestamp())
  155.                 ->set($db->quoteName('state') . ' = ' . (int) $item->state)
  156.                 ->set($db->quoteName('access') . ' = ' . (int) $item->access)
  157.                 ->set($db->quoteName('language') . ' = ' . $db->quote($item->language))
  158.                 ->set($db->quoteName('type_id') . ' = ' . (int) $item->type_id)
  159.                 ->set($db->quoteName('object') . ' = ' . $db->quote(serialize($item)))
  160.                 ->set($db->quoteName('publish_start_date') . ' = ' . $db->quote($item->publish_start_date))
  161.                 ->set($db->quoteName('publish_end_date') . ' = ' . $db->quote($item->publish_end_date))
  162.                 ->set($db->quoteName('start_date') . ' = ' . $db->quote($item->start_date))
  163.                 ->set($db->quoteName('end_date') . ' = ' . $db->quote($item->end_date))
  164.                 ->set($db->quoteName('list_price') . ' = ' . (double) ($item->list_price ? $item->list_price : 0))
  165.                 ->set($db->quoteName('sale_price') . ' = ' . (double) ($item->sale_price ? $item->sale_price : 0))
  166.                 ->where('link_id = ' . (int) $linkId);
  167.             $db->setQuery($query);
  168.             $db->execute();
  169.         }
  170.  
  171.         // Set up the variables we will need during processing.
  172.         $count = 0;
  173.  
  174.         // Mark afterLinking in the profiler.
  175.         static::$profiler ? static::$profiler->mark('afterLinking') : null;
  176.  
  177.         // Truncate the tokens tables.
  178.         $db->truncateTable('#__finder_tokens');
  179.  
  180.         // Truncate the tokens aggregate table.
  181.         $db->truncateTable('#__finder_tokens_aggregate');
  182.  
  183.         /*
  184.          * Process the item's content. The items can customize their
  185.          * processing instructions to define extra properties to process
  186.          * or rearrange how properties are weighted.
  187.          */
  188.         foreach ($item->getInstructions() as $group => $properties)
  189.         {
  190.             // Iterate through the properties of the group.
  191.             foreach ($properties as $property)
  192.             {
  193.                 // Check if the property exists in the item.
  194.                 if (empty($item->$property))
  195.                 {
  196.                     continue;
  197.                 }
  198.  
  199.                 // Tokenize the property.
  200.                 if (is_array($item->$property))
  201.                 {
  202.                     // Tokenize an array of content and add it to the database.
  203.                     foreach ($item->$property as $ip)
  204.                     {
  205.                         /*
  206.                          * If the group is path, we need to a few extra processing
  207.                          * steps to strip the extension and convert slashes and dashes
  208.                          * to spaces.
  209.                          */
  210.                         if ($group === static::PATH_CONTEXT)
  211.                         {
  212.                             $ip = JFile::stripExt($ip);
  213.                             $ip = str_replace('/', ' ', $ip);
  214.                             $ip = str_replace('-', ' ', $ip);
  215.                         }
  216.  
  217.                         // Tokenize a string of content and add it to the database.
  218.                         $count += $this->tokenizeToDB($ip, $group, $item->language, $format);
  219.  
  220.                         // Check if we're approaching the memory limit of the token table.
  221.                         if ($count > static::$state->options->get('memory_table_limit', 30000))
  222.                         {
  223.                             $this->toggleTables(false);
  224.                         }
  225.                     }
  226.                 }
  227.                 else
  228.                 {
  229.                     /*
  230.                      * If the group is path, we need to a few extra processing
  231.                      * steps to strip the extension and convert slashes and dashes
  232.                      * to spaces.
  233.                      */
  234.                     if ($group === static::PATH_CONTEXT)
  235.                     {
  236.                         $item->$property = JFile::stripExt($item->$property);
  237.                         $item->$property = str_replace('/', ' ', $item->$property);
  238.                         $item->$property = str_replace('-', ' ', $item->$property);
  239.                     }
  240.  
  241.                     // Tokenize a string of content and add it to the database.
  242.                     $count += $this->tokenizeToDB($item->$property, $group, $item->language, $format);
  243.  
  244.                     // Check if we're approaching the memory limit of the token table.
  245.                     if ($count > static::$state->options->get('memory_table_limit', 30000))
  246.                     {
  247.                         $this->toggleTables(false);
  248.                     }
  249.                 }
  250.             }
  251.         }
  252.  
  253.         /*
  254.          * Process the item's taxonomy. The items can customize their
  255.          * taxonomy mappings to define extra properties to map.
  256.          */
  257.         foreach ($item->getTaxonomy() as $branch => $nodes)
  258.         {
  259.             // Iterate through the nodes and map them to the branch.
  260.             foreach ($nodes as $node)
  261.             {
  262.                 // Add the node to the tree.
  263.                 $nodeId = FinderIndexerTaxonomy::addNode($branch, $node->title, $node->state, $node->access);
  264.  
  265.                 // Add the link => node map.
  266.                 FinderIndexerTaxonomy::addMap($linkId, $nodeId);
  267.  
  268.                 // Tokenize the node title and add them to the database.
  269.                 $count += $this->tokenizeToDB($node->title, static::META_CONTEXT, $item->language, $format);
  270.             }
  271.         }
  272.  
  273.         // Mark afterProcessing in the profiler.
  274.         static::$profiler ? static::$profiler->mark('afterProcessing') : null;
  275.  
  276.         /*
  277.          * At this point, all of the item's content has been parsed, tokenized
  278.          * and inserted into the #__finder_tokens table. Now, we need to
  279.          * aggregate all the data into that table into a more usable form. The
  280.          * aggregated data will be inserted into #__finder_tokens_aggregate
  281.          * table.
  282.          */
  283.         $query    = 'INSERT INTO ' . $db->quoteName('#__finder_tokens_aggregate') .
  284.                 ' (' . $db->quoteName('term_id') .
  285.                 ', ' . $db->quoteName('term') .
  286.                 ', ' . $db->quoteName('stem') .
  287.                 ', ' . $db->quoteName('common') .
  288.                 ', ' . $db->quoteName('phrase') .
  289.                 ', ' . $db->quoteName('term_weight') .
  290.                 ', ' . $db->quoteName('context') .
  291.                 ', ' . $db->quoteName('context_weight') .
  292.                 ', ' . $db->quoteName('language') . ')' .
  293.                 ' SELECT' .
  294.                 ' t.term_id, t1.term, t1.stem, t1.common, t1.phrase, t1.weight, t1.context,' .
  295.                 ' ROUND( t1.weight * COUNT( t2.term ) * %F, 8 ) AS context_weight, t1.language' .
  296.                 ' FROM (' .
  297.                 '   SELECT DISTINCT t1.term, t1.stem, t1.common, t1.phrase, t1.weight, t1.context, t1.language' .
  298.                 '   FROM ' . $db->quoteName('#__finder_tokens') . ' AS t1' .
  299.                 '   WHERE t1.context = %d' .
  300.                 ' ) AS t1' .
  301.                 ' JOIN ' . $db->quoteName('#__finder_tokens') . ' AS t2 ON t2.term = t1.term' .
  302.                 ' LEFT JOIN ' . $db->quoteName('#__finder_terms') . ' AS t ON t.term = t1.term' .
  303.                 ' WHERE t2.context = %d' .
  304.                 ' GROUP BY t1.term, t.term_id, t1.term, t1.stem, t1.common, t1.phrase, t1.weight, t1.context, t1.language' .
  305.                 ' ORDER BY t1.term DESC';
  306.  
  307.         // Iterate through the contexts and aggregate the tokens per context.
  308.         foreach ($state->weights as $context => $multiplier)
  309.         {
  310.             // Run the query to aggregate the tokens for this context..
  311.             $db->setQuery(sprintf($query, $multiplier, $context, $context));
  312.             $db->execute();
  313.         }
  314.  
  315.         // Mark afterAggregating in the profiler.
  316.         static::$profiler ? static::$profiler->mark('afterAggregating') : null;
  317.  
  318.         /*
  319.          * When we pulled down all of the aggregate data, we did a LEFT JOIN
  320.          * over the terms table to try to find all the term ids that
  321.          * already exist for our tokens. If any of the rows in the aggregate
  322.          * table have a term of 0, then no term record exists for that
  323.          * term so we need to add it to the terms table.
  324.          */
  325.         /* Emulation of IGNORE INTO behaviour */
  326.         $db->setQuery(
  327.             ' SELECT ta.term' .
  328.             ' FROM ' . $db->quoteName('#__finder_tokens_aggregate') . ' AS ta' .
  329.             ' WHERE ta.term_id = 0'
  330.         );
  331.         if ($db->loadRow() == null)
  332.         {
  333.             $db->setQuery(
  334.                 'INSERT INTO ' . $db->quoteName('#__finder_terms') .
  335.                 ' (' . $db->quoteName('term') .
  336.                 ', ' . $db->quoteName('stem') .
  337.                 ', ' . $db->quoteName('common') .
  338.                 ', ' . $db->quoteName('phrase') .
  339.                 ', ' . $db->quoteName('weight') .
  340.                 ', ' . $db->quoteName('soundex') .
  341.                 ', ' . $db->quoteName('language') . ')' .
  342.                 ' SELECT ta.term, ta.stem, ta.common, ta.phrase, ta.term_weight, SOUNDEX(ta.term), ta.language' .
  343.                 ' FROM ' . $db->quoteName('#__finder_tokens_aggregate') . ' AS ta' .
  344.                 ' WHERE ta.term_id = 0' .
  345.                 ' GROUP BY ta.term, ta.stem, ta.common, ta.phrase, ta.term_weight, SOUNDEX(ta.term), ta.language'
  346.             );
  347.             $db->execute();
  348.         }
  349.  
  350.         /*
  351.          * Now, we just inserted a bunch of new records into the terms table
  352.          * so we need to go back and update the aggregate table with all the
  353.          * new term ids.
  354.          */
  355.         $query = $db->getQuery(true)
  356.             ->update($db->quoteName('#__finder_tokens_aggregate') . ' AS ta')
  357.             ->join('INNER', $db->quoteName('#__finder_terms') . ' AS t ON t.term = ta.term')
  358.             ->set('ta.term_id = t.term_id')
  359.             ->where('ta.term_id = 0');
  360.         $db->setQuery($query);
  361.         $db->execute();
  362.  
  363.         // Mark afterTerms in the profiler.
  364.         static::$profiler ? static::$profiler->mark('afterTerms') : null;
  365.  
  366.         /*
  367.          * After we've made sure that all of the terms are in the terms table
  368.          * and the aggregate table has the correct term ids, we need to update
  369.          * the links counter for each term by one.
  370.          */
  371.         $query->clear()
  372.             ->update($db->quoteName('#__finder_terms') . ' AS t')
  373.             ->join('INNER', $db->quoteName('#__finder_tokens_aggregate') . ' AS ta ON ta.term_id = t.term_id')
  374.             ->set('t.' . $db->quoteName('links') . ' = t.links + 1');
  375.         $db->setQuery($query);
  376.         $db->execute();
  377.  
  378.         // Mark afterTerms in the profiler.
  379.         static::$profiler ? static::$profiler->mark('afterTerms') : null;
  380.  
  381.         /*
  382.          * Before we can insert all of the mapping rows, we have to figure out
  383.          * which mapping table the rows need to be inserted into. The mapping
  384.          * table for each term is based on the first character of the md5 of
  385.          * the first character of the term. In php, it would be expressed as
  386.          * substr(md5(substr($token, 0, 1)), 0, 1)
  387.          */
  388.         $query->clear()
  389.             ->update($db->quoteName('#__finder_tokens_aggregate'))
  390.             ->set($db->quoteName('map_suffix') . ' = SUBSTR(MD5(SUBSTR(' . $db->quoteName('term') . ', 1, 1)), 1, 1)');
  391.         $db->setQuery($query);
  392.         $db->execute();
  393.  
  394.         /*
  395.          * At this point, the aggregate table contains a record for each
  396.          * term in each context. So, we're going to pull down all of that
  397.          * data while grouping the records by term and add all of the
  398.          * sub-totals together to arrive at the final total for each token for
  399.          * this link. Then, we insert all of that data into the appropriate
  400.          * mapping table.
  401.          */
  402.         for ($i = 0; $i <= 15; $i++)
  403.         {
  404.             // Get the mapping table suffix.
  405.             $suffix = dechex($i);
  406.  
  407.             /*
  408.              * We have to run this query 16 times, one for each link => term
  409.              * mapping table.
  410.              */
  411.             $db->setQuery(
  412.                 'INSERT INTO ' . $db->quoteName('#__finder_links_terms' . $suffix) .
  413.                 ' (' . $db->quoteName('link_id') .
  414.                 ', ' . $db->quoteName('term_id') .
  415.                 ', ' . $db->quoteName('weight') . ')' .
  416.                 ' SELECT ' . (int) $linkId . ', ' . $db->quoteName('term_id') . ',' .
  417.                 ' ROUND(SUM(' . $db->quoteName('context_weight') . '), 8)' .
  418.                 ' FROM ' . $db->quoteName('#__finder_tokens_aggregate') .
  419.                 ' WHERE ' . $db->quoteName('map_suffix') . ' = ' . $db->quote($suffix) .
  420.                 ' GROUP BY ' . $db->quoteName('term') .
  421.                 ' ORDER BY ' . $db->quoteName('term') . ' DESC'
  422.             );
  423.             $db->execute();
  424.         }
  425.  
  426.         // Mark afterMapping in the profiler.
  427.         static::$profiler ? static::$profiler->mark('afterMapping') : null;
  428.  
  429.         // Update the signature.
  430.         $query->clear()
  431.             ->update($db->quoteName('#__finder_links'))
  432.             ->set($db->quoteName('md5sum') . ' = ' . $db->quote($curSig))
  433.             ->where($db->quoteName('link_id') . ' = ' . $db->quote($linkId));
  434.         $db->setQuery($query);
  435.         $db->execute();
  436.  
  437.         // Mark afterSigning in the profiler.
  438.         static::$profiler ? static::$profiler->mark('afterSigning') : null;
  439.  
  440.         // Truncate the tokens tables.
  441.         $db->truncateTable('#__finder_tokens');
  442.  
  443.         // Truncate the tokens aggregate table.
  444.         $db->truncateTable('#__finder_tokens_aggregate');
  445.  
  446.         // Toggle the token tables back to memory tables.
  447.         $this->toggleTables(true);
  448.  
  449.         // Mark afterTruncating in the profiler.
  450.         static::$profiler ? static::$profiler->mark('afterTruncating') : null;
  451.  
  452.         return $linkId;
  453.     }
  454.  
  455.     /**
  456.      * Method to remove a link from the index.
  457.      *
  458.      * @param   integer  $linkId  The id of the link.
  459.      *
  460.      * @return  boolean  True on success.
  461.      *
  462.      * @since   2.5
  463.      * @throws  Exception on database error.
  464.      */
  465.     public function remove($linkId)
  466.     {
  467.         $db = JFactory::getDbo();
  468.         $query = $db->getQuery(true);
  469.  
  470.         // Update the link counts and remove the mapping records.
  471.         for ($i = 0; $i <= 15; $i++)
  472.         {
  473.             // Update the link counts for the terms.
  474.             $query->update($db->quoteName('#__finder_terms') . ' AS t')
  475.                 ->join('INNER', $db->quoteName('#__finder_links_terms' . dechex($i)) . ' AS m ON m.term_id = t.term_id')
  476.                 ->set('t.links = t.links - 1')
  477.                 ->where('m.link_id = ' . $db->quote((int) $linkId));
  478.             $db->setQuery($query);
  479.             $db->execute();
  480.  
  481.             // Remove all records from the mapping tables.
  482.             $query->clear()
  483.                 ->delete($db->quoteName('#__finder_links_terms' . dechex($i)))
  484.                 ->where($db->quoteName('link_id') . ' = ' . (int) $linkId);
  485.             $db->setQuery($query);
  486.             $db->execute();
  487.         }
  488.  
  489.         // Delete all orphaned terms.
  490.         $query->clear()
  491.             ->delete($db->quoteName('#__finder_terms'))
  492.             ->where($db->quoteName('links') . ' <= 0');
  493.         $db->setQuery($query);
  494.         $db->execute();
  495.  
  496.         // Delete the link from the index.
  497.         $query->clear()
  498.             ->delete($db->quoteName('#__finder_links'))
  499.             ->where($db->quoteName('link_id') . ' = ' . $db->quote((int) $linkId));
  500.         $db->setQuery($query);
  501.         $db->execute();
  502.  
  503.         // Remove the taxonomy maps.
  504.         FinderIndexerTaxonomy::removeMaps($linkId);
  505.  
  506.         // Remove the orphaned taxonomy nodes.
  507.         FinderIndexerTaxonomy::removeOrphanNodes();
  508.  
  509.         return true;
  510.     }
  511.  
  512.     /**
  513.      * Method to optimize the index. We use this method to remove unused terms
  514.      * and any other optimizations that might be necessary.
  515.      *
  516.      * @return  boolean  True on success.
  517.      *
  518.      * @since   2.5
  519.      * @throws  Exception on database error.
  520.      */
  521.     public function optimize()
  522.     {
  523.         // Get the database object.
  524.         $db = JFactory::getDbo();
  525.         $query = $db->getQuery(true);
  526.  
  527.         // Delete all orphaned terms.
  528.         $query->delete($db->quoteName('#__finder_terms'))
  529.             ->where($db->quoteName('links') . ' <= 0');
  530.         $db->setQuery($query);
  531.         $db->execute();
  532.  
  533.         // Optimize the links table.
  534.         $db->setQuery('VACUUM ' . $db->quoteName('#__finder_links'));
  535.         $db->execute();
  536.         $db->setQuery('REINDEX TABLE ' . $db->quoteName('#__finder_links'));
  537.         $db->execute();
  538.  
  539.         for ($i = 0; $i <= 15; $i++)
  540.         {
  541.             // Optimize the terms mapping table.
  542.             $db->setQuery('VACUUM ' . $db->quoteName('#__finder_links_terms' . dechex($i)));
  543.             $db->execute();
  544.             $db->setQuery('REINDEX TABLE ' . $db->quoteName('#__finder_links_terms' . dechex($i)));
  545.             $db->execute();
  546.         }
  547.  
  548.         // Optimize the terms mapping table.
  549.         $db->setQuery('REINDEX TABLE ' . $db->quoteName('#__finder_links_terms'));
  550.         $db->execute();
  551.  
  552.         // Remove the orphaned taxonomy nodes.
  553.         FinderIndexerTaxonomy::removeOrphanNodes();
  554.  
  555.         // Optimize the taxonomy mapping table.
  556.         $db->setQuery('REINDEX TABLE ' . $db->quoteName('#__finder_taxonomy_map'));
  557.         $db->execute();
  558.  
  559.         return true;
  560.     }
  561.  
  562.     /**
  563.      * Method to add a set of tokens to the database.
  564.      *
  565.      * @param   mixed  $tokens   An array or single FinderIndexerToken object.
  566.      * @param   mixed  $context  The context of the tokens. See context constants. [optional]
  567.      *
  568.      * @return  integer  The number of tokens inserted into the database.
  569.      *
  570.      * @since   2.5
  571.      * @throws  Exception on database error.
  572.      */
  573.     protected function addTokensToDB($tokens, $context = '')
  574.     {
  575.         // Get the database object.
  576.         $db = JFactory::getDbo();
  577.         $query = $db->getQuery(true);
  578.  
  579.         // Force tokens to an array.
  580.         $tokens = is_array($tokens) ? $tokens : array($tokens);
  581.  
  582.         // Count the number of token values.
  583.         $values = 0;
  584.  
  585.         // Insert the tokens into the database.
  586.         $query->insert($db->quoteName('#__finder_tokens'))
  587.             ->columns(
  588.                 array(
  589.                     $db->quoteName('term'),
  590.                     $db->quoteName('stem'),
  591.                     $db->quoteName('common'),
  592.                     $db->quoteName('phrase'),
  593.                     $db->quoteName('weight'),
  594.                     $db->quoteName('context'),
  595.                     $db->quoteName('language')
  596.                 )
  597.             );
  598.  
  599.         // Iterate through the tokens to create SQL value sets.
  600.         foreach ($tokens as $token)
  601.         {
  602.             $query->values(
  603.                 $db->quote($token->term) . ', '
  604.                     . $db->quote($token->stem) . ', '
  605.                     . (int) $token->common . ', '
  606.                     . (int) $token->phrase . ', '
  607.                     . (float) $token->weight . ', '
  608.                     . (int) $context . ', '
  609.                     . $db->quote($token->language)
  610.             );
  611.             $values++;
  612.         }
  613.         $db->setQuery($query);
  614.         $db->execute();
  615.  
  616.         return $values;
  617.     }
  618.  
  619.     /**
  620.      * Method to switch the token tables from Memory tables to MyISAM tables
  621.      * when they are close to running out of memory.
  622.      *
  623.      * @param   boolean  $memory  Flag to control how they should be toggled.
  624.      *
  625.      * @return  boolean  True on success.
  626.      *
  627.      * @since   2.5
  628.      * @throws  Exception on database error.
  629.      */
  630.     protected function toggleTables($memory)
  631.     {
  632.         return true;
  633.     }
  634. }

Documentation generated on Tue, 19 Nov 2013 15:11:05 +0100 by phpDocumentor 1.4.3