Doctrine3: OPTIONAL FIXES

SHOULD BE REMOVED AFTER INTEGRATING GH-146 [1].

[1] crate/crate-pdo#146

Author: amotl

src/Crate/DBAL/Driver/PDOCrate/PDOConnection.php

@@ -23,7 +23,10 @@
 namespace Crate\DBAL\Driver\PDOCrate;
 
 use Crate\PDO\PDOCrateDB;
+use Doctrine\DBAL\Driver\PDO\Exception;
+use Doctrine\DBAL\Driver\PDO\Statement;
 use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
+use Doctrine\DBAL\Driver\Statement as StatementInterface;
 
 class PDOConnection extends PDOCrateDB implements ServerInfoAwareConnection
 {
@@ -49,4 +52,41 @@ public function requiresQueryForServerVersion()
     {
         return false;
     }
+
+    /**
+     * {@inheritDoc}
+     *
+     * References:
+     * - https://github.com/doctrine/dbal/issues/2025
+     * - https://github.com/doctrine/dbal/pull/517
+     * - https://github.com/doctrine/dbal/pull/373
+     */
+    public function prepare($sql, $options = null): StatementInterface
+    {
+        try {
+            $stmt = $this->connection->prepare($sql, $options);
+            assert($stmt instanceof PDOStatement);
+
+            return new Statement($stmt);
+        } catch (PDOException $exception) {
+            throw Exception::new($exception);
+        }
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function exec($sql): int
+    {
+        try {
+            $result = $this->connection->exec($sql);
+
+            assert($result !== false);
+
+            return $result;
+        } catch (PDOException $exception) {
+            throw Exception::new($exception);
+        }
+    }
+
 }

test/Crate/Test/DBAL/Functional/ConnectionTest.php

@@ -66,6 +66,12 @@ public function testGetDriver()
         $this->assertInstanceOf('Crate\DBAL\Driver\PDOCrate\Driver', $this->_conn->getDriver());
     }
 
+    /**
+     * @var \Doctrine\DBAL\Statement $stmt
+     *
+     * @return void
+     * @throws \Doctrine\DBAL\Exception
+     */
     public function testStatement()
     {
         $sql = 'SELECT * FROM sys.cluster';