X-Git-Url: https://git.mxchange.org/?p=core.git;a=blobdiff_plain;f=inc%2Fclasses%2Fmain%2Fdatabase%2Fclass_BaseDatabaseWrapper.php;h=25b34774a5ecb696d6e10db4b59f5d68368f9429;hp=76d486e2df65d4f7a3e8cf57b1f30eeff024b73c;hb=3f998a2d3aa2c4c16185c556d89cf755125cc699;hpb=be3e5282ba536934ddeac3daff59c5b7e43b1cd2

diff --git a/inc/classes/main/database/class_BaseDatabaseWrapper.php b/inc/classes/main/database/class_BaseDatabaseWrapper.php
index 76d486e2..25b34774 100644
--- a/inc/classes/main/database/class_BaseDatabaseWrapper.php
+++ b/inc/classes/main/database/class_BaseDatabaseWrapper.php
@@ -55,25 +55,92 @@ class BaseDatabaseWrapper extends BaseFrameworkSystem {
 		$this->cacheInstance = CacheFactory::getFactory()->createConfiguredCache();
 	}
 
+	/**
+	 * Setter for table name
+	 *
+	 * @param	$tableName	Name of table name to set
+	 * @return	void
+	 */
+	protected final function setTableName ($tableName) {
+		$this->tableName = (string) $tableName;
+	}
+
+	/**
+	 * Getter for table name
+	 *
+	 * @return	$tableName	Name of table name to set
+	 */
+	protected final function getTableName () {
+		return $this->tableName;
+	}
+
+	/**
+	 * 'Inserts' a data set instance into a local file database folder
+	 *
+	 * @param	$dataSetInstance	A storeable data set
+	 * @param	$onlyKeys			Only use these keys for a cache key
+	 * @return	void
+	 */
+	protected function queryInsertDataSet (StoreableCriteria $dataSetInstance, $onlyKeys = array()) {
+		// First get a key suitable for our cache and extend it with this class name
+		$cacheKey = $this->getCacheKeyByCriteria($dataSetInstance, $onlyKeys);
+		//* DEBUG: */ $this->debugOutput('BASE-WRAPPER: Using cache key ' . $cacheKey . ' for purging ...');
+
+		// Does this key exists in cache?
+		if ($this->cacheInstance->offsetExists($cacheKey)) {
+			// Purge the cache
+			$this->cacheInstance->purgeOffset($cacheKey);
+		} // END - if
+
+		// Handle it over to the middleware
+		$this->getDatabaseInstance()->queryInsertDataSet($dataSetInstance);
+	}
+
+	/**
+	 * 'Updates' a data set instance with a database layer
+	 *
+	 * @param	$dataSetInstance	A storeable data set
+	 * @param	$onlyKeys			Only use these keys for a cache key
+	 * @return	void
+	 */
+	protected function queryUpdateDataSet (StoreableCriteria $dataSetInstance, $onlyKeys = array()) {
+		// First get a key suitable for our cache and extend it with this class name
+		$cacheKey = $this->getCacheKeyByCriteria($dataSetInstance, $onlyKeys);
+		//* DEBUG: */ $this->debugOutput('BASE-WRAPPER: Using cache key ' . $cacheKey . ' for purging ...');
+
+		// Does this key exists in cache?
+		if ($this->cacheInstance->offsetExists($cacheKey)) {
+			// Purge the cache
+			$this->cacheInstance->purgeOffset($cacheKey);
+		} // END - if
+
+		// Handle it over to the middleware
+		$this->getDatabaseInstance()->queryUpdateDataSet($dataSetInstance);
+	}
+
 	/**
 	 * Do a "select" query on the current table with the given search criteria and
 	 * store it in cache for later usage
 	 *
 	 * @param	$criteriaInstance	An instance of a Criteria class
+	 * @param	$onlyKeys			Only use these keys for a cache key
 	 * @return	$resultInstance		An instance of a database result class
 	 */
-	public function doSelectByCriteria (Criteria $criteriaInstance) {
+	public function doSelectByCriteria (Criteria $criteriaInstance, $onlyKeys = array()) {
 		// First get a key suitable for our cache and extend it with this class name
-		$cacheKey = sprintf("%s@%s",
-			$this->__toString(),
-			$criteriaInstance->getCacheKey()
-		);
+		$cacheKey = $this->getCacheKeyByCriteria($criteriaInstance, $onlyKeys);
 
 		// Does this key exists in cache?
 		if ($this->cacheInstance->offsetExists($cacheKey)) {
+			// Debug message
+			//* DEBUG: */ $this->debugOutput('BASE-WRAPPER: Cache used for cacheKey=' . $cacheKey);
+
 			// Then use this result
 			$result = $this->cacheInstance->offsetGet($cacheKey);
 		} else {
+			// Debug message
+			//* DEBUG: */ $this->debugOutput('BASE-WRAPPER: Quering database, cacheKey=' . $cacheKey);
+
 			// Now it's time to ask the database layer for this select statement
 			$result = $this->getDatabaseInstance()->doSelectByTableCriteria($this->getTableName(), $criteriaInstance);
 
@@ -84,8 +151,8 @@ class BaseDatabaseWrapper extends BaseFrameworkSystem {
 			} else {
 				// This invalid result must be wrapped
 				$result = array(
-					'status'		=> 'invalid',
-					'exception'		=> $this->getDatabaseInstance()->getLastException()
+					BaseDatabaseFrontend::RESULT_INDEX_STATUS    => 'invalid',
+					BaseDatabaseFrontend::RESULT_INDEX_EXCEPTION => $this->getDatabaseInstance()->getLastException()
 				);
 			}
 		}
@@ -101,44 +168,29 @@ class BaseDatabaseWrapper extends BaseFrameworkSystem {
 	 * Count the numbers of rows we shall receive
 	 *
 	 * @param	$criteriaInstance	An instance of a Criteria class
+	 * @param	$onlyKeys			Only use these keys for a cache key
 	 * @return	$numRows			Numbers of rows of database entries
 	 */
-	public function doSelectCountByCriteria (Criteria $criteriaInstance) {
+	public function doSelectCountByCriteria (Criteria $criteriaInstance, $onlyKeys =  array()) {
 		// Total numbers is -1 so we can distinglish between failed and valid queries
 		$numRows = 0;
 
 		// Get the result from above method
-		$resultInstance = $this->doSelectByCriteria($criteriaInstance);
+		$resultInstance = $this->doSelectByCriteria($criteriaInstance, $onlyKeys);
 
 		// Was that query fine?
 		if ($resultInstance->ifStatusIsOkay()) {
 			// Then get the number of rows
 			$numRows = $resultInstance->getAffectedRows();
+
+			// Debug message
+			//* DEBUG: */ $this->debugOutput('BASE-WRAPPER: numRows=' . $numRows);
 		} // END - if
 
 		// Return the result
 		return $numRows;
 	}
 
-	/**
-	 * Setter for table name
-	 *
-	 * @param	$tableName	Name of table name to set
-	 * @return	void
-	 */
-	protected final function setTableName ($tableName) {
-		$this->tableName = (string) $tableName;
-	}
-
-	/**
-	 * Getter for table name
-	 *
-	 * @return	$tableName	Name of table name to set
-	 */
-	protected final function getTableName () {
-		return $this->tableName;
-	}
-
 	/**
 	 * Getter for primary key used in wrapped table
 	 *