inc/classes/main/database/class_BaseDatabaseWrapper.php

   1 <?php
   2 /**
   3  * A generic database wrapper
   4  *
   5  * @author              Roland Haeder <webmaster@ship-simu.org>
   6  * @version             0.0.0
   7  * @copyright   Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2012 Core Developer Team
   8  * @license             GNU GPL 3.0 or any newer version
   9  * @link                http://www.ship-simu.org
  10  *
  11  * This program is free software: you can redistribute it and/or modify
  12  * it under the terms of the GNU General Public License as published by
  13  * the Free Software Foundation, either version 3 of the License, or
  14  * (at your option) any later version.
  15  *
  16  * This program is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19  * GNU General Public License for more details.
  20  *
  21  * You should have received a copy of the GNU General Public License
  22  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  23  */
  24 class BaseDatabaseWrapper extends BaseFrameworkSystem {
  25         /**
  26          * Cache instance
  27          */
  28         private $cacheInstance = NULL;
  29
  30         /**
  31          * Current table name to use
  32          */
  33         private $tableName = 'unknown';
  34
  35         /**
  36          * Protected constructor
  37          *
  38          * @return      void
  39          */
  40         protected function __construct ($class) {
  41                 // Call parent constructor
  42                 parent::__construct($class);
  43
  44                 // Initialize the cache instance
  45                 $this->initCacheInstance();
  46         }
  47
  48         /**
  49          * Initializes the cache instance with a new object
  50          *
  51          * @return      void
  52          */
  53         private final function initCacheInstance () {
  54                 // Set the new instance
  55                 $this->cacheInstance = CacheFactory::getFactory()->createConfiguredCache();
  56         }
  57
  58         /**
  59          * Setter for table name
  60          *
  61          * @param       $tableName      Name of table name to set
  62          * @return      void
  63          */
  64         protected final function setTableName ($tableName) {
  65                 $this->tableName = (string) $tableName;
  66         }
  67
  68         /**
  69          * Getter for table name
  70          *
  71          * @return      $tableName      Name of table name to set
  72          */
  73         protected final function getTableName () {
  74                 return $this->tableName;
  75         }
  76
  77         /**
  78          * 'Inserts' a data set instance into a local file database folder
  79          *
  80          * @param       $dataSetInstance        A storeable data set
  81          * @param       $onlyKeys                       Only use these keys for a cache key
  82          * @return      void
  83          */
  84         protected function queryInsertDataSet (StoreableCriteria $dataSetInstance, array $onlyKeys = array()) {
  85                 // First get a key suitable for our cache and extend it with this class name
  86                 $cacheKey = $this->getCacheKeyByCriteria($dataSetInstance, $onlyKeys);
  87                 //* DEBUG: */ $this->debugOutput('BASE-WRAPPER: Using cache key ' . $cacheKey . ' for purging ...');
  88
  89                 // Does this key exists in cache?
  90                 if ($this->cacheInstance->offsetExists($cacheKey)) {
  91                         // Purge the cache
  92                         $this->cacheInstance->purgeOffset($cacheKey);
  93                 } // END - if
  94
  95                 // Handle it over to the middleware
  96                 $this->getDatabaseInstance()->queryInsertDataSet($dataSetInstance);
  97         }
  98
  99         /**
 100          * 'Updates' a data set instance with a database layer
 101          *
 102          * @param       $dataSetInstance        A storeable data set
 103          * @param       $onlyKeys                       Only use these keys for a cache key
 104          * @return      void
 105          */
 106         protected function queryUpdateDataSet (StoreableCriteria $dataSetInstance, array $onlyKeys = array()) {
 107                 // First get a key suitable for our cache and extend it with this class name
 108                 $cacheKey = $this->getCacheKeyByCriteria($dataSetInstance, $onlyKeys);
 109                 //* DEBUG: */ $this->debugOutput('BASE-WRAPPER: Using cache key ' . $cacheKey . ' for purging ...');
 110
 111                 // Does this key exists in cache?
 112                 if ($this->cacheInstance->offsetExists($cacheKey)) {
 113                         // Purge the cache
 114                         $this->cacheInstance->purgeOffset($cacheKey);
 115                 } // END - if
 116
 117                 // Handle it over to the middleware
 118                 $this->getDatabaseInstance()->queryUpdateDataSet($dataSetInstance);
 119         }
 120
 121         /**
 122          * Getter for index key
 123          *
 124          * @return      $indexKey       Index key
 125          */
 126         public final function getIndexKey () {
 127                 return $this->getDatabaseInstance()->getIndexKey();
 128         }
 129
 130         /**
 131          * Do a "select" query on the current table with the given search criteria and
 132          * store it in cache for later usage
 133          *
 134          * @param       $criteriaInstance       An instance of a Criteria class
 135          * @param       $onlyKeys                       Only use these keys for a cache key
 136          * @return      $resultInstance         An instance of a database result class
 137          */
 138         public function doSelectByCriteria (Criteria $criteriaInstance, array $onlyKeys = array()) {
 139                 // First get a key suitable for our cache and extend it with this class name
 140                 $cacheKey = $this->getCacheKeyByCriteria($criteriaInstance, $onlyKeys);
 141
 142                 // Does this key exists in cache?
 143                 if ($this->cacheInstance->offsetExists($cacheKey)) {
 144                         // Debug message
 145                         //* DEBUG: */ $this->debugOutput('BASE-WRAPPER: Cache used for cacheKey=' . $cacheKey);
 146
 147                         // Then use this result
 148                         $result = $this->cacheInstance->offsetGet($cacheKey);
 149                 } else {
 150                         // Debug message
 151                         //* DEBUG: */ $this->debugOutput('BASE-WRAPPER: Quering database, cacheKey=' . $cacheKey);
 152
 153                         // Now it's time to ask the database layer for this select statement
 154                         $result = $this->getDatabaseInstance()->doSelectByTableCriteria($this->getTableName(), $criteriaInstance);
 155
 156                         // Cache the result if not null
 157                         if (!is_null($result)) {
 158                                 // A valid result has returned from the database layer
 159                                 $this->cacheInstance->offsetSet($cacheKey, $result);
 160                         } else {
 161                                 // This invalid result must be wrapped
 162                                 $result = array(
 163                                         BaseDatabaseFrontend::RESULT_INDEX_STATUS    => 'invalid',
 164                                         BaseDatabaseFrontend::RESULT_INDEX_EXCEPTION => $this->getDatabaseInstance()->getLastException()
 165                                 );
 166                         }
 167                 }
 168
 169                 // Create an instance of a DatabaseResult class with the given result
 170                 $resultInstance = DatabaseResult::createDatabaseResult($result);
 171
 172                 // And return the instance
 173                 return $resultInstance;
 174         }
 175
 176         /**
 177          * Count the numbers of rows we shall receive
 178          *
 179          * @param       $criteriaInstance       An instance of a Criteria class
 180          * @param       $onlyKeys                       Only use these keys for a cache key
 181          * @return      $numRows                        Numbers of rows of database entries
 182          */
 183         public function doSelectCountByCriteria (Criteria $criteriaInstance, $onlyKeys =  array()) {
 184                 // Total numbers is -1 so we can distinglish between failed and valid queries
 185                 $numRows = 0;
 186
 187                 // Get the result from above method
 188                 $resultInstance = $this->doSelectByCriteria($criteriaInstance, $onlyKeys);
 189
 190                 // Was that query fine?
 191                 if ($resultInstance->ifStatusIsOkay()) {
 192                         // Then get the number of rows
 193                         $numRows = $resultInstance->getAffectedRows();
 194
 195                         // Debug message
 196                         //* DEBUG: */ $this->debugOutput('BASE-WRAPPER: numRows=' . $numRows);
 197                 } // END - if
 198
 199                 // Return the result
 200                 return $numRows;
 201         }
 202
 203         /**
 204          * Getter for primary key used in wrapped table
 205          *
 206          * @return      $primaryKey             Primary key used in wrapped table
 207          */
 208         public final function getPrimaryKeyValue () {
 209                 // Get the table name and a database instance and ask for it
 210                 $primaryKey = $this->getDatabaseInstance()->getPrimaryKeyOfTable($this->getTableName());
 211
 212                 // Return value
 213                 return $primaryKey;
 214         }
 215 }
 216
 217 // [EOF]
 218 ?>