|
11 | 11 |
|
12 | 12 | namespace Symfony\Bridge\Doctrine\SchemaListener;
|
13 | 13 |
|
14 |
| -use Doctrine\DBAL\Event\SchemaCreateTableEventArgs; |
| 14 | +use Doctrine\Common\EventSubscriber; |
15 | 15 | use Doctrine\DBAL\Events;
|
16 |
| -use Doctrine\ORM\Tools\Event\GenerateSchemaEventArgs; |
17 |
| -use Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineTransport; |
18 |
| -use Symfony\Component\Messenger\Transport\TransportInterface; |
| 16 | +use Doctrine\ORM\Tools\ToolEvents; |
| 17 | + |
| 18 | +trigger_deprecation('symfony/doctrine-bridge', '6.3', 'The "%s" class is deprecated. Use "%s" instead.', MessengerTransportDoctrineSchemaSubscriber::class, MessengerTransportDoctrineSchemaListener::class); |
19 | 19 |
|
20 | 20 | /**
|
21 | 21 | * Automatically adds any required database tables to the Doctrine Schema.
|
22 | 22 | *
|
23 | 23 | * @author Ryan Weaver <ryan@symfonycasts.com>
|
| 24 | + * |
| 25 | + * @deprecated since Symfony 6.3, use {@link MessengerTransportDoctrineSchemaListener} instead |
24 | 26 | */
|
25 |
| -final class MessengerTransportDoctrineSchemaSubscriber extends AbstractSchemaSubscriber |
| 27 | +final class MessengerTransportDoctrineSchemaSubscriber extends MessengerTransportDoctrineSchemaListener implements EventSubscriber |
26 | 28 | {
|
27 |
| - private const PROCESSING_TABLE_FLAG = self::class.':processing'; |
28 |
| - |
29 |
| - private iterable $transports; |
30 |
| - |
31 |
| - /** |
32 |
| - * @param iterable<mixed, TransportInterface> $transports |
33 |
| - */ |
34 |
| - public function __construct(iterable $transports) |
35 |
| - { |
36 |
| - $this->transports = $transports; |
37 |
| - } |
38 |
| - |
39 |
| - public function postGenerateSchema(GenerateSchemaEventArgs $event): void |
40 |
| - { |
41 |
| - $connection = $event->getEntityManager()->getConnection(); |
42 |
| - |
43 |
| - foreach ($this->transports as $transport) { |
44 |
| - if (!$transport instanceof DoctrineTransport) { |
45 |
| - continue; |
46 |
| - } |
47 |
| - |
48 |
| - $transport->configureSchema($event->getSchema(), $connection, $this->getIsSameDatabaseChecker($connection)); |
49 |
| - } |
50 |
| - } |
51 |
| - |
52 |
| - public function onSchemaCreateTable(SchemaCreateTableEventArgs $event): void |
| 29 | + public function getSubscribedEvents(): array |
53 | 30 | {
|
54 |
| - $table = $event->getTable(); |
55 |
| - |
56 |
| - // if this method triggers a nested create table below, allow Doctrine to work like normal |
57 |
| - if ($table->hasOption(self::PROCESSING_TABLE_FLAG)) { |
58 |
| - return; |
59 |
| - } |
60 |
| - |
61 |
| - foreach ($this->transports as $transport) { |
62 |
| - if (!$transport instanceof DoctrineTransport) { |
63 |
| - continue; |
64 |
| - } |
65 |
| - |
66 |
| - if (!$extraSql = $transport->getExtraSetupSqlForTable($table)) { |
67 |
| - continue; |
68 |
| - } |
| 31 | + $subscribedEvents = []; |
69 | 32 |
|
70 |
| - // avoid this same listener from creating a loop on this table |
71 |
| - $table->addOption(self::PROCESSING_TABLE_FLAG, true); |
72 |
| - $createTableSql = $event->getPlatform()->getCreateTableSQL($table); |
73 |
| - |
74 |
| - /* |
75 |
| - * Add all the SQL needed to create the table and tell Doctrine |
76 |
| - * to "preventDefault" so that only our SQL is used. This is |
77 |
| - * the only way to inject some extra SQL. |
78 |
| - */ |
79 |
| - $event->addSql($createTableSql); |
80 |
| - foreach ($extraSql as $sql) { |
81 |
| - $event->addSql($sql); |
82 |
| - } |
83 |
| - $event->preventDefault(); |
84 |
| - |
85 |
| - return; |
| 33 | + if (class_exists(ToolEvents::class)) { |
| 34 | + $subscribedEvents[] = ToolEvents::postGenerateSchema; |
86 | 35 | }
|
87 |
| - } |
88 |
| - |
89 |
| - public function getSubscribedEvents(): array |
90 |
| - { |
91 |
| - $subscribedEvents = parent::getSubscribedEvents(); |
92 | 36 |
|
93 | 37 | if (class_exists(Events::class)) {
|
94 | 38 | $subscribedEvents[] = Events::onSchemaCreateTable;
|
|
0 commit comments