src/Database/Mysql/Connection.php

@@ -19,9 +19,15 @@ class Connection implements IConnection
             $socket = (string) ini_get('mysqli.default_socket');
         }
 
-        mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
         $this->connection = new mysqli($host, $user, $password, $db, $port, $socket);
-        $this->connection->set_charset('utf8mb4');
+
+        if ($this->connection->connect_error) {
+            throw new \Exception('Connection failed: ' . $this->connection->connect_error);
+        }
+
+        if (!$this->connection->set_charset('utf8mb4')) {
+            throw new \Exception($this->connection->error);
+        }
     }
 
     public function __destruct()
@@ -31,24 +37,30 @@ class Connection implements IConnection
 
     public function startTransaction(): void
     {
-        $this->connection->autocommit(false);
+        if (!$this->connection->autocommit(false)) {
+            throw new \Exception($this->connection->error);
+        }
     }
 
     public function commit(): void
     {
-        $this->connection->commit();
-        $this->connection->autocommit(true);
+        if (!$this->connection->commit() || !$this->connection->autocommit(true)) {
+            throw new \Exception($this->connection->error);
+        }
     }
 
     public function rollback(): void
     {
-        $this->connection->rollback();
-        $this->connection->autocommit(true);
+        if (!$this->connection->rollback() || !$this->connection->autocommit(true)) {
+            throw new \Exception($this->connection->error);
+        }
     }
 
     public function query(string $query): ?IResultSet
     {
-        $result = $this->connection->query($query);
+        if (!($result = $this->connection->query($query))) {
+            throw new \Exception($this->connection->error . '. Query: ' . $query);
+        }
 
         if ($result !== true) {
             return new ResultSet($result);
@@ -59,7 +71,9 @@ class Connection implements IConnection
 
     public function multiQuery(string $query): array
     {
-        $this->connection->multi_query($query);
+        if (!$this->connection->multi_query($query)) {
+            throw new \Exception($this->connection->error . '. Query: ' . $query);
+        }
 
         $ret = [];
         do {
@@ -72,12 +86,18 @@ class Connection implements IConnection
             $this->connection->more_results();
         } while ($this->connection->next_result());
 
+        if ($this->connection->error) {
+            throw new \Exception($this->connection->error  . '. Query: ' . $query);
+        }
+
         return $ret;
     }
 
     public function prepare(string $query): IStatement
     {
-        $stmt = $this->connection->prepare($query);
+        if (!($stmt = $this->connection->prepare($query))) {
+            throw new \Exception($this->connection->error . '. Query: ' . $query);
+        }
 
         return new Statement($stmt);
     }