Add MySQL spatial type support

Extends AbstractMySQLPlatform with GEOMETRY type support and enhances MySQLSchemaManager to introspect spatial columns with geometryType and SRID properties.

MySQL supports GEOMETRY types (POINT, LINESTRING, POLYGON, etc.) with optional SRID constraints using the conditional comment syntax for MySQL 8.0.3+.

Author: ddegasperi

src/Platforms/AbstractMySQLPlatform.php

@@ -34,6 +34,7 @@
 use function sprintf;
 use function str_replace;
 use function strtolower;
+use function strtoupper;
 
 /**
  * Provides the base implementation for the lowest versions of supported MySQL-like database platforms.
@@ -224,17 +225,27 @@ public function getBooleanTypeDeclarationSQL(array $column): string
      */
     public function getGeometryTypeDeclarationSQL(array $column): string
     {
-        throw NotSupported::new(__METHOD__);
+        $geometryType = $column['geometryType'] ?? 'GEOMETRY';
+        $srid         = $column['srid'] ?? null;
+
+        $sql = strtoupper($geometryType);
+
+        if ($srid !== null) {
+            // MySQL 8.0.3+ supports SRID attribute using conditional comment syntax
+            $sql .= sprintf(' /*!80003 SRID %d */', $srid);
+        }
+
+        return $sql;
     }
 
     public function getGeometryFromTextSQL(string $sqlExpr): string
     {
-        throw NotSupported::new(__METHOD__);
+        return sprintf('ST_GeomFromText(%s)', $sqlExpr);
     }
 
     public function getGeometryAsTextSQL(string $sqlExpr): string
     {
-        throw NotSupported::new(__METHOD__);
+        return sprintf('ST_AsText(%s)', $sqlExpr);
     }
 
     /**
@@ -796,38 +807,46 @@ public function getSetTransactionIsolationSQL(TransactionIsolationLevel $level):
     protected function initializeDoctrineTypeMappings(): void
     {
         $this->doctrineTypeMapping = [
-            'bigint'     => Types::BIGINT,
-            'binary'     => Types::BINARY,
-            'blob'       => Types::BLOB,
-            'char'       => Types::STRING,
-            'date'       => Types::DATE_MUTABLE,
-            'datetime'   => Types::DATETIME_MUTABLE,
-            'decimal'    => Types::DECIMAL,
-            'double'     => Types::FLOAT,
-            'enum'       => Types::ENUM,
-            'float'      => Types::SMALLFLOAT,
-            'int'        => Types::INTEGER,
-            'integer'    => Types::INTEGER,
-            'json'       => Types::JSON,
-            'longblob'   => Types::BLOB,
-            'longtext'   => Types::TEXT,
-            'mediumblob' => Types::BLOB,
-            'mediumint'  => Types::INTEGER,
-            'mediumtext' => Types::TEXT,
-            'numeric'    => Types::DECIMAL,
-            'real'       => Types::FLOAT,
-            'set'        => Types::SIMPLE_ARRAY,
-            'smallint'   => Types::SMALLINT,
-            'string'     => Types::STRING,
-            'text'       => Types::TEXT,
-            'time'       => Types::TIME_MUTABLE,
-            'timestamp'  => Types::DATETIME_MUTABLE,
-            'tinyblob'   => Types::BLOB,
-            'tinyint'    => Types::BOOLEAN,
-            'tinytext'   => Types::TEXT,
-            'varbinary'  => Types::BINARY,
-            'varchar'    => Types::STRING,
-            'year'       => Types::DATE_MUTABLE,
+            'bigint'             => Types::BIGINT,
+            'binary'             => Types::BINARY,
+            'blob'               => Types::BLOB,
+            'char'               => Types::STRING,
+            'date'               => Types::DATE_MUTABLE,
+            'datetime'           => Types::DATETIME_MUTABLE,
+            'decimal'            => Types::DECIMAL,
+            'double'             => Types::FLOAT,
+            'enum'               => Types::ENUM,
+            'float'              => Types::SMALLFLOAT,
+            'geometry'           => Types::GEOMETRY,
+            'geometrycollection' => Types::GEOMETRY,
+            'int'                => Types::INTEGER,
+            'integer'            => Types::INTEGER,
+            'json'               => Types::JSON,
+            'linestring'         => Types::GEOMETRY,
+            'longblob'           => Types::BLOB,
+            'longtext'           => Types::TEXT,
+            'mediumblob'         => Types::BLOB,
+            'mediumint'          => Types::INTEGER,
+            'mediumtext'         => Types::TEXT,
+            'multilinestring'    => Types::GEOMETRY,
+            'multipoint'         => Types::GEOMETRY,
+            'multipolygon'       => Types::GEOMETRY,
+            'numeric'            => Types::DECIMAL,
+            'point'              => Types::GEOMETRY,
+            'polygon'            => Types::GEOMETRY,
+            'real'               => Types::FLOAT,
+            'set'                => Types::SIMPLE_ARRAY,
+            'smallint'           => Types::SMALLINT,
+            'string'             => Types::STRING,
+            'text'               => Types::TEXT,
+            'time'               => Types::TIME_MUTABLE,
+            'timestamp'          => Types::DATETIME_MUTABLE,
+            'tinyblob'           => Types::BLOB,
+            'tinyint'            => Types::BOOLEAN,
+            'tinytext'           => Types::TEXT,
+            'varbinary'          => Types::BINARY,
+            'varchar'            => Types::STRING,
+            'year'               => Types::DATE_MUTABLE,
         ];
     }
 

src/Schema/MySQLSchemaManager.php

@@ -118,12 +118,14 @@ protected function _getPortableTableColumnDefinition(array $tableColumn): Column
     {
         $tableColumn = array_change_key_case($tableColumn, CASE_LOWER);
 
-        $dbType    = $tableColumn['type'];
-        $length    = null;
-        $scale     = 0;
-        $precision = null;
-        $fixed     = false;
-        $values    = [];
+        $dbType       = $tableColumn['type'];
+        $length       = null;
+        $scale        = 0;
+        $precision    = null;
+        $fixed        = false;
+        $values       = [];
+        $geometryType = null;
+        $srid         = null;
 
         $type = $this->platform->getDoctrineTypeMapping($dbType);
 
@@ -173,6 +175,23 @@ protected function _getPortableTableColumnDefinition(array $tableColumn): Column
                     $scale = (int) $tableColumn['numeric_scale'];
                 }
 
+                break;
+
+            case 'geometry':
+            case 'point':
+            case 'linestring':
+            case 'polygon':
+            case 'multipoint':
+            case 'multilinestring':
+            case 'multipolygon':
+            case 'geometrycollection':
+                // For MySQL, the dbType directly represents the geometry subtype
+                $geometryType = $dbType;
+
+                if (isset($tableColumn['srs_id'])) {
+                    $srid = (int) $tableColumn['srs_id'];
+                }
+
                 break;
         }
 
@@ -213,6 +232,14 @@ protected function _getPortableTableColumnDefinition(array $tableColumn): Column
         $column->setPlatformOption('charset', $tableColumn['characterset']);
         $column->setPlatformOption('collation', $tableColumn['collation']);
 
+        if ($geometryType !== null) {
+            $column->setPlatformOption('geometryType', $geometryType);
+        }
+
+        if ($srid !== null) {
+            $column->setPlatformOption('srid', $srid);
+        }
+
         return $column;
     }
 
@@ -372,7 +399,8 @@ protected function selectTableColumns(string $databaseName, ?string $tableName =
        c.EXTRA,
        c.COLUMN_COMMENT     AS comment,
        c.CHARACTER_SET_NAME AS characterset,
-       c.COLLATION_NAME     AS collation
+       c.COLLATION_NAME     AS collation,
+       c.SRS_ID             AS srs_id
 FROM information_schema.COLUMNS c
     INNER JOIN information_schema.TABLES t
         ON t.TABLE_NAME = c.TABLE_NAME