Fix MariaDB binary type

brick · Mar 5, 2021 · efea562 · efea562
1 parent a32f3d9
commit efea562
Show file tree

Hide file tree

Showing 2 changed files with 31 additions and 2 deletions.
diff --git a/src/Engine/DatabaseEngine.php b/src/Engine/DatabaseEngine.php
@@ -40,6 +40,26 @@ public function __construct(bool $useProxy)
      */
     abstract protected function executeQuery(string $query, array $parameters) : array;
 
+    /**
+     * Returns the syntax required to perform a ST_GeomFromText(), together with placeholders.
+     *
+     * This method may be overridden if necessary.
+     */
+    protected function getGeomFromTextSyntax(): string
+    {
+        return 'ST_GeomFromText(?, ?)';
+    }
+
+    /**
+     * Returns the syntax required to perform a ST_GeomFromWKB(), together with placeholders.
+     *
+     * This method may be overridden if necessary.
+     */
+    protected function getGeomFromWKBSyntax(): string
+    {
+        return 'ST_GeomFromWKB(?, ?)';
+    }
+
     /**
      * Builds and executes a SQL query for a GIS function.
      *
@@ -61,10 +81,10 @@ private function query(string $function, array $parameters, bool $returnsGeometr
         foreach ($parameters as $parameter) {
             if ($parameter instanceof Geometry) {
                 if ($parameter->isEmpty()) {
-                    $queryParameters[] = 'ST_GeomFromText(?, ?)';
+                    $queryParameters[] = $this->getGeomFromTextSyntax();
                     $queryValues[] = new GeometryParameter($parameter, false);
                 } else {
-                    $queryParameters[] = 'ST_GeomFromWKB(?, ?)';
+                    $queryParameters[] = $this->getGeomFromWKBSyntax();
                     $queryValues[] = new GeometryParameter($parameter, true);
                 }
             } else {

diff --git a/src/Engine/PDOEngine.php b/src/Engine/PDOEngine.php
@@ -94,4 +94,13 @@ protected function executeQuery(string $query, array $parameters) : array
 
         return $result;
     }
+
+    protected function getGeomFromWKBSyntax(): string
+    {
+        if ($this->pdo->getAttribute(\PDO::ATTR_DRIVER_NAME) === 'mysql') {
+            return 'ST_GeomFromWKB(_binary ?, ?)';
+        }
+
+        return parent::getGeomFromWKBSyntax();
+    }
 }