Source for file Offsetter.php

Documentation is available at Offsetter.php

  1. <?php
  2. require_once RDFAPI_INCLUDE_DIR . 'sparql/SparqlEngineDb/SqlMerger.php';
  3.  
  4. /**
  5. *   Determines the offset in a row of sql queries.
  6. *
  7. *   @author Christian Weiske <cweiske@cweiske.de>
  8. *
  9. *   @package sparql
  10. */
  11. class SparqlEngineDb_Offsetter
  12. {
  13.     public function __construct(ADOConnection $dbConn, Query $query)
  14.     {
  15.         $this->dbConn   = $dbConn;
  16.         $this->query    = $query;
  17.     }//public function __construct(ADOConnection $dbConn, Query $query)
  18.  
  19.  
  20.  
  21.     /**
  22.     *   Determines the offset in the sqls, the position to start form.
  23.     *
  24.     *   @param array $arSqls    Array of SQL query parts as returned by
  25.     *                            SparqlEngine_TypeSorter::getOrderifiedSqls()
  26.     *   @return array   Array of two values: The first determines the
  27.     *                    index of the sql query to begin with, the second
  28.     *                    is the row offset that should be used in the final
  29.     *                    SQL query.
  30.     */
  31.     public function determineOffset($arSqls)
  32.     {
  33.         $arSM = $this->query->getSolutionModifier();
  34.         if ($arSM['offset'] === null) {
  35.             return array(0, 0);
  36.         }
  37.  
  38.         $nCount = 0;
  39.         foreach ($arSqls as $nId => $arSql) {
  40.             $nCurrentCount = $this->getCount($arSql);
  41.             if ($nCurrentCount + $nCount > $arSM['offset']) {
  42.                 return array($nId, $arSM['offset'] - $nCount);
  43.             }
  44.             $nCount += $nCurrentCount;
  45.         }
  46.         //nothing found - no results for this offset
  47.         return array(count($arSqls), 0);
  48.     }//public function determineOffset($arSql)
  49.  
  50.  
  51.  
  52.     /**
  53.     *   Returns the number of rows that the given query will return.
  54.     *
  55.     *   @param array $arSql Array with sql parts and at least keys
  56.     *                 'from' and 'where' set.
  57.     *   @return int     Number of rows returned.
  58.     */
  59.     protected function getCount($arSql)
  60.     {
  61.         $sql = SparqlEngineDb_SqlMerger::getCount($this->query, $arSql);
  62.         $dbResult = $this->dbConn->execute($sql);
  63.  
  64.         $nCount = 0;
  65.         foreach ($dbResult as $row) {
  66.             $nCount = intval($row[0]);
  67.             break;
  68.         }
  69.         return $nCount;
  70.     }//protected function getCount($arSql)
  71.  
  72.  
  73.  
  74.     /**
  75.     *   Creates a sql LIMIT statement if the sparql query needs one.
  76.     *   This method is needed because AdoDb does not support limits with
  77.     *   prepared statements. It's a pity.
  78.     *
  79.     *   @return string  SQL command to be appended to a query, to limit
  80.     *                    the number of result rows returned.
  81.     */
  82.     public static function getLimitSql(Query $query, ADOConnection $dbConn)
  83.     {
  84.         $arSM = $query->getSolutionModifier();
  85.         if ($arSM['limit'] === null && $arSM['offset'] === null) {
  86.             return '';
  87.         }
  88.         //this here is mysql syntax. if anyone has problems, write it
  89.         //dependent on $dbConn's type
  90.         if ($arSM['offset'] === null) {
  91.             return ' LIMIT ' . $arSM['limit'];
  92.         } else if ($arSM['limit'] === null) {
  93.             return ' LIMIT ' . $arSM['offset'] . ', 18446744073709551615';
  94.         } else {
  95.             return ' LIMIT ' . $arSM['offset'] . ', ' . $arSM['limit'];
  96.         }
  97.     }//public static function getLimitSql(Query $query, ADOConnection $dbConn)
  98.  
  99. }//class SparqlEngineDb_Offsetter
  100.  
  101. ?>

Documentation generated on Fri, 1 Jun 2007 16:50:05 +0200 by phpDocumentor 1.3.2