ChainCache.php 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187
  1. <?php
  2. namespace Doctrine\Common\Cache;
  3. use Traversable;
  4. use function array_values;
  5. use function count;
  6. use function iterator_to_array;
  7. /**
  8. * Cache provider that allows to easily chain multiple cache providers
  9. */
  10. class ChainCache extends CacheProvider
  11. {
  12. /** @var CacheProvider[] */
  13. private $cacheProviders = [];
  14. /**
  15. * @param CacheProvider[] $cacheProviders
  16. */
  17. public function __construct($cacheProviders = [])
  18. {
  19. $this->cacheProviders = $cacheProviders instanceof Traversable
  20. ? iterator_to_array($cacheProviders, false)
  21. : array_values($cacheProviders);
  22. }
  23. /**
  24. * {@inheritDoc}
  25. */
  26. public function setNamespace($namespace)
  27. {
  28. parent::setNamespace($namespace);
  29. foreach ($this->cacheProviders as $cacheProvider) {
  30. $cacheProvider->setNamespace($namespace);
  31. }
  32. }
  33. /**
  34. * {@inheritDoc}
  35. */
  36. protected function doFetch($id)
  37. {
  38. foreach ($this->cacheProviders as $key => $cacheProvider) {
  39. if ($cacheProvider->doContains($id)) {
  40. $value = $cacheProvider->doFetch($id);
  41. // We populate all the previous cache layers (that are assumed to be faster)
  42. for ($subKey = $key - 1; $subKey >= 0; $subKey--) {
  43. $this->cacheProviders[$subKey]->doSave($id, $value);
  44. }
  45. return $value;
  46. }
  47. }
  48. return false;
  49. }
  50. /**
  51. * {@inheritdoc}
  52. */
  53. protected function doFetchMultiple(array $keys)
  54. {
  55. /** @var CacheProvider[] $traversedProviders */
  56. $traversedProviders = [];
  57. $keysCount = count($keys);
  58. $fetchedValues = [];
  59. foreach ($this->cacheProviders as $key => $cacheProvider) {
  60. $fetchedValues = $cacheProvider->doFetchMultiple($keys);
  61. // We populate all the previous cache layers (that are assumed to be faster)
  62. if (count($fetchedValues) === $keysCount) {
  63. foreach ($traversedProviders as $previousCacheProvider) {
  64. $previousCacheProvider->doSaveMultiple($fetchedValues);
  65. }
  66. return $fetchedValues;
  67. }
  68. $traversedProviders[] = $cacheProvider;
  69. }
  70. return $fetchedValues;
  71. }
  72. /**
  73. * {@inheritDoc}
  74. */
  75. protected function doContains($id)
  76. {
  77. foreach ($this->cacheProviders as $cacheProvider) {
  78. if ($cacheProvider->doContains($id)) {
  79. return true;
  80. }
  81. }
  82. return false;
  83. }
  84. /**
  85. * {@inheritDoc}
  86. */
  87. protected function doSave($id, $data, $lifeTime = 0)
  88. {
  89. $stored = true;
  90. foreach ($this->cacheProviders as $cacheProvider) {
  91. $stored = $cacheProvider->doSave($id, $data, $lifeTime) && $stored;
  92. }
  93. return $stored;
  94. }
  95. /**
  96. * {@inheritdoc}
  97. */
  98. protected function doSaveMultiple(array $keysAndValues, $lifetime = 0)
  99. {
  100. $stored = true;
  101. foreach ($this->cacheProviders as $cacheProvider) {
  102. $stored = $cacheProvider->doSaveMultiple($keysAndValues, $lifetime) && $stored;
  103. }
  104. return $stored;
  105. }
  106. /**
  107. * {@inheritDoc}
  108. */
  109. protected function doDelete($id)
  110. {
  111. $deleted = true;
  112. foreach ($this->cacheProviders as $cacheProvider) {
  113. $deleted = $cacheProvider->doDelete($id) && $deleted;
  114. }
  115. return $deleted;
  116. }
  117. /**
  118. * {@inheritdoc}
  119. */
  120. protected function doDeleteMultiple(array $keys)
  121. {
  122. $deleted = true;
  123. foreach ($this->cacheProviders as $cacheProvider) {
  124. $deleted = $cacheProvider->doDeleteMultiple($keys) && $deleted;
  125. }
  126. return $deleted;
  127. }
  128. /**
  129. * {@inheritDoc}
  130. */
  131. protected function doFlush()
  132. {
  133. $flushed = true;
  134. foreach ($this->cacheProviders as $cacheProvider) {
  135. $flushed = $cacheProvider->doFlush() && $flushed;
  136. }
  137. return $flushed;
  138. }
  139. /**
  140. * {@inheritDoc}
  141. */
  142. protected function doGetStats()
  143. {
  144. // We return all the stats from all adapters
  145. $stats = [];
  146. foreach ($this->cacheProviders as $cacheProvider) {
  147. $stats[] = $cacheProvider->doGetStats();
  148. }
  149. return $stats;
  150. }
  151. }