Throw exception in case we are not able to start a transaction (#487)

staabm · Dec 14, 2022 · 246281f · 246281f
1 parent 71321fe
commit 246281f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/QueryReflection/PdoMysqlQueryReflector.php b/src/QueryReflection/PdoMysqlQueryReflector.php
@@ -49,6 +49,7 @@ protected function simulateQuery(string $queryString)
             $this->pdo->beginTransaction();
         } catch (PDOException $e) {
             // not all drivers may support transactions
+            throw new \RuntimeException('Failed to start transaction', $e->getCode(), $e);
         }
 
         try {
@@ -60,6 +61,7 @@ protected function simulateQuery(string $queryString)
                 $this->pdo->rollBack();
             } catch (PDOException $e) {
                 // not all drivers may support transactions
+                throw new \RuntimeException('Failed to rollback transaction', $e->getCode(), $e);
             }
         }
 

diff --git a/src/QueryReflection/PdoPgSqlQueryReflector.php b/src/QueryReflection/PdoPgSqlQueryReflector.php
@@ -45,6 +45,7 @@ protected function simulateQuery(string $queryString)
             $this->pdo->beginTransaction();
         } catch (PDOException $e) {
             // not all drivers may support transactions
+            throw new \RuntimeException('Failed to start transaction', $e->getCode(), $e);
         }
 
         try {
@@ -56,6 +57,7 @@ protected function simulateQuery(string $queryString)
                 $this->pdo->rollBack();
             } catch (PDOException $e) {
                 // not all drivers may support transactions
+                throw new \RuntimeException('Failed to rollback transaction', $e->getCode(), $e);
             }
         }