Add MariaDB test support and fix MySQL-family platform detection (#672)

dgafka · web-flow · commit 6c543efbb604 · 2026-06-06T11:16:37.000+02:00
* fix: detect MySQL family via AbstractMySQLPlatform so MariaDB uses MySQL SQL dialect

MariaDBPlatform does not extend MySQLPlatform (both extend AbstractMySQLPlatform),
so projection state storage emitted PostgreSQL ON CONFLICT syntax against MariaDB.
Switch platform checks to AbstractMySQLPlatform and add MariaDB to docker-compose.

* ci: add MariaDB pass to split-testing for all DBAL components

* test: fix MariaDB strictness in event-sourcing integration fixtures

- CustomEventStreamTest: select MariaDbSingleStreamStrategy on MariaDBPlatform
  instead of falling back to MySqlSingleStreamStrategy (MySQL-8 DDL rejected by MariaDB)
- GapDetection fixtures: write created_at without timezone offset (DATE_ATOM -&gt;
  Y-m-d\TH:i:s) so MariaDB strict mode accepts it

* fixes

* fixes

* test(laravel): pin doctrine/dbal ^4 in require-dev for prefer-lowest CI

Config/PDO/Connection.php implements the DBAL-4-only ServerVersionProvider
interface, so the Laravel package's own test suite needs DBAL 4. Without a pin,
--prefer-lowest resolved DBAL 3.9 and failed with 'Interface
Doctrine\DBAL\ServerVersionProvider not found'. Pin it in require-dev only, so the
constraint scopes to this package's tests and does not propagate to consumers or
the DBAL-3 Laravel quickstarts via the path repository.

* fix(data-protection): use null comparison instead of isset for nullable param

PHPStan 2.2 flags isset($length) on the always-defined ?int parameter
(isset.variable). Use $length === null, which is behaviorally identical.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -17,6 +17,7 @@ services:
       SQLITE_DATABASE_DSN: sqlite:////tmp/ecotone_test.db
       SECONDARY_DATABASE_DSN: mysql://ecotone:secret@database-mysql:3306/ecotone?serverVersion=8.0
       DATABASE_MYSQL: mysql://ecotone:secret@database-mysql:3306/ecotone?serverVersion=8.0
+      DATABASE_MARIADB: mysql://ecotone:secret@database-mariadb:3306/ecotone?serverVersion=11.4.5-MariaDB
       SQS_DSN: sqs:?key=key&secret=secret&region=us-east-1&endpoint=http://localstack:4566&version=latest
       REDIS_DSN: redis://redis:6379
       KAFKA_DSN: kafka:9092
@@ -40,6 +41,7 @@ services:
       SQLITE_DATABASE_DSN: sqlite:////tmp/ecotone_test.db
       SECONDARY_DATABASE_DSN: pgsql://ecotone:secret@database:5432/ecotone?serverVersion=16
       DATABASE_MYSQL: mysql://ecotone:secret@database-mysql:3306/ecotone?serverVersion=8.0
+      DATABASE_MARIADB: mysql://ecotone:secret@database-mariadb:3306/ecotone?serverVersion=11.4.5-MariaDB
       SQS_DSN: sqs:?key=key&secret=secret&region=us-east-1&endpoint=http://localstack:4566&version=latest
       REDIS_DSN: redis://redis:6379
       KAFKA_DSN: kafka:9092
@@ -61,6 +63,15 @@ services:
       MYSQL_DATABASE: "ecotone"
     ports:
       - "${MYSQL_PORT:-0}:3306"
+  database-mariadb:
+    image: mariadb:11.4
+    environment:
+      MARIADB_ROOT_PASSWORD: "secret"
+      MARIADB_USER: "ecotone"
+      MARIADB_PASSWORD: "secret"
+      MARIADB_DATABASE: "ecotone"
+    ports:
+      - "${MARIADB_PORT:-0}:3306"
   rabbitmq:
     build: ./.docker/rabbitmq
     environment:
diff --git a/packages/DataProtection/src/Encryption/Core.php b/packages/DataProtection/src/Encryption/Core.php
@@ -173,7 +173,7 @@ public static function substr(string $str, int $start, ?int $length = null): boo
         // mb_substr($str, 0, NULL, '8bit') returns an empty string on PHP 5.3,
         // so we have to find the length ourselves. Also, substr() doesn't
         // accept null for the length.
-        if (! isset($length)) {
+        if ($length === null) {
             if ($start >= 0) {
                 $length = $input_len - $start;
             } else {
diff --git a/packages/Dbal/src/DbalTransaction/ImplicitCommit.php b/packages/Dbal/src/DbalTransaction/ImplicitCommit.php
@@ -8,14 +8,14 @@
 namespace Ecotone\Dbal\DbalTransaction;
 
 use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Platforms\MySQLPlatform;
+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
 use Throwable;
 
 class ImplicitCommit
 {
     public static function isImplicitCommitException(Throwable $exception, Connection $connection): bool
     {
-        if (! ($connection->getDriver()->getDatabasePlatform($connection) instanceof MySQLPlatform)) {
+        if (! ($connection->getDriver()->getDatabasePlatform($connection) instanceof AbstractMySQLPlatform)) {
             return false;
         }
 
diff --git a/packages/Dbal/tests/Integration/DeduplicationModuleTest.php b/packages/Dbal/tests/Integration/DeduplicationModuleTest.php
@@ -158,7 +158,7 @@ public function test_deduplication_inserts_before_handler_when_transaction_is_ac
         // Set global lock timeout for the session
         if ($platform instanceof \Doctrine\DBAL\Platforms\PostgreSQLPlatform) {
             $connection2->executeStatement('SET lock_timeout = 1000'); // 1 second
-        } elseif ($platform instanceof \Doctrine\DBAL\Platforms\MySQLPlatform) {
+        } elseif ($platform instanceof \Doctrine\DBAL\Platforms\AbstractMySQLPlatform) {
             // For MySQL, we need to set this on the session level
             $connection2->executeStatement('SET SESSION innodb_lock_wait_timeout = 1'); // 1 second
         }
diff --git a/packages/Laravel/composer.json b/packages/Laravel/composer.json
@@ -64,6 +64,7 @@
         "nesbot/carbon": "^2.71|^3.0",
         "moneyphp/money": "^4.1.0",
         "ecotone/dbal": "~1.314.0",
+        "doctrine/dbal": "^4.0",
         "timacdonald/log-fake": "^2.0"
     },
     "extra": {
diff --git a/packages/PdoEventSourcing/src/Database/ProjectionStateTableManager.php b/packages/PdoEventSourcing/src/Database/ProjectionStateTableManager.php
@@ -5,7 +5,7 @@
 namespace Ecotone\EventSourcing\Database;
 
 use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Platforms\MySQLPlatform;
+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
 use Ecotone\Dbal\Compatibility\SchemaManagerCompatibility;
 use Ecotone\Dbal\Database\DbalTableManager;
 use Ecotone\Messaging\Config\Container\Definition;
@@ -46,7 +46,7 @@ public function getTableName(): string
 
     public function getCreateTableSql(Connection $connection): string|array
     {
-        if ($connection->getDatabasePlatform() instanceof MySQLPlatform) {
+        if ($connection->getDatabasePlatform() instanceof AbstractMySQLPlatform) {
             return $this->getMysqlCreateSql();
         }
 
diff --git a/packages/PdoEventSourcing/src/Projecting/PartitionState/DbalProjectionStateStorage.php b/packages/PdoEventSourcing/src/Projecting/PartitionState/DbalProjectionStateStorage.php
@@ -8,7 +8,7 @@
 namespace Ecotone\EventSourcing\Projecting\PartitionState;
 
 use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Platforms\MySQLPlatform;
+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
 use Ecotone\Dbal\AlreadyConnectedDbalConnectionFactory;
 use Ecotone\Dbal\MultiTenant\MultiTenantConnectionFactory;
 use Ecotone\EventSourcing\Database\ProjectionStateTableManager;
@@ -115,7 +115,7 @@ public function initPartition(string $projectionName, ?string $partitionKey = nu
 
         // Try to insert the partition state, ignoring if it already exists
         $insertQuery = match (true) {
-            $connection->getDatabasePlatform() instanceof MySQLPlatform => <<<SQL
+            $connection->getDatabasePlatform() instanceof AbstractMySQLPlatform => <<<SQL
                 INSERT INTO {$tableName} (projection_name, partition_key, last_position, user_state, metadata)
                 VALUES (:projectionName, :partitionKey, :lastPosition, :userState, :metadata)
                 ON DUPLICATE KEY UPDATE projection_name = projection_name -- no-op to ignore
@@ -155,7 +155,7 @@ public function savePartition(ProjectionPartitionState $projectionState): void
         $tableName = $this->getTableName();
 
         $saveStateQuery = match (true) {
-            $connection->getDatabasePlatform() instanceof MySQLPlatform => <<<SQL
+            $connection->getDatabasePlatform() instanceof AbstractMySQLPlatform => <<<SQL
                 INSERT INTO {$tableName} (projection_name, partition_key, last_position, user_state, metadata)
                 VALUES (:projectionName, :partitionKey, :lastPosition, :userState, :metadata)
                 ON DUPLICATE KEY UPDATE last_position = :lastPosition, user_state = :userState, metadata = :metadata
diff --git a/packages/PdoEventSourcing/tests/Integration/CustomEventStreamTest.php b/packages/PdoEventSourcing/tests/Integration/CustomEventStreamTest.php
@@ -4,13 +4,16 @@
 
 namespace Test\Ecotone\EventSourcing\Integration;
 
-use Doctrine\DBAL\Driver\PDO\PgSQL\Driver;
+use Doctrine\DBAL\Platforms\MariaDBPlatform;
+use Doctrine\DBAL\Platforms\PostgreSQLPlatform;
 use Ecotone\EventSourcing\EventSourcingConfiguration;
 use Ecotone\EventSourcing\Prooph\FromProophMessageToArrayConverter;
 use Ecotone\Lite\EcotoneLite;
 use Ecotone\Messaging\Config\ModulePackageList;
 use Ecotone\Messaging\Config\ServiceConfiguration;
 use Enqueue\Dbal\DbalConnectionFactory;
+use Prooph\EventStore\Pdo\PersistenceStrategy;
+use Prooph\EventStore\Pdo\PersistenceStrategy\MariaDbSingleStreamStrategy;
 use Prooph\EventStore\Pdo\PersistenceStrategy\MySqlSingleStreamStrategy;
 use Prooph\EventStore\Pdo\PersistenceStrategy\PostgresSingleStreamStrategy;
 use Test\Ecotone\EventSourcing\EventSourcingMessagingTestCase;
@@ -42,11 +45,7 @@ public function test_handling_custom_event_stream_when_custom_stream_persistence
                 ])
                 ->withExtensionObjects([
                     EventSourcingConfiguration::createWithDefaults()
-                        ->withCustomPersistenceStrategy(
-                            $this->isPostgres()
-                                ? new PostgresSingleStreamStrategy(new FromProophMessageToArrayConverter())
-                                : new MySqlSingleStreamStrategy(new FromProophMessageToArrayConverter())
-                        ),
+                        ->withCustomPersistenceStrategy($this->persistenceStrategy()),
                 ]),
             pathToRootCatalog: __DIR__ . '/../../',
             runForProductionEventStore: true
@@ -60,8 +59,14 @@ public function test_handling_custom_event_stream_when_custom_stream_persistence
         self::assertEquals(2, $ecotone->sendQueryWithRouting('action_collector.getCount'));
     }
 
-    private function isPostgres(): bool
+    private function persistenceStrategy(): PersistenceStrategy
     {
-        return $this->getConnection()->getDriver() instanceof Driver;
+        $platform = $this->getConnection()->getDatabasePlatform();
+
+        return match (true) {
+            $platform instanceof PostgreSQLPlatform => new PostgresSingleStreamStrategy(new FromProophMessageToArrayConverter()),
+            $platform instanceof MariaDBPlatform => new MariaDbSingleStreamStrategy(new FromProophMessageToArrayConverter()),
+            default => new MySqlSingleStreamStrategy(new FromProophMessageToArrayConverter()),
+        };
     }
 }
diff --git a/packages/PdoEventSourcing/tests/Integration/GapDetectionInPollingProjectionTest.php b/packages/PdoEventSourcing/tests/Integration/GapDetectionInPollingProjectionTest.php
@@ -61,15 +61,15 @@ protected function setUp(): void
 
         $metadata = json_decode($connection->fetchOne(sprintf('select metadata from %s where no = ?', $streamName), [1]), true);
         $metadata['timestamp'] = $initialTimestamp;
-        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date(DATE_ATOM, $initialTimestamp)], ['no' => 1]);
+        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date('Y-m-d\TH:i:s', $initialTimestamp)], ['no' => 1]);
 
         $metadata = json_decode($connection->fetchOne(sprintf('select metadata from %s where no = ?', $streamName), [3]), true);
         $metadata['timestamp'] = $initialTimestamp + 10;
-        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date(DATE_ATOM, $initialTimestamp + 10)], ['no' => 3]);
+        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date('Y-m-d\TH:i:s', $initialTimestamp + 10)], ['no' => 3]);
 
         $metadata = json_decode($connection->fetchOne(sprintf('select metadata from %s where no = ?', $streamName), [4]), true);
         $metadata['timestamp'] = $initialTimestamp + 20;
-        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date(DATE_ATOM, $initialTimestamp + 20)], ['no' => 4]);
+        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date('Y-m-d\TH:i:s', $initialTimestamp + 20)], ['no' => 4]);
     }
 
     public function test_detecting_gaps_without_detection_window(): void
diff --git a/packages/PdoEventSourcing/tests/Integration/GapDetectionInSynchronousProjectionTest.php b/packages/PdoEventSourcing/tests/Integration/GapDetectionInSynchronousProjectionTest.php
@@ -58,15 +58,15 @@ protected function setUp(): void
 
         $metadata = json_decode($connection->fetchOne(sprintf('select metadata from %s where no = ?', $streamName), [1]), true);
         $metadata['timestamp'] = $initialTimestamp;
-        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date(DATE_ATOM, $initialTimestamp)], ['no' => 1]);
+        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date('Y-m-d\TH:i:s', $initialTimestamp)], ['no' => 1]);
 
         $metadata = json_decode($connection->fetchOne(sprintf('select metadata from %s where no = ?', $streamName), [3]), true);
         $metadata['timestamp'] = $initialTimestamp + 10;
-        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date(DATE_ATOM, $initialTimestamp + 10)], ['no' => 3]);
+        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date('Y-m-d\TH:i:s', $initialTimestamp + 10)], ['no' => 3]);
 
         $metadata = json_decode($connection->fetchOne(sprintf('select metadata from %s where no = ?', $streamName), [4]), true);
         $metadata['timestamp'] = $initialTimestamp + 20;
-        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date(DATE_ATOM, $initialTimestamp + 20)], ['no' => 4]);
+        $connection->update($streamName, ['metadata' => json_encode($metadata), 'created_at' => date('Y-m-d\TH:i:s', $initialTimestamp + 20)], ['no' => 4]);
     }
 
     public function test_detecting_gaps_without_detection_window(): void
diff --git a/packages/PdoEventSourcing/tests/Projecting/Partitioned/PartitionedProjectionEdgeCasesTest.php b/packages/PdoEventSourcing/tests/Projecting/Partitioned/PartitionedProjectionEdgeCasesTest.php
@@ -8,7 +8,7 @@
 namespace Test\Ecotone\EventSourcing\Projecting\Partitioned;
 
 use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Platforms\MySQLPlatform;
+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
 use Ecotone\EventSourcing\Attribute\FromStream;
 use Ecotone\EventSourcing\Attribute\ProjectionDelete;
 use Ecotone\EventSourcing\Attribute\ProjectionInitialization;
@@ -262,7 +262,7 @@ public function getTickets(): array
             #[EventHandler]
             public function addTicket(TicketWasRegistered $event): void
             {
-                if ($this->connection->getDatabasePlatform() instanceof MySQLPlatform) {
+                if ($this->connection->getDatabasePlatform() instanceof AbstractMySQLPlatform) {
                     $this->connection->executeStatement('INSERT IGNORE INTO idempotent_projection_tickets VALUES (?,?)', [$event->getTicketId(), $event->getTicketType()]);
                 } else {
                     $this->connection->executeStatement('INSERT INTO idempotent_projection_tickets VALUES (?,?) ON CONFLICT (ticket_id) DO NOTHING', [$event->getTicketId(), $event->getTicketType()]);
@@ -413,7 +413,7 @@ public function whenMeetingCreated(MeetingCreated $event): void
             #[ProjectionInitialization]
             public function initialization(): void
             {
-                if ($this->connection->getDatabasePlatform() instanceof MySQLPlatform) {
+                if ($this->connection->getDatabasePlatform() instanceof AbstractMySQLPlatform) {
                     $this->connection->executeStatement('CREATE TABLE IF NOT EXISTS multi_stream_edge_events (id INT AUTO_INCREMENT PRIMARY KEY, event_type VARCHAR(100), aggregate_id VARCHAR(36), stream_name VARCHAR(255))');
                 } else {
                     $this->connection->executeStatement('CREATE TABLE IF NOT EXISTS multi_stream_edge_events (id SERIAL PRIMARY KEY, event_type VARCHAR(100), aggregate_id VARCHAR(36), stream_name VARCHAR(255))');
diff --git a/packages/PdoEventSourcing/tests/Projecting/Partitioned/ProjectionWithStateTest.php b/packages/PdoEventSourcing/tests/Projecting/Partitioned/ProjectionWithStateTest.php
@@ -5,7 +5,7 @@
 namespace Test\Ecotone\EventSourcing\Projecting\Partitioned;
 
 use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Platforms\MySQLPlatform;
+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
 use Ecotone\EventSourcing\Attribute\FromStream;
 use Ecotone\EventSourcing\Attribute\ProjectionDelete;
 use Ecotone\EventSourcing\Attribute\ProjectionInitialization;
@@ -174,7 +174,7 @@ public function initialization(): void
                         )
                     SQL);
                 $insertQuery = match (true) {
-                    $this->connection->getDatabasePlatform() instanceof MySQLPlatform => <<<SQL
+                    $this->connection->getDatabasePlatform() instanceof AbstractMySQLPlatform => <<<SQL
                         INSERT INTO ticket_counter_partitioned (id, ticket_count, closed_count) VALUES (1, 0, 0)
                         ON DUPLICATE KEY UPDATE id = id
                         SQL,
diff --git a/packages/PdoEventSourcing/tests/Projecting/RebuildProjectionTest.php b/packages/PdoEventSourcing/tests/Projecting/RebuildProjectionTest.php
@@ -5,7 +5,7 @@
 namespace Test\Ecotone\EventSourcing\Projecting;
 
 use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Platforms\MySQLPlatform;
+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
 use Ecotone\EventSourcing\Attribute\FromStream;
 use Ecotone\EventSourcing\Attribute\ProjectionDelete;
 use Ecotone\EventSourcing\Attribute\ProjectionInitialization;
@@ -141,7 +141,7 @@ public function __construct(private Connection $connection)
     public function onTicketRegistered(TicketWasRegistered $event): void
     {
         $this->handleEvent($event->getTicketId());
-        if ($this->connection->getDatabasePlatform() instanceof MySQLPlatform) {
+        if ($this->connection->getDatabasePlatform() instanceof AbstractMySQLPlatform) {
             $this->connection->executeStatement('INSERT IGNORE INTO rebuild_rollback_tickets VALUES (?,?)', [$event->getTicketId(), $event->getTicketType()]);
         } else {
             $this->connection->executeStatement('INSERT INTO rebuild_rollback_tickets VALUES (?,?) ON CONFLICT(ticket_id) DO NOTHING', [$event->getTicketId(), $event->getTicketType()]);
diff --git a/packages/PdoEventSourcing/tests/Projecting/TransactionRollbackTest.php b/packages/PdoEventSourcing/tests/Projecting/TransactionRollbackTest.php
@@ -8,7 +8,7 @@
 namespace Test\Ecotone\EventSourcing\Projecting;
 
 use Doctrine\DBAL\Connection;
-use Doctrine\DBAL\Platforms\MySQLPlatform;
+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
 use Ecotone\Dbal\DbalBackedMessageChannelBuilder;
 use Ecotone\EventSourcing\Attribute\FromStream;
 use Ecotone\EventSourcing\Attribute\ProjectionDelete;
@@ -111,7 +111,7 @@ public function test_partitioned_multi_stream_projection_rolls_back_on_failure_a
 
         $ecotone = $this->bootstrapEcotoneForCalendar([$projection::class], [$projection], $projection::CHANNEL);
 
-        if ($this->getConnection()->getDatabasePlatform() instanceof MySQLPlatform) {
+        if ($this->getConnection()->getDatabasePlatform() instanceof AbstractMySQLPlatform) {
             $this->getConnection()->executeStatement('CREATE TABLE IF NOT EXISTS multi_stream_rollback_events (id INT AUTO_INCREMENT PRIMARY KEY, event_type VARCHAR(100), aggregate_id VARCHAR(36), stream_name VARCHAR(255))');
         } else {
             $this->getConnection()->executeStatement('CREATE TABLE IF NOT EXISTS multi_stream_rollback_events (id SERIAL PRIMARY KEY, event_type VARCHAR(100), aggregate_id VARCHAR(36), stream_name VARCHAR(255))');
@@ -146,7 +146,7 @@ public function test_partitioned_multi_stream_with_events_in_both_streams_proces
 
         $ecotone = $this->bootstrapEcotoneForCalendar([$projection::class], [$projection], $projection::CHANNEL);
 
-        if ($this->getConnection()->getDatabasePlatform() instanceof MySQLPlatform) {
+        if ($this->getConnection()->getDatabasePlatform() instanceof AbstractMySQLPlatform) {
             $this->getConnection()->executeStatement('CREATE TABLE IF NOT EXISTS multi_stream_fail_second_events (id INT AUTO_INCREMENT PRIMARY KEY, event_type VARCHAR(100), aggregate_id VARCHAR(36), stream_name VARCHAR(255))');
         } else {
             $this->getConnection()->executeStatement('CREATE TABLE IF NOT EXISTS multi_stream_fail_second_events (id SERIAL PRIMARY KEY, event_type VARCHAR(100), aggregate_id VARCHAR(36), stream_name VARCHAR(255))');

Original file line number	Diff line number	Diff line change
`@@ -8,14 +8,14 @@`
`8`	`8`	`namespace Ecotone\Dbal\DbalTransaction;`
`9`	`9`
`10`	`10`	`use Doctrine\DBAL\Connection;`
`11`		`-use Doctrine\DBAL\Platforms\MySQLPlatform;`
	`11`	`+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;`
`12`	`12`	`use Throwable;`
`13`	`13`
`14`	`14`	`class ImplicitCommit`
`15`	`15`	`{`
`16`	`16`	`public static function isImplicitCommitException(Throwable $exception, Connection $connection): bool`
`17`	`17`	`{`
`18`		`- if (! ($connection->getDriver()->getDatabasePlatform($connection) instanceof MySQLPlatform)) {`
	`18`	`+ if (! ($connection->getDriver()->getDatabasePlatform($connection) instanceof AbstractMySQLPlatform)) {`
`19`	`19`	`return false;`
`20`	`20`	`}`
`21`	`21`
Original file line number	Diff line number	Diff line change
`@@ -158,7 +158,7 @@ public function test_deduplication_inserts_before_handler_when_transaction_is_ac`
`158`	`158`	`// Set global lock timeout for the session`
`159`	`159`	`if ($platform instanceof \Doctrine\DBAL\Platforms\PostgreSQLPlatform) {`
`160`	`160`	`$connection2->executeStatement('SET lock_timeout = 1000'); // 1 second`
`161`		`- } elseif ($platform instanceof \Doctrine\DBAL\Platforms\MySQLPlatform) {`
	`161`	`+ } elseif ($platform instanceof \Doctrine\DBAL\Platforms\AbstractMySQLPlatform) {`
`162`	`162`	`// For MySQL, we need to set this on the session level`
`163`	`163`	`$connection2->executeStatement('SET SESSION innodb_lock_wait_timeout = 1'); // 1 second`
`164`	`164`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@`
`5`	`5`	`namespace Ecotone\EventSourcing\Database;`
`6`	`6`
`7`	`7`	`use Doctrine\DBAL\Connection;`
`8`		`-use Doctrine\DBAL\Platforms\MySQLPlatform;`
	`8`	`+use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;`
`9`	`9`	`use Ecotone\Dbal\Compatibility\SchemaManagerCompatibility;`
`10`	`10`	`use Ecotone\Dbal\Database\DbalTableManager;`
`11`	`11`	`use Ecotone\Messaging\Config\Container\Definition;`
`@@ -46,7 +46,7 @@ public function getTableName(): string`
`46`	`46`
`47`	`47`	`public function getCreateTableSql(Connection $connection): string\|array`
`48`	`48`	`{`
`49`		`- if ($connection->getDatabasePlatform() instanceof MySQLPlatform) {`
	`49`	`+ if ($connection->getDatabasePlatform() instanceof AbstractMySQLPlatform) {`
`50`	`50`	`return $this->getMysqlCreateSql();`
`51`	`51`	`}`
`52`	`52`