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. // note: the array_combine() is in place to keep an association between our $keys and the $namespacedKeys
  79. $namespacedKeys = array_combine($keys, array_map(array($this, 'getNamespacedId'), $keys));
  80. $items = $this->doFetchMultiple($namespacedKeys);
  81. $foundItems = array();
  82. // no internal array function supports this sort of mapping: needs to be iterative
  83. // this filters and combines keys in one pass
  84. foreach ($namespacedKeys as $requestedKey => $namespacedKey) {
  85. if (isset($items[$namespacedKey])) {
  86. $foundItems[$requestedKey] = $items[$namespacedKey];
  87. }
  88. }
  89. return $foundItems;
  90. }
  91. /**
  92. * {@inheritdoc}
  93. */
  94. public function contains($id)
  95. {
  96. return $this->doContains($this->getNamespacedId($id));
  97. }
  98. /**
  99. * {@inheritdoc}
  100. */
  101. public function save($id, $data, $lifeTime = 0)
  102. {
  103. return $this->doSave($this->getNamespacedId($id), $data, $lifeTime);
  104. }
  105. /**
  106. * {@inheritdoc}
  107. */
  108. public function delete($id)
  109. {
  110. return $this->doDelete($this->getNamespacedId($id));
  111. }
  112. /**
  113. * {@inheritdoc}
  114. */
  115. public function getStats()
  116. {
  117. return $this->doGetStats();
  118. }
  119. /**
  120. * {@inheritDoc}
  121. */
  122. public function flushAll()
  123. {
  124. return $this->doFlush();
  125. }
  126. /**
  127. * {@inheritDoc}
  128. */
  129. public function deleteAll()
  130. {
  131. $namespaceCacheKey = $this->getNamespaceCacheKey();
  132. $namespaceVersion = $this->getNamespaceVersion() + 1;
  133. $this->namespaceVersion = $namespaceVersion;
  134. return $this->doSave($namespaceCacheKey, $namespaceVersion);
  135. }
  136. /**
  137. * Prefixes the passed id with the configured namespace value.
  138. *
  139. * @param string $id The id to namespace.
  140. *
  141. * @return string The namespaced id.
  142. */
  143. private function getNamespacedId($id)
  144. {
  145. $namespaceVersion = $this->getNamespaceVersion();
  146. return sprintf('%s[%s][%s]', $this->namespace, $id, $namespaceVersion);
  147. }
  148. /**
  149. * Returns the namespace cache key.
  150. *
  151. * @return string
  152. */
  153. private function getNamespaceCacheKey()
  154. {
  155. return sprintf(self::DOCTRINE_NAMESPACE_CACHEKEY, $this->namespace);
  156. }
  157. /**
  158. * Returns the namespace version.
  159. *
  160. * @return integer
  161. */
  162. private function getNamespaceVersion()
  163. {
  164. if (null !== $this->namespaceVersion) {
  165. return $this->namespaceVersion;
  166. }
  167. $namespaceCacheKey = $this->getNamespaceCacheKey();
  168. $namespaceVersion = $this->doFetch($namespaceCacheKey);
  169. if (false === $namespaceVersion) {
  170. $namespaceVersion = 1;
  171. $this->doSave($namespaceCacheKey, $namespaceVersion);
  172. }
  173. $this->namespaceVersion = $namespaceVersion;
  174. return $this->namespaceVersion;
  175. }
  176. /**
  177. * Default implementation of doFetchMultiple. Each driver that supports multi-get should owerwrite it.
  178. *
  179. * @param array $keys Array of keys to retrieve from cache
  180. * @return array Array of values retrieved for the given keys.
  181. */
  182. protected function doFetchMultiple(array $keys)
  183. {
  184. $returnValues = array();
  185. foreach ($keys as $index => $key) {
  186. if (false !== ($item = $this->doFetch($key))) {
  187. $returnValues[$key] = $item;
  188. }
  189. }
  190. return $returnValues;
  191. }
  192. /**
  193. * Fetches an entry from the cache.
  194. *
  195. * @param string $id The id of the cache entry to fetch.
  196. *
  197. * @return mixed|boolean The cached data or FALSE, if no cache entry exists for the given id.
  198. */
  199. abstract protected function doFetch($id);
  200. /**
  201. * Tests if an entry exists in the cache.
  202. *
  203. * @param string $id The cache id of the entry to check for.
  204. *
  205. * @return boolean TRUE if a cache entry exists for the given cache id, FALSE otherwise.
  206. */
  207. abstract protected function doContains($id);
  208. /**
  209. * Puts data into the cache.
  210. *
  211. * @param string $id The cache id.
  212. * @param string $data The cache entry/data.
  213. * @param int $lifeTime The lifetime. If != 0, sets a specific lifetime for this
  214. * cache entry (0 => infinite lifeTime).
  215. *
  216. * @return boolean TRUE if the entry was successfully stored in the cache, FALSE otherwise.
  217. */
  218. abstract protected function doSave($id, $data, $lifeTime = 0);
  219. /**
  220. * Deletes a cache entry.
  221. *
  222. * @param string $id The cache id.
  223. *
  224. * @return boolean TRUE if the cache entry was successfully deleted, FALSE otherwise.
  225. */
  226. abstract protected function doDelete($id);
  227. /**
  228. * Flushes all cache entries.
  229. *
  230. * @return boolean TRUE if the cache entries were successfully flushed, FALSE otherwise.
  231. */
  232. abstract protected function doFlush();
  233. /**
  234. * Retrieves cached information from the data store.
  235. *
  236. * @since 2.2
  237. *
  238. * @return array|null An associative array with server's statistics if available, NULL otherwise.
  239. */
  240. abstract protected function doGetStats();
  241. }