TablePartitionDefinition.php 6.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193
  1. <?php
  2. declare(strict_types=1);
  3. namespace PhpMyAdmin;
  4. use function array_intersect_key;
  5. use function array_merge;
  6. use function array_splice;
  7. use function min;
  8. class TablePartitionDefinition
  9. {
  10. /**
  11. * @param array|null $details Details that may be pre-filled
  12. *
  13. * @return array
  14. */
  15. public static function getDetails(?array $details = null): array
  16. {
  17. if (! isset($details)) {
  18. $details = self::generateDetails();
  19. }
  20. return $details;
  21. }
  22. /**
  23. * @return array
  24. */
  25. protected static function generateDetails(): array
  26. {
  27. $partitionDetails = self::extractDetailsFromRequest();
  28. // Only LIST and RANGE type parameters allow subpartitioning
  29. $partitionDetails['can_have_subpartitions'] = $partitionDetails['partition_count'] > 1
  30. && isset($partitionDetails['partition_by'])
  31. && ($partitionDetails['partition_by'] === 'RANGE'
  32. || $partitionDetails['partition_by'] === 'RANGE COLUMNS'
  33. || $partitionDetails['partition_by'] === 'LIST'
  34. || $partitionDetails['partition_by'] === 'LIST COLUMNS');
  35. // Values are specified only for LIST and RANGE type partitions
  36. $partitionDetails['value_enabled'] = isset($partitionDetails['partition_by'])
  37. && ($partitionDetails['partition_by'] === 'RANGE'
  38. || $partitionDetails['partition_by'] === 'RANGE COLUMNS'
  39. || $partitionDetails['partition_by'] === 'LIST'
  40. || $partitionDetails['partition_by'] === 'LIST COLUMNS');
  41. return self::extractPartitions($partitionDetails);
  42. }
  43. /**
  44. * Extract some partitioning and subpartitioning parameters from the request
  45. *
  46. * @return array
  47. */
  48. protected static function extractDetailsFromRequest(): array
  49. {
  50. $partitionParams = [
  51. 'partition_by' => null,
  52. 'partition_expr' => null,
  53. 'subpartition_by' => null,
  54. 'subpartition_expr' => null,
  55. ];
  56. //Initialize details with values to "null" if not in request
  57. $details = array_merge(
  58. $partitionParams,
  59. //Keep $_POST values, but only for keys that are in $partitionParams
  60. array_intersect_key($_POST, $partitionParams)
  61. );
  62. $details['partition_count'] = self::extractPartitionCount('partition_count') ?: '';
  63. $details['subpartition_count'] = self::extractPartitionCount('subpartition_count') ?: '';
  64. return $details;
  65. }
  66. /**
  67. * @param string $paramLabel Label searched in request
  68. */
  69. protected static function extractPartitionCount(string $paramLabel): int
  70. {
  71. if (Core::isValid($_POST[$paramLabel], 'numeric')) {
  72. // MySQL's limit is 8192, so do not allow more
  73. $count = min((int) $_POST[$paramLabel], 8192);
  74. } else {
  75. $count = 0;
  76. }
  77. return $count;
  78. }
  79. /**
  80. * @param array $partitionDetails Details of partitions
  81. *
  82. * @return array
  83. */
  84. protected static function extractPartitions(array $partitionDetails): array
  85. {
  86. $partitionCount = $partitionDetails['partition_count'];
  87. $subpartitionCount = $partitionDetails['subpartition_count'];
  88. // No partitions
  89. if ($partitionCount <= 1) {
  90. return $partitionDetails;
  91. }
  92. // Has partitions
  93. $partitions = $_POST['partitions'] ?? [];
  94. // Remove details of the additional partitions
  95. // when number of partitions have been reduced
  96. array_splice($partitions, $partitionCount);
  97. for ($i = 0; $i < $partitionCount; $i++) {
  98. if (! isset($partitions[$i])) { // Newly added partition
  99. $partitions[$i] = [
  100. 'name' => 'p' . $i,
  101. 'value_type' => '',
  102. 'value' => '',
  103. 'engine' => '',
  104. 'comment' => '',
  105. 'data_directory' => '',
  106. 'index_directory' => '',
  107. 'max_rows' => '',
  108. 'min_rows' => '',
  109. 'tablespace' => '',
  110. 'node_group' => '',
  111. ];
  112. }
  113. $partition =& $partitions[$i];
  114. $partition['prefix'] = 'partitions[' . $i . ']';
  115. // Changing from HASH/KEY to RANGE/LIST
  116. if (! isset($partition['value_type'])) {
  117. $partition['value_type'] = '';
  118. $partition['value'] = '';
  119. }
  120. if (! isset($partition['engine'])) { // When removing subpartitioning
  121. $partition['engine'] = '';
  122. $partition['comment'] = '';
  123. $partition['data_directory'] = '';
  124. $partition['index_directory'] = '';
  125. $partition['max_rows'] = '';
  126. $partition['min_rows'] = '';
  127. $partition['tablespace'] = '';
  128. $partition['node_group'] = '';
  129. }
  130. // No subpartitions
  131. if ($subpartitionCount <= 1 || $partitionDetails['can_have_subpartitions'] !== true) {
  132. unset($partition['subpartitions'], $partition['subpartition_count']);
  133. continue;
  134. }
  135. // Has subpartitions
  136. $partition['subpartition_count'] = $subpartitionCount;
  137. if (! isset($partition['subpartitions'])) {
  138. $partition['subpartitions'] = [];
  139. }
  140. $subpartitions =& $partition['subpartitions'];
  141. // Remove details of the additional subpartitions
  142. // when number of subpartitions have been reduced
  143. array_splice($subpartitions, $subpartitionCount);
  144. for ($j = 0; $j < $subpartitionCount; $j++) {
  145. if (! isset($subpartitions[$j])) { // Newly added subpartition
  146. $subpartitions[$j] = [
  147. 'name' => $partition['name'] . '_s' . $j,
  148. 'engine' => '',
  149. 'comment' => '',
  150. 'data_directory' => '',
  151. 'index_directory' => '',
  152. 'max_rows' => '',
  153. 'min_rows' => '',
  154. 'tablespace' => '',
  155. 'node_group' => '',
  156. ];
  157. }
  158. $subpartitions[$j]['prefix'] = 'partitions[' . $i . ']'
  159. . '[subpartitions][' . $j . ']';
  160. }
  161. }
  162. $partitionDetails['partitions'] = $partitions;
  163. return $partitionDetails;
  164. }
  165. }