CacheProvider.php 7.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277
  1. <?php
  2. /*
  3. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  4. * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  5. * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  6. * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  7. * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  8. * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  9. * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  10. * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  11. * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  12. * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  13. * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  14. *
  15. * This software consists of voluntary contributions made by many individuals
  16. * and is licensed under the MIT license. For more information, see
  17. * <http://www.doctrine-project.org>.
  18. */
  19. namespace Doctrine\Common\Cache;
  20. /**
  21. * Base class for cache provider implementations.
  22. *
  23. * @since 2.2
  24. * @author Benjamin Eberlei <kontakt@beberlei.de>
  25. * @author Guilherme Blanco <guilhermeblanco@hotmail.com>
  26. * @author Jonathan Wage <jonwage@gmail.com>
  27. * @author Roman Borschel <roman@code-factory.org>
  28. * @author Fabio B. Silva <fabio.bat.silva@gmail.com>
  29. */
  30. abstract class CacheProvider implements Cache, FlushableCache, ClearableCache, MultiGetCache
  31. {
  32. const DOCTRINE_NAMESPACE_CACHEKEY = 'DoctrineNamespaceCacheKey[%s]';
  33. /**
  34. * The namespace to prefix all cache ids with.
  35. *
  36. * @var string
  37. */
  38. private $namespace = '';
  39. /**
  40. * The namespace version.
  41. *
  42. * @var integer|null
  43. */
  44. private $namespaceVersion;
  45. /**
  46. * Sets the namespace to prefix all cache ids with.
  47. *
  48. * @param string $namespace
  49. *
  50. * @return void
  51. */
  52. public function setNamespace($namespace)
  53. {
  54. $this->namespace = (string) $namespace;
  55. $this->namespaceVersion = null;
  56. }
  57. /**
  58. * Retrieves the namespace that prefixes all cache ids.
  59. *
  60. * @return string
  61. */
  62. public function getNamespace()
  63. {
  64. return $this->namespace;
  65. }
  66. /**
  67. * {@inheritdoc}
  68. */
  69. public function fetch($id)
  70. {
  71. return $this->doFetch($this->getNamespacedId($id));
  72. }
  73. /**
  74. * {@inheritdoc}
  75. */
  76. public function fetchMultiple(array $keys)
  77. {
  78. if (empty($keys)) {
  79. return array();
  80. }
  81. // note: the array_combine() is in place to keep an association between our $keys and the $namespacedKeys
  82. $namespacedKeys = array_combine($keys, array_map(array($this, 'getNamespacedId'), $keys));
  83. $items = $this->doFetchMultiple($namespacedKeys);
  84. $foundItems = array();
  85. // no internal array function supports this sort of mapping: needs to be iterative
  86. // this filters and combines keys in one pass
  87. foreach ($namespacedKeys as $requestedKey => $namespacedKey) {
  88. if (isset($items[$namespacedKey]) || array_key_exists($namespacedKey, $items)) {
  89. $foundItems[$requestedKey] = $items[$namespacedKey];
  90. }
  91. }
  92. return $foundItems;
  93. }
  94. /**
  95. * {@inheritdoc}
  96. */
  97. public function contains($id)
  98. {
  99. return $this->doContains($this->getNamespacedId($id));
  100. }
  101. /**
  102. * {@inheritdoc}
  103. */
  104. public function save($id, $data, $lifeTime = 0)
  105. {
  106. return $this->doSave($this->getNamespacedId($id), $data, $lifeTime);
  107. }
  108. /**
  109. * {@inheritdoc}
  110. */
  111. public function delete($id)
  112. {
  113. return $this->doDelete($this->getNamespacedId($id));
  114. }
  115. /**
  116. * {@inheritdoc}
  117. */
  118. public function getStats()
  119. {
  120. return $this->doGetStats();
  121. }
  122. /**
  123. * {@inheritDoc}
  124. */
  125. public function flushAll()
  126. {
  127. return $this->doFlush();
  128. }
  129. /**
  130. * {@inheritDoc}
  131. */
  132. public function deleteAll()
  133. {
  134. $namespaceCacheKey = $this->getNamespaceCacheKey();
  135. $namespaceVersion = $this->getNamespaceVersion() + 1;
  136. if ($this->doSave($namespaceCacheKey, $namespaceVersion)) {
  137. $this->namespaceVersion = $namespaceVersion;
  138. return true;
  139. }
  140. return false;
  141. }
  142. /**
  143. * Prefixes the passed id with the configured namespace value.
  144. *
  145. * @param string $id The id to namespace.
  146. *
  147. * @return string The namespaced id.
  148. */
  149. private function getNamespacedId($id)
  150. {
  151. $namespaceVersion = $this->getNamespaceVersion();
  152. return sprintf('%s[%s][%s]', $this->namespace, $id, $namespaceVersion);
  153. }
  154. /**
  155. * Returns the namespace cache key.
  156. *
  157. * @return string
  158. */
  159. private function getNamespaceCacheKey()
  160. {
  161. return sprintf(self::DOCTRINE_NAMESPACE_CACHEKEY, $this->namespace);
  162. }
  163. /**
  164. * Returns the namespace version.
  165. *
  166. * @return integer
  167. */
  168. private function getNamespaceVersion()
  169. {
  170. if (null !== $this->namespaceVersion) {
  171. return $this->namespaceVersion;
  172. }
  173. $namespaceCacheKey = $this->getNamespaceCacheKey();
  174. $this->namespaceVersion = $this->doFetch($namespaceCacheKey) ?: 1;
  175. return $this->namespaceVersion;
  176. }
  177. /**
  178. * Default implementation of doFetchMultiple. Each driver that supports multi-get should owerwrite it.
  179. *
  180. * @param array $keys Array of keys to retrieve from cache
  181. * @return array Array of values retrieved for the given keys.
  182. */
  183. protected function doFetchMultiple(array $keys)
  184. {
  185. $returnValues = array();
  186. foreach ($keys as $index => $key) {
  187. if (false !== ($item = $this->doFetch($key))) {
  188. $returnValues[$key] = $item;
  189. }
  190. }
  191. return $returnValues;
  192. }
  193. /**
  194. * Fetches an entry from the cache.
  195. *
  196. * @param string $id The id of the cache entry to fetch.
  197. *
  198. * @return mixed|boolean The cached data or FALSE, if no cache entry exists for the given id.
  199. */
  200. abstract protected function doFetch($id);
  201. /**
  202. * Tests if an entry exists in the cache.
  203. *
  204. * @param string $id The cache id of the entry to check for.
  205. *
  206. * @return boolean TRUE if a cache entry exists for the given cache id, FALSE otherwise.
  207. */
  208. abstract protected function doContains($id);
  209. /**
  210. * Puts data into the cache.
  211. *
  212. * @param string $id The cache id.
  213. * @param string $data The cache entry/data.
  214. * @param int $lifeTime The lifetime. If != 0, sets a specific lifetime for this
  215. * cache entry (0 => infinite lifeTime).
  216. *
  217. * @return boolean TRUE if the entry was successfully stored in the cache, FALSE otherwise.
  218. */
  219. abstract protected function doSave($id, $data, $lifeTime = 0);
  220. /**
  221. * Deletes a cache entry.
  222. *
  223. * @param string $id The cache id.
  224. *
  225. * @return boolean TRUE if the cache entry was successfully deleted, FALSE otherwise.
  226. */
  227. abstract protected function doDelete($id);
  228. /**
  229. * Flushes all cache entries.
  230. *
  231. * @return boolean TRUE if the cache entries were successfully flushed, FALSE otherwise.
  232. */
  233. abstract protected function doFlush();
  234. /**
  235. * Retrieves cached information from the data store.
  236. *
  237. * @since 2.2
  238. *
  239. * @return array|null An associative array with server's statistics if available, NULL otherwise.
  240. */
  241. abstract protected function doGetStats();
  242. }