Exception wenn Statement nicht ausgeführt werden kann

Author: rkrx

src/Kir/MySQL/Databases/MySQL.php

@@ -1,12 +1,13 @@
 <?php
 namespace Kir\MySQL\Databases;
 
-use Kir\MySQL\Builder;
-use Kir\MySQL\Database;
 use PDO;
+use Exception;
 use PDOStatement;
-use Kir\MySQL\Builder\RunnableSelect;
+use Kir\MySQL\Builder;
+use Kir\MySQL\Database;
 use UnexpectedValueException;
+use Kir\MySQL\Builder\RunnableSelect;
 
 class MySQL implements Database {
 	/**
@@ -28,10 +29,14 @@ public function __construct(PDO $pdo) {
 
 	/**
 	 * @param string $query
+	 * @throws Exception
 	 * @return PDOStatement
 	 */
 	public function query($query) {
 		$stmt = $this->pdo->query($query);
+		if(!$stmt) {
+			throw new Exception("Could not execute statement:\n{$query}");
+		}
 		$stmt->execute();
 		return $stmt;
 	}