UpgradeSerializedFields.php 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\User\Setup\Patch\Data;
  7. use Magento\Framework\DB\DataConverter\SerializedToJson;
  8. use Magento\Framework\DB\FieldDataConverterFactory;
  9. use Magento\Framework\App\ResourceConnection;
  10. use Magento\Framework\Setup\Patch\DataPatchInterface;
  11. use Magento\Framework\Setup\Patch\PatchVersionInterface;
  12. /**
  13. * Class UpgradeSerializedFields
  14. * @package Magento\User\Setup\Patch
  15. */
  16. class UpgradeSerializedFields implements DataPatchInterface, PatchVersionInterface
  17. {
  18. /**
  19. * @var \Magento\Framework\Setup\ModuleDataSetupInterface
  20. */
  21. private $moduleDataSetup;
  22. /**
  23. * @var FieldDataConverterFactory
  24. */
  25. private $fieldDataConverterFactory;
  26. /**
  27. * UpgradeSerializedFields constructor.
  28. * @param \Magento\Framework\Setup\ModuleDataSetupInterface $moduleDataSetup
  29. * @param FieldDataConverterFactory $fieldDataConverterFactory
  30. */
  31. public function __construct(
  32. \Magento\Framework\Setup\ModuleDataSetupInterface $moduleDataSetup,
  33. FieldDataConverterFactory $fieldDataConverterFactory
  34. ) {
  35. $this->moduleDataSetup = $moduleDataSetup;
  36. $this->fieldDataConverterFactory = $fieldDataConverterFactory;
  37. }
  38. /**
  39. * {@inheritdoc}
  40. */
  41. public function apply()
  42. {
  43. $this->moduleDataSetup->getConnection()->startSetup();
  44. $this->upgradeSerializedFields();
  45. $this->moduleDataSetup->getConnection()->endSetup();
  46. }
  47. /**
  48. * {@inheritdoc}
  49. */
  50. public static function getDependencies()
  51. {
  52. return [
  53. UpgradePasswordHashes::class
  54. ];
  55. }
  56. /**
  57. * {@inheritdoc}
  58. */
  59. public static function getVersion()
  60. {
  61. return '2.0.2';
  62. }
  63. /**
  64. * {@inheritdoc}
  65. */
  66. public function getAliases()
  67. {
  68. return [];
  69. }
  70. /**
  71. * Convert serialized data to json.
  72. */
  73. private function upgradeSerializedFields()
  74. {
  75. $fieldDataConverter = $this->fieldDataConverterFactory->create(SerializedToJson::class);
  76. $fieldDataConverter->convert(
  77. $this->moduleDataSetup->getConnection(),
  78. $this->moduleDataSetup->getTable('admin_user'),
  79. 'user_id',
  80. 'extra'
  81. );
  82. }
  83. }