DiffManager.php 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\Framework\Setup\Declaration\Schema\Diff;
  7. use Magento\Framework\Setup\Declaration\Schema\Comparator;
  8. use Magento\Framework\Setup\Declaration\Schema\Dto\Column;
  9. use Magento\Framework\Setup\Declaration\Schema\Dto\Constraints\Reference;
  10. use Magento\Framework\Setup\Declaration\Schema\Dto\ElementInterface;
  11. use Magento\Framework\Setup\Declaration\Schema\Dto\Table;
  12. use Magento\Framework\Setup\Declaration\Schema\Operations\AddColumn;
  13. use Magento\Framework\Setup\Declaration\Schema\Operations\AddComplexElement;
  14. use Magento\Framework\Setup\Declaration\Schema\Operations\CreateTable;
  15. use Magento\Framework\Setup\Declaration\Schema\Operations\DropElement;
  16. use Magento\Framework\Setup\Declaration\Schema\Operations\DropReference;
  17. use Magento\Framework\Setup\Declaration\Schema\Operations\DropTable;
  18. use Magento\Framework\Setup\Declaration\Schema\Operations\ModifyColumn;
  19. use Magento\Framework\Setup\Declaration\Schema\Operations\ModifyTable;
  20. use Magento\Framework\Setup\Declaration\Schema\Operations\ReCreateTable;
  21. /**
  22. * Helper which provide methods, that helps to compare 2 different nodes:
  23. * For instance, 2 columns between each other.
  24. *
  25. * @SuppressWarnings(PHPMD.CouplingBetweenObjects)
  26. */
  27. class DiffManager
  28. {
  29. /**
  30. * @var Comparator
  31. */
  32. private $comparator;
  33. /**
  34. * Constructor.
  35. *
  36. * @param Comparator $comparator
  37. */
  38. public function __construct(Comparator $comparator)
  39. {
  40. $this->comparator = $comparator;
  41. }
  42. /**
  43. * Check whether this is element is new or not, by checking it in db schema.
  44. *
  45. * @param ElementInterface[] $generatedElements
  46. * @param ElementInterface $element
  47. * @return bool
  48. */
  49. public function shouldBeCreated(array $generatedElements, ElementInterface $element)
  50. {
  51. return !isset($generatedElements[$element->getName()]);
  52. }
  53. /**
  54. * Check whether we have elements that should be removed from database.
  55. *
  56. * @param array $generatedElements
  57. * @return bool
  58. */
  59. public function shouldBeRemoved(array $generatedElements)
  60. {
  61. return !empty($generatedElements);
  62. }
  63. /**
  64. * Register element, that should changes.
  65. *
  66. * @param Diff $diff
  67. * @param ElementInterface $element
  68. * @param ElementInterface $generatedElement
  69. * @return DiffInterface
  70. */
  71. public function registerModification(
  72. Diff $diff,
  73. ElementInterface $element,
  74. ElementInterface $generatedElement
  75. ) {
  76. if ($element instanceof Column) {
  77. $diff->register($element, ModifyColumn::OPERATION_NAME, $generatedElement);
  78. } else {
  79. $diff = $this->registerRemoval($diff, [$generatedElement]);
  80. $diff = $this->registerCreation($diff, $element);
  81. }
  82. return $diff;
  83. }
  84. /**
  85. * If elements really dont exists in declaration - we will remove them.
  86. * If some mistake happens (and element is just not preprocessed), we will throw exception.
  87. *
  88. * @param Diff $diff
  89. * @param ElementInterface[] $generatedElements
  90. * @return DiffInterface
  91. */
  92. public function registerRemoval(
  93. Diff $diff,
  94. array $generatedElements
  95. ) {
  96. foreach ($generatedElements as $generatedElement) {
  97. if ($generatedElement instanceof Reference) {
  98. $diff->register($generatedElement, DropReference::OPERATION_NAME, $generatedElement);
  99. } elseif ($generatedElement instanceof Table) {
  100. $diff->register($generatedElement, DropTable::OPERATION_NAME, $generatedElement);
  101. } else {
  102. $diff->register($generatedElement, DropElement::OPERATION_NAME, $generatedElement);
  103. }
  104. }
  105. return $diff;
  106. }
  107. /**
  108. * Register creation.
  109. *
  110. * @param DiffInterface $diff
  111. * @param ElementInterface $element
  112. * @return DiffInterface
  113. */
  114. public function registerCreation(DiffInterface $diff, ElementInterface $element)
  115. {
  116. if ($element instanceof Table) {
  117. $operation = CreateTable::OPERATION_NAME;
  118. } elseif ($element instanceof Column) {
  119. $operation = AddColumn::OPERATION_NAME;
  120. } else {
  121. $operation = AddComplexElement::OPERATION_NAME;
  122. }
  123. $diff->register($element, $operation);
  124. return $diff;
  125. }
  126. /**
  127. * Depends on what should be changed we can re-create table or modify it.
  128. *
  129. * For example, we can modify table if we need to change comment or engine.
  130. * Or we can re-create table, when we need to change it shard.
  131. *
  132. * @param Table $declaredTable
  133. * @param Table $generatedTable
  134. * @param Diff $diff
  135. * @return void
  136. */
  137. public function registerTableModification(Table $declaredTable, Table $generatedTable, Diff $diff)
  138. {
  139. $diff->register(
  140. $declaredTable,
  141. ModifyTable::OPERATION_NAME,
  142. $generatedTable
  143. );
  144. }
  145. /**
  146. * Register recreation of table, in case for example, when we need to move table from one shard to another
  147. *
  148. * @param Table $declaredTable
  149. * @param Table $generatedTable
  150. * @param Diff $diff
  151. * @return void
  152. */
  153. public function registerRecreation(Table $declaredTable, Table $generatedTable, Diff $diff)
  154. {
  155. $diff->register(
  156. $declaredTable,
  157. ReCreateTable::OPERATION_NAME,
  158. $generatedTable
  159. );
  160. }
  161. /**
  162. * Check whether element should be modified or not.
  163. *
  164. * @param ElementInterface $element
  165. * @param ElementInterface $generatedElement
  166. * @return bool
  167. */
  168. public function shouldBeModified(
  169. ElementInterface $element,
  170. ElementInterface $generatedElement
  171. ) {
  172. return !$this->comparator->compare($element, $generatedElement);
  173. }
  174. }