Added db tests

Author: Jakiboy

README.md

@@ -12,24 +12,6 @@ In the majority of cases, the most used build-in function with underscore are re
 composer require floatphp/classes
 ```
 
-## Contributing:
-
-Please read [CONTRIBUTING.md](https://github.com/floatphp/Classes/blob/master/CONTRIBUTING.md) for details on our code of conduct, and the process for submitting pull requests to us.
-
-## Versioning:
-
-We use [SemVer](http://semver.org/) for versioning. For the versions available, see the [tags on this repository](https://github.com/floatphp/Classes/tags). 
-
-## Authors:
-
-* **Jihad Sinnaour** - [Jakiboy](https://github.com/Jakiboy) (*Initial work*)
-
-See also the full list of [contributors](https://github.com/floatphp/Classes/contributors) who participated in this project. Any suggestions (Pull requests) are welcome!
-
-## License:
-
-This project is licensed under the MIT License - see the [LICENSE](https://github.com/floatphp/Classes/blob/master/LICENSE) file for details.
-
 ## ⭐ Support:
 
-Please give it a Star if you like the project.
+Skip the coffee! If you like the project, a **Star** would mean a lot.

composer.json

@@ -24,9 +24,17 @@
     "php": ">=8.2",
     "floatphp/interfaces": "^1.5.0"
   },
+  "require-dev": {
+    "phpunit/phpunit": "^11.5"
+  },
   "autoload": {
     "psr-4": {
       "FloatPHP\\Classes\\": "src/"
     }
+  },
+  "autoload-dev": {
+    "psr-4": {
+      "FloatPHP\\Tests\\Classes\\": "tests/"
+    }
   }
 }

src/Connection/Db.php

@@ -27,17 +27,17 @@ class Db
 {
     /**
      * @access protected
-     * @var object $pdo
-     * @var object $query
+     * @var ?PDO $pdo
+     * @var ?\PDOStatement $query
      * @var bool $isConnected
      * @var array $parameters
-     * @var object $logger
+     * @var ?LoggerInterface $logger
      */
-    protected $pdo;
-    protected $query;
-    protected $isConnected = false;
-    protected $parameters = [];
-    protected $logger;
+    protected ?PDO $pdo = null;
+    protected ?\PDOStatement $query = null;
+    protected bool $isConnected = false;
+    protected array $parameters = [];
+    protected ?LoggerInterface $logger = null;
 
     /**
      * Connect to database.
@@ -53,6 +53,17 @@ public function __construct(array $config = [], ?LoggerInterface $logger = null)
         $this->parameters = [];
     }
 
+    /**
+     * Destructor - Close connection automatically.
+     *
+     * @access public
+     * @return void
+     */
+    public function __destruct()
+    {
+        $this->close();
+    }
+
     /**
      * Close connection.
      *
@@ -62,6 +73,7 @@ public function __construct(array $config = [], ?LoggerInterface $logger = null)
     public function close() : void
     {
         $this->pdo = null;
+        $this->query = null;
     }
 
     /**
@@ -87,12 +99,10 @@ public function bind(string $bind, $value = null) : void
      */
     public function bindMore(array $bind) : void
     {
-        if ( empty($this->parameters) ) {
-            if ( TypeCheck::isArray($bind) ) {
-                $columns = Arrayify::keys($bind);
-                foreach ($columns as $i => &$column) {
-                    $this->bind($column, $bind[$column]);
-                }
+        if ( TypeCheck::isArray($bind) && !empty($bind) ) {
+            $columns = Arrayify::keys($bind);
+            foreach ($columns as $column) {
+                $this->bind($column, $bind[$column]);
             }
         }
     }
@@ -133,11 +143,14 @@ public function query(string $sql, ?array $params = null, int $mode = 2) : mixed
      * Get last inserted Id.
      *
      * @access public
-     * @return mixed
+     * @return int|false
      */
-    public function lastInsertId() : mixed
+    public function lastInsertId() : int|false
     {
-        return $this->pdo->lastInsertId();
+        if ( !$this->pdo ) {
+            return false;
+        }
+        return (int)$this->pdo->lastInsertId();
     }
 
     /**
@@ -148,6 +161,9 @@ public function lastInsertId() : mixed
      */
     public function beginTransaction() : bool
     {
+        if ( !$this->pdo ) {
+            return false;
+        }
         return $this->pdo->beginTransaction();
     }
 
@@ -159,6 +175,9 @@ public function beginTransaction() : bool
      */
     public function executeTransaction() : bool
     {
+        if ( !$this->pdo ) {
+            return false;
+        }
         return $this->pdo->commit();
     }
 
@@ -170,6 +189,9 @@ public function executeTransaction() : bool
      */
     public function rollBack() : bool
     {
+        if ( !$this->pdo ) {
+            return false;
+        }
         return $this->pdo->rollBack();
     }
 
@@ -267,7 +289,7 @@ protected function connect(array $config = []) : void
         } catch (PDOException $e) {
             $message = $e->getMessage();
             $this->log($message);
-            exit($message);
+            throw new PDOException("Database connection failed: " . $message, 0, $e);
         }
     }
 
@@ -276,10 +298,10 @@ protected function connect(array $config = []) : void
      *
      * @access protected
      * @param string $sql
-     * @param array $params
+     * @param ?array $params
      * @return void
      */
-    protected function init(string $sql, array $params = []) : void
+    protected function init(string $sql, ?array $params = null) : void
     {
         // Connect to database
         if ( !$this->isConnected ) {
@@ -292,7 +314,9 @@ protected function init(string $sql, array $params = []) : void
             $this->query = $this->pdo->prepare($sql);
 
             // Add bind parameters
-            $this->bindMore($params);
+            if ( $params !== null ) {
+                $this->bindMore($params);
+            }
 
             // Bind parameters
             if ( !empty($this->parameters) ) {
@@ -321,7 +345,7 @@ protected function init(string $sql, array $params = []) : void
             // Write into log and display exception
             $message = $e->getMessage();
             $this->log($message, $sql);
-            exit($message);
+            throw new PDOException("Query execution failed: " . $message, 0, $e);
         }
 
         // Reset bind parameters
@@ -333,9 +357,9 @@ protected function init(string $sql, array $params = []) : void
      *
      * @access protected
      * @param string $sql
-     * @return mixed
+     * @return string|false
      */
-    protected function getStatementType(string $sql = '') : mixed
+    protected function getStatementType(string $sql = '') : string|false
     {
         $sql = Stringify::replaceRegex(regex: "/\s+|\t+|\n+/", replace: ' ', subject: $sql);
         $raw = explode(' ', $sql);